activities

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

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

type EmitSignalResponse struct {
	QueueSignalID string
	WorkflowID    string
	Skipped       bool
}

type GetEmitterRequest struct {
	EmitterID string `validate:"required"`
}

type MarkEmitterFiredRequest struct {
	EmitterID string `validate:"required"`
}

type MarkEmitterFiredResponse struct {
	Success bool
}

type Params struct {
	fx.In

	V           *validator.Validate
	DB          *gorm.DB `name:"psql"`
	QueueClient *queueclient.Client
	TClient     temporalclient.Client
	L           *zap.Logger
}

type TerminateWorkflowRequest struct {
	WorkflowID string `validate:"required"`
	Namespace  string `validate:"required"`
	Reason     string
}

type UpdateEmitterStatsRequest struct {
	EmitterID string `validate:"required"`
}

type UpdateEmitterStatsResponse struct {
	EmitCount int64
}

type UpdateEmitterStatusRequest struct {
	EmitterID string     `validate:"required"`
	Status    app.Status `validate:"required"`
}

type UpdateEmitterStatusResponse struct{}

type UpdateSignalEmitterRequest struct {
	QueueSignalID string `validate:"required"`
	EmitterID     string `validate:"required"`
}

type UpdateSignalEmitterResponse struct {
	Success bool
}