model

Documentation

Index

• func ParseRequestName(name string) (Origin, RequestName, error)
• type Artefact
• type ControllerKey
  • func NewControllerKey(hostname string, port string) ControllerKey
  • func NewLocalControllerKey(suffix int) ControllerKey
  • func ParseControllerKey(key string) (ControllerKey, error)
• type Deployment
  • func (d *Deployment) Close() error
• type DeploymentKey
  • func NewDeploymentKey(module string) DeploymentKey
  • func ParseDeploymentKey(input string) (DeploymentKey, error)
  • func (d *DeploymentKey) MarshalText() ([]byte, error)
  • func (d *DeploymentKey) Scan(value any) error
  • func (d *DeploymentKey) String() string
  • func (d *DeploymentKey) UnmarshalText(bytes []byte) error
  • func (d DeploymentKey) Value() (driver.Value, error)
• type Labels
  • func (l Labels) String() string
• type MaybeRequestName
• type Origin
  • func ParseOrigin(origin string) (Origin, error)
• type RequestName
  • func NewRequestName(origin Origin, key string) RequestName
  • func (d *RequestName) MarshalText() ([]byte, error)
  • func (d *RequestName) Scan(value any) error
  • func (d *RequestName) String() string
  • func (d *RequestName) UnmarshalText(bytes []byte) error
  • func (d *RequestName) Value() (driver.Value, error)
• type RunnerKey
  • func NewLocalRunnerKey(suffix int) RunnerKey
  • func NewRunnerKey(hostname string, port string) RunnerKey
  • func ParseRunnerKey(key string) (RunnerKey, error)

Functions

func ParseRequestName

func ParseRequestName(name string) (Origin, RequestName, error)

Types

type Artefact

type Artefact struct {
	Path       string
	Executable bool
	Digest     sha256.SHA256
	// ~Zero-cost on-demand reader.
	Content io.ReadCloser
}

type ControllerKey

type ControllerKey = keyType[controllerKey]

func NewControllerKey

func NewControllerKey(hostname string, port string) ControllerKey

func NewLocalControllerKey

func NewLocalControllerKey(suffix int) ControllerKey

func ParseControllerKey

func ParseControllerKey(key string) (ControllerKey, error)

type Deployment

type Deployment struct {
	Module    string
	Language  string
	Key       DeploymentKey
	Schema    *schema.Module
	Artefacts []*Artefact
}

func (*Deployment) Close

func (d *Deployment) Close() error

Close is a convenience function to close all artefacts.

type DeploymentKey

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

func NewDeploymentKey

func NewDeploymentKey(module string) DeploymentKey

func ParseDeploymentKey

func ParseDeploymentKey(input string) (DeploymentKey, error)

func (*DeploymentKey) MarshalText

func (d *DeploymentKey) MarshalText() ([]byte, error)

func (*DeploymentKey) Scan

func (d *DeploymentKey) Scan(value any) error

func (*DeploymentKey) String

func (d *DeploymentKey) String() string

func (*DeploymentKey) UnmarshalText

func (d *DeploymentKey) UnmarshalText(bytes []byte) error

func (DeploymentKey) Value

func (d DeploymentKey) Value() (driver.Value, error)

type Labels

type Labels map[string]any

func (Labels) String

func (l Labels) String() string

type MaybeRequestName

type MaybeRequestName optional.Option[RequestName]

type Origin

type Origin string

const (
	OriginIngress Origin = "ingress"
	OriginCron    Origin = "cron"
	OriginPubsub  Origin = "pubsub"
)

func ParseOrigin

func ParseOrigin(origin string) (Origin, error)

type RequestName

type RequestName string

A RequestName represents an inbound request into the cluster.

func NewRequestName

func NewRequestName(origin Origin, key string) RequestName

func (*RequestName) MarshalText

func (d *RequestName) MarshalText() ([]byte, error)

func (*RequestName) Scan

func (d *RequestName) Scan(value any) error

func (*RequestName) String

func (d *RequestName) String() string

func (*RequestName) UnmarshalText

func (d *RequestName) UnmarshalText(bytes []byte) error

func (*RequestName) Value

func (d *RequestName) Value() (driver.Value, error)

type RunnerKey

type RunnerKey = keyType[runnerKey]

func NewLocalRunnerKey

func NewLocalRunnerKey(suffix int) RunnerKey

func NewRunnerKey

func NewRunnerKey(hostname string, port string) RunnerKey

func ParseRunnerKey

func ParseRunnerKey(key string) (RunnerKey, error)