emitter

type CheckCANRequest struct{}

type CheckCANResponse struct {
	WorkflowType  string `json:"workflow_type"`
	Namespace     string `json:"namespace"`
	HistoryLength int    `json:"history_length"`
	HistoryMax    int    `json:"history_max"`
	Restarting    bool   `json:"restarting"`
}

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
	MetricsWriter metrics.Writer
}

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
}