Documentation
¶
Index ¶
- type Activities
- func (a *Activities) CreateQueueSignal(ctx context.Context, req *CreateQueueSignalRequest) (*app.QueueSignal, error)
- func (a *Activities) IncrementQueueSignalExecutionCount(ctx context.Context, req *IncrementQueueSignalExecutionCountRequest) error
- func (a *Activities) UpdateQueueSignalRunID(ctx context.Context, req *UpdateQueueSignalRunIDRequest) error
- type CreateQueueSignalRequest
- type IncrementQueueSignalExecutionCountRequest
- type Params
- type UpdateQueueSignalRunIDRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Activities ¶
type Activities struct {
// contains filtered or unexported fields
}
func New ¶
func New(params Params) *Activities
func (*Activities) CreateQueueSignal ¶
func (a *Activities) CreateQueueSignal(ctx context.Context, req *CreateQueueSignalRequest) (*app.QueueSignal, error)
@temporal-gen-v2 activity
func (*Activities) IncrementQueueSignalExecutionCount ¶ added in v0.19.894
func (a *Activities) IncrementQueueSignalExecutionCount(ctx context.Context, req *IncrementQueueSignalExecutionCountRequest) error
@temporal-gen-v2 activity @start-to-close-timeout 1m
func (*Activities) UpdateQueueSignalRunID ¶ added in v0.19.911
func (a *Activities) UpdateQueueSignalRunID(ctx context.Context, req *UpdateQueueSignalRunIDRequest) error
@temporal-gen-v2 activity @start-to-close-timeout 10s
type CreateQueueSignalRequest ¶
type CreateQueueSignalRequest struct {
QueueID string `json:"queue_id" validate:"required"`
Signal signal.Signal `json:"signal" validate:"required"`
// OwnerID and OwnerType are optional — when set they populate the polymorphic
// owner association on the created QueueSignal so no separate UPDATE is needed.
OwnerID string `json:"owner_id,omitempty"`
OwnerType string `json:"owner_type,omitempty"`
}
type IncrementQueueSignalExecutionCountRequest ¶ added in v0.19.894
type IncrementQueueSignalExecutionCountRequest struct {
QueueSignalID string `json:"queue_signal_id" validate:"required"`
}
type UpdateQueueSignalRunIDRequest ¶ added in v0.19.911
Source Files
¶
Click to show internal directories.
Click to hide internal directories.