memstreamer

Documentation

Index

• type Option
  • func WithClock(clock clock.Clock) Option
• type Stream
  • func (s *Stream) Close() error
  • func (s *Stream) Recv(ctx context.Context) (*workflow.Event, workflow.Ack, error)
  • func (s *Stream) Send(ctx context.Context, recordID int64, statusType int, ...) error
• type StreamConstructor
  • func New(opts ...Option) *StreamConstructor
  • func (s StreamConstructor) NewConsumer(topic string, name string, opts ...workflow.ConsumerOption) workflow.Consumer
  • func (s StreamConstructor) NewProducer(topic string) workflow.Producer

Types

type Option

type Option func(o *options)

func WithClock

func WithClock(clock clock.Clock) Option

type Stream

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

func (*Stream) Close

func (s *Stream) Close() error

func (*Stream) Recv

func (s *Stream) Recv(ctx context.Context) (*workflow.Event, workflow.Ack, error)

func (*Stream) Send

func (s *Stream) Send(ctx context.Context, recordID int64, statusType int, headers map[workflow.Header]string) error

type StreamConstructor

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

func New

func New(opts ...Option) *StreamConstructor

func (StreamConstructor) NewConsumer

func (s StreamConstructor) NewConsumer(topic string, name string, opts ...workflow.ConsumerOption) workflow.Consumer

func (StreamConstructor) NewProducer

func (s StreamConstructor) NewProducer(topic string) workflow.Producer