event

Documentation

Index

• type Event
• type Header
• type Producer
• type Transactional
  • func NewTransactional(ctx context.Context, producer Producer) *Transactional
  • func (t *Transactional) Begin(opt ...*sql.TxOptions) (db uow.Txn, err error)
  • func (t *Transactional) Commit() error
  • func (t *Transactional) Rollback() error
  • func (t *Transactional) Send(msg ...Event) error
• type TransactionalProducer
  • func NewTransactionalProducer(wrap Producer, keys []string) *TransactionalProducer
  • func (t *TransactionalProducer) BatchSend(ctx context.Context, msg []Event) error
  • func (t *TransactionalProducer) Close() error
  • func (t *TransactionalProducer) Send(ctx context.Context, msg Event) error

Types

type Event

type Event interface {
	Header() Header
	Key() string
	Value() []byte
}

type Header

type Header interface {
	Get(key string) string
	Set(key string, value string)
	Keys() []string
}

type Producer

type Producer interface {
	io.Closer
	Send(ctx context.Context, msg Event) error
	BatchSend(ctx context.Context, msg []Event) error
}

type Transactional

type Transactional struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewTransactional

func NewTransactional(ctx context.Context, producer Producer) *Transactional

func (*Transactional) Begin

func (t *Transactional) Begin(opt ...*sql.TxOptions) (db uow.Txn, err error)

func (*Transactional) Commit

func (t *Transactional) Commit() error

func (*Transactional) Rollback

func (t *Transactional) Rollback() error

func (*Transactional) Send

func (t *Transactional) Send(msg ...Event) error

type TransactionalProducer

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

func NewTransactionalProducer

func NewTransactionalProducer(wrap Producer, keys []string) *TransactionalProducer

func (*TransactionalProducer) BatchSend

func (t *TransactionalProducer) BatchSend(ctx context.Context, msg []Event) error

func (*TransactionalProducer) Close

func (t *TransactionalProducer) Close() error

func (*TransactionalProducer) Send

func (t *TransactionalProducer) Send(ctx context.Context, msg Event) error