Versions in this module Expand all Collapse all v0 v0.3.8 Jul 6, 2026 v0.3.2 May 13, 2026 Changes in this version + var AckFactory = sdk.NewTypedStepFactory("step.eventbus.ack", &emptypb.Empty{}, &eventbusv1.AckRequest{}, AckHandler) + var ConsumeFactory = sdk.NewTypedStepFactory("step.eventbus.consume", &emptypb.Empty{}, &eventbusv1.ConsumeRequest{}, ...) + var PublishFactory = sdk.NewTypedStepFactory("step.eventbus.publish", &emptypb.Empty{}, &eventbusv1.PublishRequest{}, ...) + func AckHandler(ctx context.Context, ...) (*sdk.TypedStepResult[*eventbusv1.AckResponse], error) + func All() []sdk.TypedStepProvider + func ConsumeHandler(ctx context.Context, ...) (*sdk.TypedStepResult[*eventbusv1.ConsumeResponse], error) + func PublishHandler(ctx context.Context, ...) (*sdk.TypedStepResult[*eventbusv1.PublishResponse], error)
Go to main page