apecs

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,
	timeout time.Duration,
) (*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,
	txn *rkcypb.ApecsTxn,
	traceParent string,
) error

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(
	ctx context.Context,
	plat *platform.Platform,
	respBrokers string,
	rtxn *rkcy.RtApecsTxn,
) error

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

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

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