watch

Documentation

Index

• func DecodeTxnOpaques(ctx context.Context, txn *rkcypb.ApecsTxn, ...) ([]byte, error)
• func Start(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)
• func WatchResultTopics(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)

Functions

func DecodeTxnOpaques

func DecodeTxnOpaques(ctx context.Context, txn *rkcypb.ApecsTxn, concernHandlers rkcy.ConcernHandlers, pjOpts *protojson.MarshalOptions) ([]byte, error)

func Start

func Start(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	cncHdlrs rkcy.ConcernHandlers,
	watchDecode bool,
)

func WatchResultTopics

func WatchResultTopics(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	cncHdlrs rkcy.ConcernHandlers,
	watchDecode bool,
)