Help us shape the future of Go! Take the 2026 Go Developer Survey

model

package
v0.414.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 21, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Artefact 

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

type ControllerKey 

type ControllerKey = KeyType[ControllerPayload, *ControllerPayload]

func NewControllerKey 

func NewControllerKey(hostname, port string) ControllerKey

func NewLocalControllerKey 

func NewLocalControllerKey(suffix int) ControllerKey

func ParseControllerKey 

func ParseControllerKey(key string) (ControllerKey, error)

type ControllerPayload 

type ControllerPayload struct {
	HostPortMixin
}

func (*ControllerPayload) Kind 

func (c *ControllerPayload) Kind() string

type CronJob 

type CronJob struct {
	Key           CronJobKey
	DeploymentKey DeploymentKey
	Verb          schema.Ref
	Schedule      string
	StartTime     time.Time
	NextExecution time.Time
	LastExecution optional.Option[time.Time]
}

type CronJobKey 

type CronJobKey = KeyType[CronJobPayload, *CronJobPayload]

func NewCronJobKey 

func NewCronJobKey(module, verb string) CronJobKey

func ParseCronJobKey 

func ParseCronJobKey(key string) (CronJobKey, error)

type CronJobPayload 

type CronJobPayload struct {
	Module string
	Verb   string
}

func (*CronJobPayload) Kind 

func (d *CronJobPayload) Kind() string

func (*CronJobPayload) Parse 

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

func (*CronJobPayload) RandomBytes 

func (d *CronJobPayload) RandomBytes() int

func (*CronJobPayload) String 

func (d *CronJobPayload) String() string

type Deployment 

type Deployment struct {
	Module   string
	Language string
	Key      DeploymentKey
	Schema   *schema.Module
}

type DeploymentKey 

type DeploymentKey = KeyType[DeploymentPayload, *DeploymentPayload]

func NewDeploymentKey 

func NewDeploymentKey(module string) DeploymentKey

func ParseDeploymentKey 

func ParseDeploymentKey(key string) (DeploymentKey, error)

type DeploymentPayload 

type DeploymentPayload struct {
	Module string
}

func (*DeploymentPayload) Kind 

func (d *DeploymentPayload) Kind() string

func (*DeploymentPayload) Parse 

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

func (*DeploymentPayload) RandomBytes 

func (d *DeploymentPayload) RandomBytes() int

func (*DeploymentPayload) String 

func (d *DeploymentPayload) String() string

type HostPortMixin 

type HostPortMixin struct {
	Hostname optional.Option[string]
	Port     string
}

HostPortMixin is a mixin for keys that have an (optional) hostname and a port.

func (*HostPortMixin) Parse 

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

func (*HostPortMixin) RandomBytes 

func (h *HostPortMixin) RandomBytes() int

func (*HostPortMixin) String 

func (h *HostPortMixin) String() string

type KeyPayload 

type KeyPayload interface {
	Kind() string
	String() string
	// Parse the hyphen-separated parts of the payload
	Parse(parts []string) error
	// RandomBytes determines the number of random bytes the key should include.
	RandomBytes() int
}

KeyPayload is an interface that all key payloads must implement.

type KeyType 

type KeyType[T any, TP keyPayloadConstraint[T]] struct {
	Payload T
	Suffix  []byte
}

KeyType is a helper type to avoid having to write a bunch of boilerplate.

func (KeyType[T, TP]) Equal 

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

func (KeyType[T, TP]) GoString 

func (d KeyType[T, TP]) GoString() string

func (KeyType[T, TP]) IsZero 

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

func (KeyType[T, TP]) Kind 

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

func (KeyType[T, TP]) MarshalText 

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

func (*KeyType[T, TP]) Scan 

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

Scan from DB representation.

func (KeyType[T, TP]) String 

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

func (*KeyType[T, TP]) UnmarshalText 

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

func (KeyType[T, TP]) Value 

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

type Labels 

type Labels map[string]any

func (Labels) String 

func (l Labels) String() string

type Origin 

type Origin string

Origin of a request. 

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

func ParseOrigin 

func ParseOrigin(origin string) (Origin, error)

type RequestKey 

type RequestKey = KeyType[RequestKeyPayload, *RequestKeyPayload]

A RequestKey represents an inbound request into the cluster.

func NewRequestKey 

func NewRequestKey(origin Origin, key string) RequestKey

func ParseRequestKey 

func ParseRequestKey(name string) (RequestKey, error)

type RequestKeyPayload 

type RequestKeyPayload struct {
	Origin Origin
	Key    string
}

func (*RequestKeyPayload) Kind 

func (r *RequestKeyPayload) Kind() string

func (*RequestKeyPayload) Parse 

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

func (*RequestKeyPayload) RandomBytes 

func (r *RequestKeyPayload) RandomBytes() int

func (*RequestKeyPayload) String 

func (r *RequestKeyPayload) String() string

type RunnerKey 

type RunnerKey = KeyType[RunnerPayload, *RunnerPayload]

func NewLocalRunnerKey 

func NewLocalRunnerKey(suffix int) RunnerKey

func NewRunnerKey 

func NewRunnerKey(hostname, port string) RunnerKey

func ParseRunnerKey 

func ParseRunnerKey(key string) (RunnerKey, error)

type RunnerPayload 

type RunnerPayload struct {
	HostPortMixin
}

func (*RunnerPayload) Kind 

func (r *RunnerPayload) Kind() string

type SubscriberKey 

type SubscriberKey = KeyType[SubscriberPayload, *SubscriberPayload]

func NewSubscriberKey 

func NewSubscriberKey(module, subscription, sink string) SubscriberKey

func ParseSubscriberKey 

func ParseSubscriberKey(key string) (SubscriberKey, error)

type SubscriberPayload 

type SubscriberPayload struct {
	Module       string
	Subscription string
}

func (*SubscriberPayload) Kind 

func (s *SubscriberPayload) Kind() string

func (*SubscriberPayload) Parse 

func (s *SubscriberPayload) Parse(parts []string) error

func (*SubscriberPayload) RandomBytes 

func (s *SubscriberPayload) RandomBytes() int

func (*SubscriberPayload) String 

func (s *SubscriberPayload) String() string

type Subscription 

type Subscription struct {
	Name   string
	Key    SubscriptionKey
	Topic  TopicKey
	Cursor optional.Option[TopicEventKey]
}

type SubscriptionKey 

type SubscriptionKey = KeyType[SubscriptionPayload, *SubscriptionPayload]

func NewSubscriptionKey 

func NewSubscriptionKey(module, name string) SubscriptionKey

func ParseSubscriptionKey 

func ParseSubscriptionKey(key string) (SubscriptionKey, error)

type SubscriptionPayload 

type SubscriptionPayload struct {
	Module string
	Name   string
}

func (*SubscriptionPayload) Kind 

func (s *SubscriptionPayload) Kind() string

func (*SubscriptionPayload) Parse 

func (s *SubscriptionPayload) Parse(parts []string) error

func (*SubscriptionPayload) RandomBytes 

func (s *SubscriptionPayload) RandomBytes() int

func (*SubscriptionPayload) String 

func (s *SubscriptionPayload) String() string

type TopicEventKey 

type TopicEventKey = KeyType[TopicEventPayload, *TopicEventPayload]

func NewTopicEventKey 

func NewTopicEventKey(module, topic string) TopicEventKey

func ParseTopicEventKey 

func ParseTopicEventKey(key string) (TopicEventKey, error)

type TopicEventPayload 

type TopicEventPayload struct {
	Module string
	Topic  string
}

func (*TopicEventPayload) Kind 

func (t *TopicEventPayload) Kind() string

func (*TopicEventPayload) Parse 

func (t *TopicEventPayload) Parse(parts []string) error

func (*TopicEventPayload) RandomBytes 

func (t *TopicEventPayload) RandomBytes() int

func (*TopicEventPayload) String 

func (t *TopicEventPayload) String() string

type TopicKey 

type TopicKey = KeyType[TopicPayload, *TopicPayload]

func NewTopicKey 

func NewTopicKey(module, name string) TopicKey

func ParseTopicKey 

func ParseTopicKey(key string) (TopicKey, error)

type TopicPayload 

type TopicPayload struct {
	Module string
	Name   string
}

func (*TopicPayload) Kind 

func (t *TopicPayload) Kind() string

func (*TopicPayload) Parse 

func (t *TopicPayload) Parse(parts []string) error

func (*TopicPayload) RandomBytes 

func (t *TopicPayload) RandomBytes() int

func (*TopicPayload) String 

func (t *TopicPayload) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.