kafka

Documentation

Index

• type KafkaDriver
  • func (d *KafkaDriver) Close(context.Context) error
  • func (d *KafkaDriver) Init(context.Context) error
  • func (d *KafkaDriver) Prepare() error
  • func (d *KafkaDriver) Send(key, data []byte) error

Types

type KafkaDriver

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

func (*KafkaDriver) Close

func (d *KafkaDriver) Close(context.Context) error

func (*KafkaDriver) Init

func (d *KafkaDriver) Init(context.Context) error

func (*KafkaDriver) Prepare

func (d *KafkaDriver) Prepare() error

func (*KafkaDriver) Send

func (d *KafkaDriver) Send(key, data []byte) error