transmithandler

Documentation

Index

• type Transmit
  • func (t Transmit) Send(key, val []byte, topic string) (partition int32, offset int64, err error)
• type TransmitHandler
  • func New(kfkConn sarama.Client) (*TransmitHandler, error)
  • func (th *TransmitHandler) Close()
  • func (th *TransmitHandler) Outgoing() <-chan Transmit

Types

type Transmit

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

func (Transmit) Send

func (t Transmit) Send(key, val []byte, topic string) (partition int32, offset int64, err error)

type TransmitHandler

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

func New

func New(kfkConn sarama.Client) (*TransmitHandler, error)

func (*TransmitHandler) Close

func (th *TransmitHandler) Close()

func (*TransmitHandler) Outgoing

func (th *TransmitHandler) Outgoing() <-chan Transmit