kafka

Documentation

Index

• func NewKafka(_c interface{}) (kafka.Kafka, error)
• type Kafka
  • func (k *Kafka) Close() error
  • func (k *Kafka) CommitMessages(ctx context.Context, m _kafka.Message) error
  • func (k *Kafka) DialContext(ctx context.Context, network, addr string) (*_kafka.Conn, error)
  • func (k *Kafka) FetchMessage(ctx context.Context) (_kafka.Message, error)
  • func (k *Kafka) NewReader(t []string) *_kafka.Reader
  • func (k *Kafka) ReadMessage(ctx context.Context) (_kafka.Message, error)
  • func (k *Kafka) WriteMessages(ctx context.Context, m _kafka.Message) error

Functions

func NewKafka

func NewKafka(_c interface{}) (kafka.Kafka, error)

Types

type Kafka

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

func (*Kafka) Close

func (k *Kafka) Close() error

func (*Kafka) CommitMessages

func (k *Kafka) CommitMessages(ctx context.Context, m _kafka.Message) error

func (*Kafka) DialContext

func (k *Kafka) DialContext(ctx context.Context, network, addr string) (*_kafka.Conn, error)

func (*Kafka) FetchMessage

func (k *Kafka) FetchMessage(ctx context.Context) (_kafka.Message, error)

func (*Kafka) NewReader

func (k *Kafka) NewReader(t []string) *_kafka.Reader

func (*Kafka) ReadMessage

func (k *Kafka) ReadMessage(ctx context.Context) (_kafka.Message, error)

func (*Kafka) WriteMessages

func (k *Kafka) WriteMessages(ctx context.Context, m _kafka.Message) error