stream

Documentation

Index

• func NewLogEventToConsoleFn(logFormat string) (func(e *eventspb.BusEvent), error)
• func ReadEvents(ctx context.Context, cancel context.CancelFunc, wg *sync.WaitGroup, ...) error
• func Run(batchSize uint, party, market, serverAddr, logFormat string, reconnect bool, ...) error
• func WaitSig(ctx context.Context, cancel func())

Functions

func NewLogEventToConsoleFn

func NewLogEventToConsoleFn(logFormat string) (func(e *eventspb.BusEvent), error)

NewLogEventToConsoleFn returns a common logging function for use across tools that deal with events.

func ReadEvents

func ReadEvents(
	ctx context.Context,
	cancel context.CancelFunc,
	wg *sync.WaitGroup,
	batchSize uint,
	party, market, serverAddr string,
	handleEvent func(event *eventspb.BusEvent),
	reconnect bool,
	types []string,
) error

ReadEvents reads all the events from the server.

func Run

func Run(
	batchSize uint,
	party, market, serverAddr, logFormat string,
	reconnect bool,
	types []string,
) error

Run is the main function of `stream` package.

func WaitSig

func WaitSig(ctx context.Context, cancel func())

WaitSig waits until Terminate or interrupt event is received.