activities

package

v0.19.771 Latest Latest Go to latest Published: Feb 7, 2026 License: AGPL-3.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func AwaitCreateQueueSignal(ctx workflow.Context, sig signal.Signal, req *CreateQueueSignalRequest) (*app.QueueSignal, error)

NOTE(jm): temporal-gen does not support activities with multiple args

func AwaitGetQueueSignalSignal(ctx workflow.Context, req *GetQueueSignalSignalRequest) (signal.Signal, error)

NOTE(jm): signal.Signal is not compatible with temporal-gen

func AwaitGetQueueSignalSignalByQueueSignalID(ctx workflow.Context, queueSignalID string) (signal.Signal, error)

type Activities struct {
	// contains filtered or unexported fields
}

func New(params Params) *Activities

func (a *Activities) CreateQueueSignal(ctx context.Context, sig signal.Signal, req *CreateQueueSignalRequest) (*app.QueueSignal, error)

func (a *Activities) GetQueue(ctx context.Context, req *GetQueueRequest) (*app.Queue, error)

@temporal-gen activity @by-id QueueID

func (a *Activities) GetQueueSignal(ctx context.Context, req *GetQueueSignalRequest) (*app.QueueSignal, error)

@temporal-gen activity @by-id QueueSignalID

func (a *Activities) GetQueueSignalSignal(ctx context.Context, req *GetQueueSignalSignalRequest) (signal.Signal, error)

func (a *Activities) GetQueueSignals(ctx context.Context, req *GetQueueSignalsRequest) ([]*app.QueueSignal, error)

@temporal-gen activity @by-id QueueID

type CreateQueueSignalRequest struct {
	QueueID string `validate:"required"`
}

type GetQueueRequest struct {
	QueueID string `validate:"required"`
}

type GetQueueSignalRequest struct {
	QueueSignalID string `validate:"required"`
}

type GetQueueSignalSignalRequest struct {
	QueueSignalID string `validate:"required"`
}

type GetQueueSignalsRequest struct {
	QueueID string `validate:"required"`
}

type Params struct {
	fx.In

	V  *validator.Validate
	DB *gorm.DB `name:"psql"`
}