state

type Event struct {
	Time           time.Time `json:"time"`
	Op             string    `json:"op"`
	Status         Status    `json:"status"`
	Message        string    `json:"message"`
	ProviderID     string    `json:"provider_id,omitempty"`
	IdempotencyKey string    `json:"idempotency_key,omitempty"`
}

type Journal interface {
	Record(ev Event) error
	Events() ([]Event, error)
	Completed(idempotencyKey string) (Event, bool)
}

type Release struct {
	ID        string        `json:"id"`
	PlanHash  string        `json:"plan_hash"`
	Images    []model.Image `json:"images"`
	AppliedAt time.Time     `json:"applied_at"`
	Status    Status        `json:"status"`
	// Migrations lists migration ids this release ran; reversible is per id.
	Migrations map[string]bool `json:"migrations,omitempty"`
}

type ResourceState struct {
	Name       string             `json:"name"`
	Type       model.ResourceType `json:"type"`
	Lifecycle  model.Lifecycle    `json:"lifecycle"`
	ProviderID string             `json:"provider_id"`
	CreatedAt  time.Time          `json:"created_at"`
}

type Snapshot struct {
	Revision        uint64                   `json:"revision,omitempty"`
	Workloads       map[string]WorkloadState `json:"workloads,omitempty"`
	Identities      map[string][]string      `json:"identities,omitempty"`
	FailedOperation string                   `json:"failed_operation,omitempty"`
	ActivePlanHash  string                   `json:"active_plan_hash,omitempty"`
	Releases        []Release                `json:"releases"`
	Resources       map[string]ResourceState `json:"resources"`
	Status          Status                   `json:"status"`
}

type Status string

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

type WorkloadState struct {
	PlanHash  string      `json:"plan_hash"`
	Resources []string    `json:"resources"`
	Image     model.Image `json:"image"`
}