emitter

type CronTickerWorkflowRequest struct {
	QueueID   string `validate:"required"`
	EmitterID string `validate:"required"`
}

type EmitterState struct {
	EmitCount int64
}

type EmitterWorkflowRequest struct {
	QueueID   string `validate:"required"`
	EmitterID string `validate:"required"`
	Version   string `validate:"required"`

	State *EmitterState
}

type EnsureRunningRequest struct{}

type EnsureRunningResponse struct {
	Running   bool
	EmitterID string
	Mode      string
	EmitCount int64
	Stopped   bool
	Fired     bool
}

type Params struct {
	fx.In

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

type PauseRequest struct{}

type PauseResponse struct {
	Paused bool
}

type RestartRequest struct{}

type RestartResponse struct{}

type ResumeRequest struct{}

type ResumeResponse struct {
	Paused bool
}

type StatusRequest struct{}

type StatusResponse struct {
	EmitterID string
	QueueID   string
	EmitCount int64
	Stopped   bool
}

type StopRequest struct{}

type StopResponse struct{}

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