model

Apr 15, 2024

Changes in this version

+ const CronJobStateExecuting

+ const CronJobStateIdle

+ type CronJob struct

+ DeploymentKey DeploymentKey

+ Key CronJobKey

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Verb VerbRef

+ type CronJobState string

+ type VerbRef struct

+ Module string

+ Name string

+ func (v VerbRef) String() string

Apr 12, 2024

Changes in this version

+ type CronJobKey = KeyType[CronJobPayload, *CronJobPayload]

+ func NewCronJobKey(module, verb string) CronJobKey

+ func ParseCronJobKey(key string) (CronJobKey, error)

+ type CronJobPayload struct

+ Ref string

+ func (d *CronJobPayload) Kind() string

+ func (d *CronJobPayload) Parse(parts []string) error

+ func (d *CronJobPayload) RandomBytes() int

+ func (d *CronJobPayload) String() string

Apr 10, 2024

Changes in this version

+ type ControllerPayload struct

+ func (c *ControllerPayload) Kind() string

+ type DeploymentPayload struct

+ Module string

+ func (d *DeploymentPayload) Kind() string

+ func (d *DeploymentPayload) Parse(parts []string) error

+ func (d *DeploymentPayload) RandomBytes() int

+ func (d *DeploymentPayload) String() string

+ type HostPortMixin struct

+ Hostname optional.Option[string]

+ Port string

+ func (h *HostPortMixin) Parse(parts []string) error

+ func (h *HostPortMixin) RandomBytes() int

+ func (h *HostPortMixin) String() string

+ type KeyPayload interface

+ Kind func() string

+ Parse func(parts []string) error

+ RandomBytes func() int

+ String func() string

+ type KeyType struct

+ Payload T

+ Suffix []byte

+ func (d *KeyType[T, TP]) Scan(src any) error

+ func (d *KeyType[T, TP]) UnmarshalText(bytes []byte) error

+ func (d KeyType[T, TP]) Equal(other KeyType[T, TP]) bool

+ func (d KeyType[T, TP]) IsZero() bool

+ func (d KeyType[T, TP]) Kind() string

+ func (d KeyType[T, TP]) MarshalText() ([]byte, error)

+ func (d KeyType[T, TP]) String() string

+ func (d KeyType[T, TP]) Value() (driver.Value, error)

+ type RequestKey = KeyType[RequestKeyPayload, *RequestKeyPayload]

+ func NewRequestKey(origin Origin, key string) RequestKey

+ func ParseRequestKey(name string) (RequestKey, error)

+ type RequestKeyPayload struct

+ Key string

+ Origin Origin

+ func (r *RequestKeyPayload) Kind() string

+ func (r *RequestKeyPayload) Parse(parts []string) error

+ func (r *RequestKeyPayload) RandomBytes() int

+ func (r *RequestKeyPayload) String() string

+ type RunnerPayload struct

+ func (r *RunnerPayload) Kind() string

Mar 15, 2024

Changes in this version

type Deployment

+ Key DeploymentKey

+ type DeploymentKey struct

+ 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)

Mar 13, 2024

Changes in this version

type ControllerKey

+ func NewLocalControllerKey(suffix int) ControllerKey

type RunnerKey

+ func NewLocalRunnerKey(suffix int) RunnerKey

Feb 16, 2024

Changes in this version

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

+ type Artefact struct

+ Content io.ReadCloser

+ Digest sha256.SHA256

+ Executable bool

+ Path string

+ type ControllerKey = keyType[controllerKey]

+ func NewControllerKey() ControllerKey

+ func ParseControllerKey(key string) (ControllerKey, error)

+ type Deployment struct

+ Artefacts []*Artefact

+ Language string

+ Module string

+ Name DeploymentName

+ Schema *schema.Module

+ func (d *Deployment) Close() error

+ type DeploymentName string

+ func NewDeploymentName(module string) DeploymentName

+ func ParseDeploymentName(name string) (DeploymentName, error)

+ func (d *DeploymentName) MarshalText() ([]byte, error)

+ func (d *DeploymentName) Scan(value any) error

+ func (d *DeploymentName) String() string

+ func (d *DeploymentName) UnmarshalText(bytes []byte) error

+ func (d *DeploymentName) Value() (driver.Value, error)

+ type Labels map[string]any

+ func (l Labels) String() string

+ type MaybeDeploymentName optional.Option[DeploymentName]

+ type MaybeRequestName optional.Option[RequestName]

+ type Origin string

+ const OriginCron

+ const OriginIngress

+ const OriginPubsub

+ func ParseOrigin(origin string) (Origin, error)

+ type RequestName string

+ 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 = keyType[runnerKey]

+ func NewRunnerKey() RunnerKey

+ func ParseRunnerKey(key string) (RunnerKey, error)