outbox

Documentation

Index

• func InitConsumers(cnfs []*config.KafkaConfig, pusher core.Hub, twl *tw.TimingWheel)
• type Consumers
• type KV
  • func (kv *KV) GetData() []byte
  • func (kv *KV) GetMetaData() []byte
  • func (kv *KV) GetTopic() string

Functions

func InitConsumers

func InitConsumers(cnfs []*config.KafkaConfig, pusher core.Hub, twl *tw.TimingWheel)

Types

type Consumers

type Consumers struct {
	// contains filtered or unexported fields
}

type KV

type KV struct {
	Key []byte
	Val []byte
}

func (*KV) GetData

func (kv *KV) GetData() []byte

func (*KV) GetMetaData

func (kv *KV) GetMetaData() []byte

func (*KV) GetTopic

func (kv *KV) GetTopic() string