kafka

Documentation

Index

• type KafkaQueue
  • func (k *KafkaQueue) GetName() string
  • func (k *KafkaQueue) Initialize(configuration util.Configuration, prefix string) (err error)
  • func (k *KafkaQueue) SendMessage(key string, message proto.Message) (err error)

Types

type KafkaQueue

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

func (*KafkaQueue) GetName

func (k *KafkaQueue) GetName() string

func (*KafkaQueue) Initialize

func (k *KafkaQueue) Initialize(configuration util.Configuration, prefix string) (err error)

func (*KafkaQueue) SendMessage

func (k *KafkaQueue) SendMessage(key string, message proto.Message) (err error)