state

type AddRealtedTaskToEventReuqest struct {
	EventID string
	Task    []string
}

type ElectTasksRequest struct {
	Tasks []task.Task
}

type Options struct {
	Name string
	// EventChan to write new event to the channel once a chance was applied
	EventChan chan *event.Event
	// CommandsChan to receive commands to create new change channel
	CommandsChan chan string
	// StateUpdateRequest to receive updated on the state in realtime
	StateUpdateRequest chan UpdateRequest
	Logger             logger.Logger
	WG                 *sync.WaitGroup
}

type ServiceState struct {
}

type State interface {
	Copy() (State, error)
	Tasks() map[string]TaskState
	Events() []event.Event
	Services() []ServiceState
	StateBytes() ([]byte, error)
	EventBytes() ([]byte, error)
	StartProcess()
	GetStepOutputInto(step string, target interface{}) error
}

type TaskState struct {
	State  string    `yaml:"state"`
	Status string    `yaml:"status"`
	Task   task.Task `yaml:"task"`
	Times  TaskTimes `yaml:"times"`
	Output string    `yaml:"output"`
	Error  error     `yaml:"error"`
	Logger string    `yaml:"logger"`
}

type TaskTimes struct {
	Started  time.Time `yaml:"started"`
	Finished time.Time `yaml:"finished"`
}

type UpdateRequest struct {
	Metadata                     UpdateRequestMetadata
	ElectTasksRequest            *ElectTasksRequest
	AddRealtedTaskToEventReuqest *AddRealtedTaskToEventReuqest
	UpdateTaskStateRequest       *UpdateTaskStateRequest
	UpdateStateMetadataRequest   *UpdateStateMetadataRequest
}

type UpdateRequestMetadata struct {
	CreatedAt time.Time
}

type UpdateStateMetadataRequest struct {
	State  string
	Status string
}

type UpdateTaskStateRequest struct {
	State TaskState
}