state

Documentation

Index

• func EventExtractor(diff tuple.Pair[SchemaState, SchemaState]) iter.Seq[SchemaEvent]
• func NewInMemoryRunnerState(ctx context.Context) eventstream.EventStream[RunnerState, RunnerEvent]
• func NewInMemorySchemaState(ctx context.Context) *statemachine.SingleQueryHandle[struct{}, SchemaState, SchemaEvent]
• type Deployment
• type DeploymentActivatedEvent
  • func (r *DeploymentActivatedEvent) Handle(t SchemaState) (SchemaState, error)
• type DeploymentArtefact
• type DeploymentCreatedEvent
  • func (r *DeploymentCreatedEvent) Handle(t SchemaState) (SchemaState, error)
• type DeploymentDeactivatedEvent
  • func (r *DeploymentDeactivatedEvent) Handle(t SchemaState) (SchemaState, error)
• type DeploymentReplicasUpdatedEvent
  • func (r *DeploymentReplicasUpdatedEvent) Handle(t SchemaState) (SchemaState, error)
• type DeploymentSchemaUpdatedEvent
  • func (r *DeploymentSchemaUpdatedEvent) Handle(t SchemaState) (SchemaState, error)
• type Runner
• type RunnerDeletedEvent
  • func (r *RunnerDeletedEvent) Handle(t RunnerState) (RunnerState, error)
• type RunnerEvent
• type RunnerRegisteredEvent
  • func (r *RunnerRegisteredEvent) Handle(t RunnerState) (RunnerState, error)
  • func (r *RunnerRegisteredEvent) VerboseMessage()
• type RunnerState
  • func (r *RunnerState) Runner(s key.Runner) optional.Option[Runner]
  • func (r *RunnerState) Runners() []Runner
  • func (r *RunnerState) RunnersForDeployment(deployment key.Deployment) []Runner
• type SchemaEvent
• type SchemaState
  • func (r *SchemaState) GetActiveDeploymentSchemas() []*schema.Module
  • func (r *SchemaState) GetActiveDeployments() map[key.Deployment]*Deployment
  • func (r *SchemaState) GetDeployment(deployment key.Deployment) (*Deployment, error)
  • func (r *SchemaState) GetDeployments() map[key.Deployment]*Deployment

Functions

func EventExtractor

func EventExtractor(diff tuple.Pair[SchemaState, SchemaState]) iter.Seq[SchemaEvent]

EventExtractor calculates controller events from changes to the state.

func NewInMemoryRunnerState

func NewInMemoryRunnerState(ctx context.Context) eventstream.EventStream[RunnerState, RunnerEvent]

func NewInMemorySchemaState

func NewInMemorySchemaState(ctx context.Context) *statemachine.SingleQueryHandle[struct{}, SchemaState, SchemaEvent]

Types

type Deployment

type Deployment struct {
	Key    key.Deployment
	Schema *schema.Module
}

type DeploymentActivatedEvent

type DeploymentActivatedEvent struct {
	Key         key.Deployment
	ActivatedAt time.Time
	MinReplicas int
}

func (*DeploymentActivatedEvent) Handle

func (r *DeploymentActivatedEvent) Handle(t SchemaState) (SchemaState, error)

type DeploymentArtefact

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

type DeploymentCreatedEvent

type DeploymentCreatedEvent struct {
	Key       key.Deployment
	CreatedAt time.Time
	Schema    *schema.Module
}

func (*DeploymentCreatedEvent) Handle

func (r *DeploymentCreatedEvent) Handle(t SchemaState) (SchemaState, error)

type DeploymentDeactivatedEvent

type DeploymentDeactivatedEvent struct {
	Key           key.Deployment
	ModuleRemoved bool
}

func (*DeploymentDeactivatedEvent) Handle

func (r *DeploymentDeactivatedEvent) Handle(t SchemaState) (SchemaState, error)

type DeploymentReplicasUpdatedEvent

type DeploymentReplicasUpdatedEvent struct {
	Key      key.Deployment
	Replicas int
}

func (*DeploymentReplicasUpdatedEvent) Handle

func (r *DeploymentReplicasUpdatedEvent) Handle(t SchemaState) (SchemaState, error)

type DeploymentSchemaUpdatedEvent

type DeploymentSchemaUpdatedEvent struct {
	Key    key.Deployment
	Schema *schema.Module
}

func (*DeploymentSchemaUpdatedEvent) Handle

func (r *DeploymentSchemaUpdatedEvent) Handle(t SchemaState) (SchemaState, error)

type Runner

type Runner struct {
	Key        key.Runner
	Create     time.Time
	LastSeen   time.Time
	Endpoint   string
	Module     string
	Deployment key.Deployment
}

type RunnerDeletedEvent

type RunnerDeletedEvent struct {
	Key key.Runner
}

func (*RunnerDeletedEvent) Handle

func (r *RunnerDeletedEvent) Handle(t RunnerState) (RunnerState, error)

type RunnerEvent

type RunnerEvent interface {
	Handle(view RunnerState) (RunnerState, error)
}

type RunnerRegisteredEvent

type RunnerRegisteredEvent struct {
	Key        key.Runner
	Time       time.Time
	Endpoint   string
	Module     string
	Deployment key.Deployment
}

func (*RunnerRegisteredEvent) Handle

func (r *RunnerRegisteredEvent) Handle(t RunnerState) (RunnerState, error)

func (*RunnerRegisteredEvent) VerboseMessage

func (r *RunnerRegisteredEvent) VerboseMessage()

type RunnerState

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

func (*RunnerState) Runner

func (r *RunnerState) Runner(s key.Runner) optional.Option[Runner]

func (*RunnerState) Runners

func (r *RunnerState) Runners() []Runner

func (*RunnerState) RunnersForDeployment

func (r *RunnerState) RunnersForDeployment(deployment key.Deployment) []Runner

type SchemaEvent

type SchemaEvent interface {
	Handle(view SchemaState) (SchemaState, error)
}

type SchemaState

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

func (*SchemaState) GetActiveDeploymentSchemas

func (r *SchemaState) GetActiveDeploymentSchemas() []*schema.Module

func (*SchemaState) GetActiveDeployments

func (r *SchemaState) GetActiveDeployments() map[key.Deployment]*Deployment

func (*SchemaState) GetDeployment

func (r *SchemaState) GetDeployment(deployment key.Deployment) (*Deployment, error)

func (*SchemaState) GetDeployments

func (r *SchemaState) GetDeployments() map[key.Deployment]*Deployment