state

Documentation

Index

• func NewInMemoryRunnerState(ctx context.Context) eventstream.EventStream[RunnerState, RunnerEvent]
• type DeploymentArtefact
• 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

Functions

func NewInMemoryRunnerState

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

Types

type DeploymentArtefact

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

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