state

type ConsulEventStore struct {
	*ConsulStore
}

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

type ConsulTaskStore struct {
	*ConsulStore
}

type Event struct {
	ID       string            `json:"id"`
	Resolved bool              `json:"resolved"`
	Type     string            `json:"type"`
	Payload  []byte            `json:"payload"`
	Meta     map[string]string `json:"meta"`
}

type EventStorer interface {
	List() ([]*Event, error)
	Get(string) (*Event, error)
	Update(*Event) error
	Delete(string) error
}

type IOPair struct {
	Task       *Task
	Event      *Event
	InProgress bool
}

type Storer interface {
	Tasks() TaskStorer
	Events() EventStorer
}

type Task struct {
	ID           string            `json:"id"`
	SubscribesTo []string          `json:"subscribesTo"`
	Image        string            `json:"image"`
	Env          map[string]string `json:"env"`
	CPU          float64           `json:"cpu"`
	Mem          float64           `json:"mem"`
}

type TaskStorer interface {
	List() ([]*Task, error)
	Get(string) (*Task, error)
	GetBySubscription(string) ([]*Task, error)
	Update(*Task) error
	Delete(string) error
}