kafka

Documentation

Index

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

Types

type LogQueue

type LogQueue struct {
}

func (*LogQueue) GetName

func (k *LogQueue) GetName() string

func (*LogQueue) Initialize

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

func (*LogQueue) SendMessage

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