kafkanotify

Documentation

Index

• type Notify
  • func NewKafkaNotify(host string, port int, topic string, partition int) *Notify
  • func (n *Notify) Close() error
  • func (n *Notify) Connect(ctx context.Context) (err error)
  • func (n *Notify) Notify(_ context.Context, message notify.Message) error

Types

type Notify

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

func NewKafkaNotify

func NewKafkaNotify(host string, port int, topic string, partition int) *Notify

func (*Notify) Close

func (n *Notify) Close() error

func (*Notify) Connect

func (n *Notify) Connect(ctx context.Context) (err error)

func (*Notify) Notify

func (n *Notify) Notify(_ context.Context, message notify.Message) error