models

Documentation

Index

• type ExitCallback
• type InitCallback
• type JoinCallback
• type ProcessCallback
• type ProcessorCallbacks
• type Record
  • func NewRecord(key string, value []byte) *Record
  • func NewRecordWithConsumerMessage(msg *sarama.ConsumerMessage) *Record
  • func (r *Record) Key() string
  • func (r *Record) Value() []byte

Types

type ExitCallback

type ExitCallback func()

type InitCallback

type InitCallback func() error

type JoinCallback

type JoinCallback func(ctx context.Context, leftRecord *Record, rightRecord *Record) error

type ProcessCallback

type ProcessCallback func(ctx context.Context, record *Record) error

type ProcessorCallbacks

type ProcessorCallbacks struct {
	OnInit  InitCallback
	Process ProcessCallback
	Join    JoinCallback
	OnExit  ExitCallback
}

type Record

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

func NewRecord

func NewRecord(key string, value []byte) *Record

func NewRecordWithConsumerMessage

func NewRecordWithConsumerMessage(msg *sarama.ConsumerMessage) *Record

func (*Record) Key

func (r *Record) Key() string

func (*Record) Value

func (r *Record) Value() []byte