middlewares

Documentation

Index

• type Asynchronizer
• type EventTargetWrapper
  • func NewEventTargetWrapper(target base.EventTarget) *EventTargetWrapper
  • func (s *EventTargetWrapper) Close() error
  • func (s *EventTargetWrapper) Push(input base.EventBatch) error

Types

type Asynchronizer

type Asynchronizer interface {
	Close() error
	Push(input base.EventBatch) error
}

Asynchronizer is tasks.asynchronousSnapshotState for abstract2. However, as there is no way to tell if a batch contains "non-row" events, push is always asynchronous.

type EventTargetWrapper

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

func NewEventTargetWrapper

func NewEventTargetWrapper(target base.EventTarget) *EventTargetWrapper

func (*EventTargetWrapper) Close

func (s *EventTargetWrapper) Close() error

func (*EventTargetWrapper) Push

func (s *EventTargetWrapper) Push(input base.EventBatch) error