state

type Controller struct {
	Endpoint string
	Key      model.ControllerKey
}

type ControllerEvent interface {
	Handle(view State) (State, error)
}

type ControllerState eventstream.EventStream[State, ControllerEvent]

type Deployment struct {
	Key         model.DeploymentKey
	Module      string
	Schema      *schema.Module
	MinReplicas int
	CreatedAt   time.Time
	ActivatedAt optional.Option[time.Time]
	Artefacts   map[string]*DeploymentArtefact
	Language    string
}

type DeploymentActivatedEvent struct {
	Key         model.DeploymentKey
	ActivatedAt time.Time
	MinReplicas int
}

type DeploymentArtefact struct {
	Digest     sha256.SHA256
	Path       string
	Executable bool
}

type DeploymentArtefactCreatedEvent struct {
	Digest sha256.SHA256
}

type DeploymentCreatedEvent struct {
	Key       model.DeploymentKey
	CreatedAt time.Time
	Module    string
	Schema    *schema.Module
	Artefacts []*DeploymentArtefact
	Language  string
}

type DeploymentDeactivatedEvent struct {
	Key           model.DeploymentKey
	ModuleRemoved bool
}

type DeploymentReplicasUpdatedEvent struct {
	Key      model.DeploymentKey
	Replicas int
}

type DeploymentSchemaUpdatedEvent struct {
	Key    model.DeploymentKey
	Schema *schema.Module
}

type Runner struct {
	Key        model.RunnerKey
	Create     time.Time
	LastSeen   time.Time
	Endpoint   string
	Module     string
	Deployment model.DeploymentKey
}

type RunnerDeletedEvent struct {
	Key model.RunnerKey
}

type RunnerRegisteredEvent struct {
	Key        model.RunnerKey
	Time       time.Time
	Endpoint   string
	Module     string
	Deployment model.DeploymentKey
}

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