apecs

Documentation

Index

• Constants
• func CodeTranslate(code rkcypb.Code) grpc_codes.Code
• func ExecuteTxnAsync(ctx context.Context, plat *platform.Platform, txn *rkcy.Txn) error
• func ExecuteTxnSync(ctx context.Context, plat *platform.Platform, txn *rkcy.Txn, ...) (*rkcy.ResultProto, error)
• func ProduceComplete(ctx context.Context, plat *platform.Platform, rtxn *rkcy.RtApecsTxn) error
• func ProduceCurrentStep(ctx context.Context, wg *sync.WaitGroup, aprod *stream.ApecsProducer, ...) error
• func ProduceError(ctx context.Context, plat *platform.Platform, rtxn *rkcy.RtApecsTxn, ...) error
• func ProduceResponse(ctx context.Context, plat *platform.Platform, respBrokers string, ...) error
• func SetStepResult(rslt *rkcypb.ApecsTxn_Step_Result, err error)
• func StartApecsConsumer(ctx context.Context, plat *platform.Platform, storageTarget string, ...)
• func StartApecsRunner(ctx context.Context, plat *platform.Platform, storageTarget string, ...)

Constants

const DEFAULT_SYNC_TIMEOUT time.Duration = time.Minute * 5

Functions

func CodeTranslate

func CodeTranslate(code rkcypb.Code) grpc_codes.Code

func ExecuteTxnAsync

func ExecuteTxnAsync(
	ctx context.Context,
	plat *platform.Platform,
	txn *rkcy.Txn,
) error

func ExecuteTxnSync

func ExecuteTxnSync(
	ctx context.Context,
	plat *platform.Platform,
	txn *rkcy.Txn,
	timeout time.Duration,
) (*rkcy.ResultProto, error)

func ProduceComplete

func ProduceComplete(
	ctx context.Context,
	plat *platform.Platform,
	rtxn *rkcy.RtApecsTxn,
) error

func ProduceCurrentStep

func ProduceCurrentStep(
	ctx context.Context,
	wg *sync.WaitGroup,
	aprod *stream.ApecsProducer,
	txn *rkcypb.ApecsTxn,
	traceParent string,
) error

func ProduceError

func ProduceError(
	ctx context.Context,
	plat *platform.Platform,
	rtxn *rkcy.RtApecsTxn,
	step *rkcypb.ApecsTxn_Step,
	code rkcypb.Code,
	logToResult bool,
	msg string,
) error

func ProduceResponse

func ProduceResponse(
	ctx context.Context,
	plat *platform.Platform,
	respBrokers string,
	rtxn *rkcy.RtApecsTxn,
) error

func SetStepResult

func SetStepResult(rslt *rkcypb.ApecsTxn_Step_Result, err error)

func StartApecsConsumer

func StartApecsConsumer(
	ctx context.Context,
	plat *platform.Platform,
	storageTarget string,
	consumerBrokers string,
	fullTopic string,
	partition int32,
	bailoutCh chan<- bool,
)

func StartApecsRunner

func StartApecsRunner(
	ctx context.Context,
	plat *platform.Platform,
	storageTarget string,
	consumerBrokers string,
	tp *rkcy.TopicParts,
	partition int32,
	bailoutCh chan<- bool,
)