client

package
v0.19.850 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 25, 2026 License: AGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

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 New

func New(params Params) *Client

func (*Client) CreateEmitter

func (c *Client) CreateEmitter(ctx context.Context, req *CreateEmitterRequest) (*app.QueueEmitter, error)

func (*Client) DeleteEmitter

func (c *Client) DeleteEmitter(ctx context.Context, emitterID string) error

func (*Client) EnsureRunning

func (c *Client) EnsureRunning(ctx context.Context, emitterID string) (*emitter.EnsureRunningResponse, error)

func (*Client) GetEmitter

func (c *Client) GetEmitter(ctx context.Context, emitterID string) (*app.QueueEmitter, error)

func (*Client) GetEmittersByQueueID

func (c *Client) GetEmittersByQueueID(ctx context.Context, queueID string) ([]app.QueueEmitter, error)

func (*Client) PauseEmitter

func (c *Client) PauseEmitter(ctx context.Context, emitterID string) (*app.QueueEmitter, error)

func (*Client) RestartEmitterWorkflow

func (c *Client) RestartEmitterWorkflow(ctx context.Context, emitterID string) (*app.QueueEmitter, error)

func (*Client) ResumeEmitter

func (c *Client) ResumeEmitter(ctx context.Context, emitterID string) (*app.QueueEmitter, error)

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
}

type Params

type Params struct {
	fx.In

	DB      *gorm.DB `name:"psql"`
	Cfg     *internal.Config
	TClient temporalclient.Client
	L       *zap.Logger
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL