Versions in this module Expand all Collapse all v0 v0.1.1 Sep 13, 2020 Changes in this version + type Cache struct + func NewCache() *Cache + func (this *Cache) Clean() + func (this *Cache) Get(key string) interface{} + func (this *Cache) GetInt(key string) int64 + func (this *Cache) GetMap(key string) map[string]string + func (this *Cache) GetMapInterface(key string) map[string]interface{} + func (this *Cache) GetMapInterfaceList(key string) []map[string]interface{} + func (this *Cache) GetString(key string) string + func (this *Cache) GetStringList(key string) []string + func (this *Cache) Set(key string, value interface{}, expiration time.Duration) + func (this *Cache) SetInt(key string, value int64, expiration time.Duration) + func (this *Cache) SetMap(key string, value map[string]string, expiration time.Duration) + func (this *Cache) SetMapInterface(key string, value map[string]interface{}, expiration time.Duration) + func (this *Cache) SetMapInterfaceList(key string, value []map[string]interface{}, expiration time.Duration) + func (this *Cache) SetString(key, value string, expiration time.Duration) + func (this *Cache) SetStringList(key string, value []string, expiration time.Duration) + type Kafka struct + Conn *kafka.Conn + func NewKafka(topic string, partition int) (*Kafka, error) + func (this *Kafka) Close() + func (this *Kafka) LookupPartitions() ([]kafka.Partition, error) + func (this *Kafka) ReadMessage() ([]byte, error) + func (this *Kafka) ReadMessages() ([][]byte, error) + func (this *Kafka) SetReadOffset(offset int64) error + func (this *Kafka) SetReadOffsetByTime(tm time.Time) error + func (this *Kafka) WriteMessage(msg []byte) (int, error) + func (this *Kafka) WriteMessages(msglist [][]byte) (int, error)
Go to main page