Documentation
¶
Index ¶
- type Client
- func (c *Client) CreateEmitter(ctx context.Context, req *CreateEmitterRequest) (*app.QueueEmitter, error)
- func (c *Client) DeleteEmitter(ctx context.Context, emitterID string) error
- func (c *Client) EnsureRunning(ctx context.Context, emitterID string) (*emitter.EnsureRunningResponse, error)
- func (c *Client) GetEmitter(ctx context.Context, emitterID string) (*app.QueueEmitter, error)
- func (c *Client) GetEmittersByQueueID(ctx context.Context, queueID string) ([]app.QueueEmitter, error)
- func (c *Client) PauseEmitter(ctx context.Context, emitterID string) (*app.QueueEmitter, error)
- func (c *Client) RestartEmitterWorkflow(ctx context.Context, emitterID string) (*app.QueueEmitter, error)
- func (c *Client) ResumeEmitter(ctx context.Context, emitterID string) (*app.QueueEmitter, error)
- type CreateEmitterRequest
- type Params
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) CreateEmitter ¶
func (c *Client) CreateEmitter(ctx context.Context, req *CreateEmitterRequest) (*app.QueueEmitter, error)
func (*Client) DeleteEmitter ¶
func (*Client) EnsureRunning ¶
func (*Client) GetEmitter ¶
func (*Client) GetEmittersByQueueID ¶
func (*Client) PauseEmitter ¶
func (*Client) RestartEmitterWorkflow ¶
func (*Client) ResumeEmitter ¶
type CreateEmitterRequest ¶
type CreateEmitterRequest struct {
QueueID string `validate:"required"`
Name string `validate:"required"`
Description string
// Mode determines if this is a recurring cron emitter or a one-shot scheduled emitter
Mode app.QueueEmitterMode `validate:"required"`
// For cron mode: the cron schedule expression (e.g., "0 * * * *")
CronSchedule string
// For scheduled mode: when to fire the signal
ScheduledAt *time.Time
SignalType signal.SignalType `validate:"required"`
SignalTemplate signal.Signal
}
Click to show internal directories.
Click to hide internal directories.