event

Documentation

Index

• type Event
• type Handler
• type Message
  • func NewMessage(key string, value []byte) *Message
  • func (m *Message) GetKey() string
  • func (m *Message) GetValue() []byte
• type Receiver
• type Sender

Types

type Event

type Event interface {
	GetKey() string
	GetValue() []byte
}

type Handler

type Handler func(context.Context, Event) error

type Message

type Message struct {
	Key   string
	Value []byte
}

func NewMessage

func NewMessage(key string, value []byte) *Message

func (*Message) GetKey

func (m *Message) GetKey() string

func (*Message) GetValue

func (m *Message) GetValue() []byte

type Receiver

type Receiver interface {
	Receive(ctx context.Context, handler Handler) error
	Close() error
}

type Sender

type Sender interface {
	Send(ctx context.Context, topic string, msg Event) error
	Close() error
}