reflexstreamer

Documentation

Index

• func New(writer, reader *sql.DB, table *rsql.EventsTableInt, ...) workflow.EventStreamer
• type Consumer
  • func (c Consumer) Close() error
  • func (c Consumer) Recv(ctx context.Context) (*workflow.Event, workflow.Ack, error)
• type EventType
  • func (ev EventType) ReflexType() int
• type Producer
  • func (p Producer) Close() error
  • func (p Producer) Send(ctx context.Context, recordID int64, statusType int, ...) error

Functions

func New

func New(writer, reader *sql.DB, table *rsql.EventsTableInt, cursorStore reflex.CursorStore) workflow.EventStreamer

Types

type Consumer

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

func (Consumer) Close

func (c Consumer) Close() error

func (Consumer) Recv

func (c Consumer) Recv(ctx context.Context) (*workflow.Event, workflow.Ack, error)

type EventType

type EventType int

func (EventType) ReflexType

func (ev EventType) ReflexType() int

type Producer

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

func (Producer) Close

func (p Producer) Close() error

func (Producer) Send

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