schema

package

Go to main page

Versions in this module

v0

v0.434.0

Jan 29, 2025

Changes in this version

+ func EventToProto(value Event) *destpb.Event

+ func Graph(s *Schema) map[RefKey]GraphNode

type DatabaseRuntimeEvent

+ Connections *DatabaseRuntimeConnections

+ Module string

+ type DeploymentActivatedEvent struct

+ ActivatedAt time.Time

+ Key key.Deployment

+ MinReplicas int

+ func DeploymentActivatedEventFromProto(v *destpb.DeploymentActivatedEvent) (out *DeploymentActivatedEvent, err error)

+ func (x *DeploymentActivatedEvent) ToProto() *destpb.DeploymentActivatedEvent

+ type DeploymentCreatedEvent struct

+ Key key.Deployment

+ Schema *Module

+ func DeploymentCreatedEventFromProto(v *destpb.DeploymentCreatedEvent) (out *DeploymentCreatedEvent, err error)

+ func (x *DeploymentCreatedEvent) ToProto() *destpb.DeploymentCreatedEvent

+ type DeploymentDeactivatedEvent struct

+ Key key.Deployment

+ ModuleRemoved bool

+ func DeploymentDeactivatedEventFromProto(v *destpb.DeploymentDeactivatedEvent) (out *DeploymentDeactivatedEvent, err error)

+ func (x *DeploymentDeactivatedEvent) ToProto() *destpb.DeploymentDeactivatedEvent

+ type DeploymentReplicasUpdatedEvent struct

+ Key key.Deployment

+ Replicas int

+ func DeploymentReplicasUpdatedEventFromProto(v *destpb.DeploymentReplicasUpdatedEvent) (out *DeploymentReplicasUpdatedEvent, err error)

+ func (x *DeploymentReplicasUpdatedEvent) ToProto() *destpb.DeploymentReplicasUpdatedEvent

+ type DeploymentSchemaUpdatedEvent struct

+ Key key.Deployment

+ Schema *Module

+ func DeploymentSchemaUpdatedEventFromProto(v *destpb.DeploymentSchemaUpdatedEvent) (out *DeploymentSchemaUpdatedEvent, err error)

+ func (x *DeploymentSchemaUpdatedEvent) ToProto() *destpb.DeploymentSchemaUpdatedEvent

+ type Event interface

+ func EventFromProto(v *destpb.Event) (Event, error)

+ type GraphNode struct

+ Decl Decl

+ In []RefKey

+ Out []RefKey

type ModuleRuntimeEvent

+ Base optional.Option[ModuleRuntimeBase]

+ Deployment optional.Option[ModuleRuntimeDeployment]

+ DeploymentKey optional.Option[string]

+ Module string

+ Scaling optional.Option[ModuleRuntimeScaling]

+ func (x *ModuleRuntimeEvent) ToProto() *destpb.ModuleRuntimeEvent

+ type ProvisioningCreatedEvent struct

+ DesiredModule *Module

+ func ProvisioningCreatedEventFromProto(v *destpb.ProvisioningCreatedEvent) (out *ProvisioningCreatedEvent, err error)

+ func (x *ProvisioningCreatedEvent) ToProto() *destpb.ProvisioningCreatedEvent

type TopicRuntimeEvent

+ Module string

type VerbRuntimeEvent

+ Base optional.Option[VerbRuntimeBase]

+ Module string

+ Subscription optional.Option[VerbRuntimeSubscription]

v0.433.2

Jan 24, 2025

v0.433.1

Jan 23, 2025

v0.433.0

Jan 23, 2025

v0.432.0

Jan 22, 2025

Changes in this version

+ type MetadataSQLColumn struct

+ Name string

+ Pos Position

+ Table string

+ func MetadataSQLColumnFromProto(v *destpb.MetadataSQLColumn) (out *MetadataSQLColumn, err error)

+ func (m *MetadataSQLColumn) Position() Position

+ func (m *MetadataSQLColumn) String() string

+ func (x *MetadataSQLColumn) ToProto() *destpb.MetadataSQLColumn

v0.431.1

Jan 20, 2025

v0.431.0

Jan 20, 2025

Changes in this version

type Verb

+ func (v *Verb) GetQuery() (*MetadataSQLQuery, bool)

v0.430.1

Jan 20, 2025

v0.430.0

Jan 20, 2025

v0.429.0

Jan 20, 2025

v0.428.1

Jan 19, 2025

v0.428.0

Jan 18, 2025

Changes in this version

type MetadataSQLQuery

+ Command string

type Module

+ func (m *Module) Validate() error

type ModuleRuntime

+ func (m *ModuleRuntime) ModScaling() *ModuleRuntimeScaling

type Schema

+ func (s *Schema) Validate() (*Schema, error)

v0.427.2

Jan 17, 2025

v0.427.1

Jan 16, 2025

v0.427.0

Jan 16, 2025

v0.426.0

Jan 15, 2025

Changes in this version

type Verb

+ func (v *Verb) GetRawSQLQuery() (string, bool)

+ func (v *Verb) IsGenerated() bool

v0.425.0

Jan 15, 2025

v0.424.2

Jan 15, 2025

v0.424.1

Jan 15, 2025

v0.424.0

Jan 15, 2025

Changes in this version

type AWSIAMAuthDatabaseConnector

+ func AWSIAMAuthDatabaseConnectorFromProto(v *destpb.AWSIAMAuthDatabaseConnector) *AWSIAMAuthDatabaseConnector

type AliasKind

+ func AliasKindFromProto(v destpb.AliasKind) AliasKind

type Any

+ func AnyFromProto(v *destpb.Any) *Any

type Array

+ func ArrayFromProto(v *destpb.Array) *Array

type Bool

+ func BoolFromProto(v *destpb.Bool) *Bool

type Bytes

+ func BytesFromProto(v *destpb.Bytes) *Bytes

type DSNDatabaseConnector

+ func DSNDatabaseConnectorFromProto(v *destpb.DSNDatabaseConnector) *DSNDatabaseConnector

type Decl

+ func DeclFromProto(v *destpb.Decl) Decl

type EnumVariant

+ func EnumVariantFromProto(v *destpb.EnumVariant) *EnumVariant

type Field

+ func FieldFromProto(v *destpb.Field) *Field

type Float

+ func FloatFromProto(v *destpb.Float) *Float

type FromOffset

+ func FromOffsetFromProto(v destpb.FromOffset) FromOffset

type IngressPathComponent

+ func IngressPathComponentFromProto(v *destpb.IngressPathComponent) IngressPathComponent

type IngressPathLiteral

+ func IngressPathLiteralFromProto(v *destpb.IngressPathLiteral) *IngressPathLiteral

type IngressPathParameter

+ func IngressPathParameterFromProto(v *destpb.IngressPathParameter) *IngressPathParameter

type Int

+ func IntFromProto(v *destpb.Int) *Int

type IntValue

+ func IntValueFromProto(v *destpb.IntValue) *IntValue

type Map

+ func MapFromProto(v *destpb.Map) *Map

type Metadata

+ func MetadataFromProto(v *destpb.Metadata) Metadata

type MetadataAlias

+ func MetadataAliasFromProto(v *destpb.MetadataAlias) *MetadataAlias

type MetadataArtefact

+ func MetadataArtefactFromProto(v *destpb.MetadataArtefact) *MetadataArtefact

type MetadataCalls

+ func MetadataCallsFromProto(v *destpb.MetadataCalls) *MetadataCalls

type MetadataConfig

+ func MetadataConfigFromProto(v *destpb.MetadataConfig) *MetadataConfig

type MetadataCronJob

+ func MetadataCronJobFromProto(v *destpb.MetadataCronJob) *MetadataCronJob

type MetadataDBColumn

+ func MetadataDBColumnFromProto(v *destpb.MetadataDBColumn) *MetadataDBColumn

type MetadataDatabases

+ func MetadataDatabasesFromProto(v *destpb.MetadataDatabases) *MetadataDatabases

type MetadataEncoding

+ func MetadataEncodingFromProto(v *destpb.MetadataEncoding) *MetadataEncoding

type MetadataIngress

+ func MetadataIngressFromProto(v *destpb.MetadataIngress) *MetadataIngress

type MetadataPartitions

+ func MetadataPartitionsFromProto(v *destpb.MetadataPartitions) *MetadataPartitions

type MetadataPublisher

+ func MetadataPublisherFromProto(v *destpb.MetadataPublisher) *MetadataPublisher

type MetadataRetry

+ func MetadataRetryFromProto(v *destpb.MetadataRetry) *MetadataRetry

type MetadataSQLMigration

+ func MetadataSQLMigrationFromProto(v *destpb.MetadataSQLMigration) *MetadataSQLMigration

type MetadataSQLQuery

+ func MetadataSQLQueryFromProto(v *destpb.MetadataSQLQuery) *MetadataSQLQuery

type MetadataSecrets

+ func MetadataSecretsFromProto(v *destpb.MetadataSecrets) *MetadataSecrets

type MetadataSubscriber

+ func MetadataSubscriberFromProto(v *destpb.MetadataSubscriber) *MetadataSubscriber

type MetadataTypeMap

+ func MetadataTypeMapFromProto(v *destpb.MetadataTypeMap) *MetadataTypeMap

type Module

+ func ValidatedModuleFromProto(v *schemapb.Module) (*Module, error)

type Optional

+ func OptionalFromProto(v *destpb.Optional) *Optional

type Position

+ func PositionFromProto(v *destpb.Position) *Position

type RuntimeEvent

+ func RuntimeEventFromProto(v *destpb.RuntimeEvent) RuntimeEvent

type Schema

+ func SchemaFromProto(v *destpb.Schema) *Schema

type String

+ func StringFromProto(v *destpb.String) *String

type StringValue

+ func StringValueFromProto(v *destpb.StringValue) *StringValue

type Time

+ func TimeFromProto(v *destpb.Time) *Time

type TypeParameter

+ func TypeParameterFromProto(v *destpb.TypeParameter) *TypeParameter

type TypeValue

+ func TypeValueFromProto(v *destpb.TypeValue) *TypeValue

type Unit

+ func UnitFromProto(v *destpb.Unit) *Unit

type Value

+ func ValueFromProto(v *destpb.Value) Value

type VerbRuntime

+ func VerbRuntimeFromProto(v *destpb.VerbRuntime) *VerbRuntime

v0.423.1

Jan 14, 2025

v0.423.0

Jan 14, 2025

v0.422.2

Jan 14, 2025

v0.422.1

Jan 14, 2025

Changes in this version

type ModuleRuntimeDeployment

+ func (m *ModuleRuntimeDeployment) GetCreatedAt() time.Time

+ func (m *ModuleRuntimeDeployment) GetDeploymentKey() string

v0.422.0

Jan 14, 2025

Changes in this version

+ type MetadataDBColumn struct

+ Name string

+ Pos Position

+ Table string

+ func (m *MetadataDBColumn) Position() Position

+ func (m *MetadataDBColumn) String() string

+ func (x *MetadataDBColumn) ToProto() *destpb.MetadataDBColumn

+ type MetadataSQLQuery struct

+ Pos Position

+ Query string

+ func (m *MetadataSQLQuery) Position() Position

+ func (m *MetadataSQLQuery) String() string

+ func (x *MetadataSQLQuery) ToProto() *destpb.MetadataSQLQuery

type Module

+ func (m *Module) GetRuntime() *ModuleRuntime

+ func (m *Module) ModRuntime() *ModuleRuntime

type ModuleRuntime

+ func (m *ModuleRuntime) GetDeployment() *ModuleRuntimeDeployment

+ func (m *ModuleRuntime) GetScaling() *ModuleRuntimeScaling

+ func (m *ModuleRuntime) ModDeployment() *ModuleRuntimeDeployment

type ModuleRuntimeDeployment

+ ActivatedAt time.Time

+ CreatedAt time.Time

type ModuleRuntimeScaling

+ func (m *ModuleRuntimeScaling) GetMinReplicas() int32

v0.421.0

Jan 10, 2025

Changes in this version

+ type MetadataPartitions struct

+ Partitions int

+ Pos Position

+ func (m *MetadataPartitions) Position() Position

+ func (m *MetadataPartitions) String() string

+ func (x *MetadataPartitions) ToProto() *destpb.MetadataPartitions

type Module

+ func (m *Module) Equals(other *Module) bool

type Topic

+ Metadata []Metadata

v0.420.1

Jan 3, 2025

v0.420.0

Jan 3, 2025

v0.419.0

Jan 3, 2025

v0.418.0

Jan 1, 2025

v0.417.0

Dec 30, 2024

v0.416.0

Dec 30, 2024

v0.415.1

Dec 23, 2024

v0.415.0

Dec 23, 2024

v0.414.0

Dec 21, 2024

Changes in this version

+ func DeadLetterNameForSubscriber(verb string) string

v0.413.2

Dec 19, 2024

v0.413.1

Dec 19, 2024

Changes in this version

type Schema

+ func (s *Schema) ModuleDependencies(module string) map[string]*Module

v0.413.0

Dec 18, 2024

v0.412.6

Dec 16, 2024

v0.412.5

Dec 16, 2024

v0.412.4

Dec 16, 2024

v0.412.3

Dec 16, 2024

v0.412.2

Dec 16, 2024

v0.412.1

Dec 16, 2024

v0.412.0

Dec 16, 2024

Changes in this version

+ const BuiltinsSource

+ const DefaultMaxBackoff

+ const DefaultRetryCount

+ const MaxBackoffLimit

+ const MaxBackoffLimitStr

+ const MinBackoffLimit

+ const MinBackoffLimitStr

+ const MySQLDatabaseType

+ const PostgresDatabaseType

+ var ErrNotFound = errors.New("not found")

+ var Lexer = lexer.MustSimple([]lexer.SimpleRule{ ... })

+ func AliasKindStrings() []string

+ func DatabaseConnectorToProto(value DatabaseConnector) *destpb.DatabaseConnector

+ func DatabaseRuntimeEventPayloadToProto(value DatabaseRuntimeEventPayload) *destpb.DatabaseRuntimeEventPayload

+ func DeclToProto(value Decl) *destpb.Decl

+ func EncodeComments(comments []string) string

+ func GetProvisioned(root Node) map[string]Provisioned

+ func IngressPathComponentToProto(value IngressPathComponent) *destpb.IngressPathComponent

+ func MetadataToProto(value Metadata) *destpb.Metadata

+ func ModuleRuntimeEventToProto(value ModuleRuntimeEvent) *destpb.ModuleRuntimeEvent

+ func ModuleToBytes(m *Module) ([]byte, error)

+ func Normalise[T Node](n T) T

+ func Redact[T Node](n T) T

+ func RequestResponseToJSONSchema(sch *Schema, ref Ref) (*jsonschema.Schema, error)

+ func RuntimeEventToProto(value RuntimeEvent) *destpb.RuntimeEvent

+ func SortModuleDecls(module *Module)

+ func TransformAliasedFields(sch *Schema, t Type, obj any, ...) error

+ func TransformFromAliasedFields(ref *Ref, sch *Schema, request map[string]any) (map[string]any, error)

+ func TransformToAliasedFields(ref *Ref, sch *Schema, request map[string]any) (map[string]any, error)

+ func TypeName(v any) string

+ func TypeToProto(value Type) *destpb.Type

+ func ValidateJSONValue(fieldType Type, path path, value any, sch *Schema, opts ...EncodingOption) error

+ func ValidateModule(module *Module) error

+ func ValidateName(name string) bool

+ func ValidateRequestMap(ref *Ref, path path, request map[string]any, sch *Schema, ...) error

+ func ValueToProto(value Value) *destpb.Value

+ func VerbRuntimePayloadToProto(value VerbRuntimePayload) *destpb.VerbRuntimePayload

+ func Visit(n Node, visit func(n Node, next func() error) error) error

+ func VisitExcludingMetadataChildren(n Node, visit func(n Node, next func() error) error) error

+ func VisitWithParent(n Node, parent Node, visit func(n Node, parent Node, next func() error) error) error

+ type AWSIAMAuthDatabaseConnector struct

+ Database string

+ Endpoint string

+ Pos Position

+ Username string

+ func (d *AWSIAMAuthDatabaseConnector) Position() Position

+ func (d *AWSIAMAuthDatabaseConnector) String() string

+ func (x *AWSIAMAuthDatabaseConnector) ToProto() *destpb.AWSIAMAuthDatabaseConnector

+ type AliasKind int

+ const AliasKindJSON

+ const AliasKindUnspecified

+ func AliasKindString(s string) (AliasKind, error)

+ func AliasKindValues() []AliasKind

+ func (i *AliasKind) UnmarshalJSON(data []byte) error

+ func (i *AliasKind) UnmarshalText(text []byte) error

+ func (i AliasKind) IsAAliasKind() bool

+ func (i AliasKind) MarshalJSON() ([]byte, error)

+ func (i AliasKind) MarshalText() ([]byte, error)

+ func (i AliasKind) String() string

+ func (x AliasKind) ToProto() destpb.AliasKind

+ type Any struct

+ Any bool

+ Pos Position

+ func (*Any) Equal(other Type) bool

+ func (*Any) GetName() string

+ func (*Any) String() string

+ func (a *Any) Position() Position

+ func (x *Any) ToProto() *destpb.Any

+ type Array struct

+ Element Type

+ Pos Position

+ func (a *Array) Equal(other Type) bool

+ func (a *Array) Position() Position

+ func (a *Array) String() string

+ func (x *Array) ToProto() *destpb.Array

+ type Bool struct

+ Bool bool

+ Pos Position

+ func (*Bool) GetName() string

+ func (*Bool) String() string

+ func (b *Bool) Equal(other Type) bool

+ func (b *Bool) Position() Position

+ func (x *Bool) ToProto() *destpb.Bool

+ type Bytes struct

+ Bytes bool

+ Pos Position

+ func (*Bytes) GetName() string

+ func (*Bytes) String() string

+ func (b *Bytes) Equal(other Type) bool

+ func (b *Bytes) Position() Position

+ func (x *Bytes) ToProto() *destpb.Bytes

+ type Config struct

+ Comments []string

+ Name string

+ Pos Position

+ Type Type

+ func ConfigFromProto(p *schemapb.Config) *Config

+ func (s *Config) GetName() string

+ func (s *Config) IsExported() bool

+ func (s *Config) Position() Position

+ func (s *Config) String() string

+ func (x *Config) ToProto() *destpb.Config

+ type DSNDatabaseConnector struct

+ DSN string

+ Pos Position

+ func (d *DSNDatabaseConnector) Position() Position

+ func (d *DSNDatabaseConnector) String() string

+ func (x *DSNDatabaseConnector) ToProto() *destpb.DSNDatabaseConnector

+ type Data struct

+ Comments []string

+ Export bool

+ Fields []*Field

+ Metadata []Metadata

+ Name string

+ Pos Position

+ TypeParameters []*TypeParameter

+ func DataFromProto(s *schemapb.Data) *Data

+ func (d *Data) FieldByName(name string) *Field

+ func (d *Data) GetName() string

+ func (d *Data) IsExported() bool

+ func (d *Data) Monomorphise(ref *Ref) (*Data, error)

+ func (d *Data) Position() Position

+ func (d *Data) Scope() Scope

+ func (d *Data) String() string

+ func (x *Data) ToProto() *destpb.Data

+ type Database struct

+ Comments []string

+ Metadata []Metadata

+ Name string

+ Pos Position

+ Runtime *DatabaseRuntime

+ Type string

+ func DatabaseFromProto(s *schemapb.Database) *Database

+ func (d *Database) GetName() string

+ func (d *Database) GetProvisioned() ResourceSet

+ func (d *Database) IsExported() bool

+ func (d *Database) Position() Position

+ func (d *Database) ResourceID() string

+ func (d *Database) String() string

+ func (x *Database) ToProto() *destpb.Database

+ type DatabaseConnector interface

+ func DatabaseConnectorFromProto(s *schemapb.DatabaseConnector) DatabaseConnector

+ type DatabaseRuntime struct

+ Connections *DatabaseRuntimeConnections

+ func DatabaseRuntimeFromProto(s *schemapb.DatabaseRuntime) *DatabaseRuntime

+ func (d *DatabaseRuntime) ApplyEvent(e *DatabaseRuntimeEvent)

+ func (d *DatabaseRuntime) Position() Position

+ func (d *DatabaseRuntime) String() string

+ func (x *DatabaseRuntime) ToProto() *destpb.DatabaseRuntime

+ type DatabaseRuntimeConnections struct

+ Read DatabaseConnector

+ Write DatabaseConnector

+ func DatabaseRuntimeConnectionsFromProto(s *schemapb.DatabaseRuntimeConnections) *DatabaseRuntimeConnections

+ func (d *DatabaseRuntimeConnections) Position() Position

+ func (d *DatabaseRuntimeConnections) String() string

+ func (x *DatabaseRuntimeConnections) ToProto() *destpb.DatabaseRuntimeConnections

+ type DatabaseRuntimeConnectionsEvent struct

+ Connections *DatabaseRuntimeConnections

+ func DatabaseRuntimeConnectionsEventFromProto(s *schemapb.DatabaseRuntimeConnectionsEvent) *DatabaseRuntimeConnectionsEvent

+ func (x *DatabaseRuntimeConnectionsEvent) ToProto() *destpb.DatabaseRuntimeConnectionsEvent

+ type DatabaseRuntimeEvent struct

+ ID string

+ Payload DatabaseRuntimeEventPayload

+ func DatabaseRuntimeEventFromProto(s *schemapb.DatabaseRuntimeEvent) *DatabaseRuntimeEvent

+ func (d *DatabaseRuntimeEvent) ApplyTo(s *Module)

+ func (x *DatabaseRuntimeEvent) ToProto() *destpb.DatabaseRuntimeEvent

+ type DatabaseRuntimeEventPayload interface

+ func DatabaseRuntimeEventPayloadFromProto(s *schemapb.DatabaseRuntimeEventPayload) DatabaseRuntimeEventPayload

+ type Decl interface

+ GetName func() string

+ IsExported func() bool

+ type EncodingOption func(option *encodingOptions)

+ func LenientMode() EncodingOption

+ type Enum struct

+ Comments []string

+ Export bool

+ Name string

+ Pos Position

+ Type Type

+ Variants []*EnumVariant

+ func EnumFromProto(s *schemapb.Enum) *Enum

+ func (e *Enum) GetName() string

+ func (e *Enum) IsExported() bool

+ func (e *Enum) IsValueEnum() bool

+ func (e *Enum) Position() Position

+ func (e *Enum) String() string

+ func (e *Enum) VariantForName(name string) optional.Option[*EnumVariant]

+ func (x *Enum) ToProto() *destpb.Enum

+ type EnumVariant struct

+ Comments []string

+ Name string

+ Pos Position

+ Value Value

+ func (e *EnumVariant) Position() Position

+ func (e *EnumVariant) String() string

+ func (x *EnumVariant) ToProto() *destpb.EnumVariant

+ type Field struct

+ Comments []string

+ Metadata []Metadata

+ Name string

+ Pos Position

+ Type Type

+ func (f *Field) Alias(kind AliasKind) optional.Option[string]

+ func (f *Field) Position() Position

+ func (f *Field) String() string

+ func (x *Field) ToProto() *destpb.Field

+ type Float struct

+ Float bool

+ Pos Position

+ func (*Float) GetName() string

+ func (*Float) String() string

+ func (f *Float) Equal(other Type) bool

+ func (f *Float) Position() Position

+ func (x *Float) ToProto() *destpb.Float

+ type FromOffset int

+ const FromOffsetBeginning

+ const FromOffsetLatest

+ const FromOffsetUnspecified

+ func (o *FromOffset) Capture(values []string) error

+ func (o FromOffset) String() string

+ func (x FromOffset) ToProto() destpb.FromOffset

+ type IngressPathComponent interface

+ type IngressPathLiteral struct

+ Pos Position

+ Text string

+ func (l *IngressPathLiteral) Position() Position

+ func (l *IngressPathLiteral) String() string

+ func (x *IngressPathLiteral) ToProto() *destpb.IngressPathLiteral

+ type IngressPathParameter struct

+ Name string

+ Pos Position

+ func (l *IngressPathParameter) Position() Position

+ func (l *IngressPathParameter) String() string

+ func (x *IngressPathParameter) ToProto() *destpb.IngressPathParameter

+ type Int struct

+ Int bool

+ Pos Position

+ func (*Int) GetName() string

+ func (*Int) String() string

+ func (i *Int) Equal(other Type) bool

+ func (i *Int) Position() Position

+ func (x *Int) ToProto() *destpb.Int

+ type IntValue struct

+ Pos Position

+ Value int

+ func (i *IntValue) GetValue() any

+ func (i *IntValue) Position() Position

+ func (i *IntValue) String() string

+ func (x *IntValue) ToProto() *destpb.IntValue

+ type Map struct

+ Key Type

+ Pos Position

+ Value Type

+ func (m *Map) Equal(other Type) bool

+ func (m *Map) Position() Position

+ func (m *Map) String() string

+ func (x *Map) ToProto() *destpb.Map

+ type Metadata interface

+ type MetadataAlias struct

+ Alias string

+ Kind AliasKind

+ Pos Position

+ func (m *MetadataAlias) Position() Position

+ func (m *MetadataAlias) String() string

+ func (x *MetadataAlias) ToProto() *destpb.MetadataAlias

+ type MetadataArtefact struct

+ Digest string

+ Executable bool

+ Path string

+ Pos Position

+ func (m *MetadataArtefact) Position() Position

+ func (m *MetadataArtefact) String() string

+ func (x *MetadataArtefact) ToProto() *destpb.MetadataArtefact

+ type MetadataCalls struct

+ Calls []*Ref

+ Pos Position

+ func (m *MetadataCalls) Position() Position

+ func (m *MetadataCalls) String() string

+ func (x *MetadataCalls) ToProto() *destpb.MetadataCalls

+ type MetadataConfig struct

+ Config []*Ref

+ Pos Position

+ func (m *MetadataConfig) Position() Position

+ func (m *MetadataConfig) String() string

+ func (x *MetadataConfig) ToProto() *destpb.MetadataConfig

+ type MetadataCronJob struct

+ Cron string

+ Pos Position

+ func (m *MetadataCronJob) Position() Position

+ func (m *MetadataCronJob) String() string

+ func (x *MetadataCronJob) ToProto() *destpb.MetadataCronJob

+ type MetadataDatabases struct

+ Calls []*Ref

+ Pos Position

+ func (m *MetadataDatabases) Position() Position

+ func (m *MetadataDatabases) String() string

+ func (x *MetadataDatabases) ToProto() *destpb.MetadataDatabases

+ type MetadataEncoding struct

+ Lenient bool

+ Pos Position

+ Type string

+ func (m *MetadataEncoding) Position() Position

+ func (m *MetadataEncoding) String() string

+ func (x *MetadataEncoding) ToProto() *destpb.MetadataEncoding

+ type MetadataIngress struct

+ Method string

+ Path []IngressPathComponent

+ Pos Position

+ Type string

+ func (m *MetadataIngress) PathString() string

+ func (m *MetadataIngress) Position() Position

+ func (m *MetadataIngress) String() string

+ func (x *MetadataIngress) ToProto() *destpb.MetadataIngress

+ type MetadataPublisher struct

+ Pos Position

+ Topics []*Ref

+ func (m *MetadataPublisher) Position() Position

+ func (m *MetadataPublisher) String() string

+ func (x *MetadataPublisher) ToProto() *destpb.MetadataPublisher

+ type MetadataRetry struct

+ Catch *Ref

+ Count *int

+ MaxBackoff string

+ MinBackoff string

+ Pos Position

+ func (m *MetadataRetry) Position() Position

+ func (m *MetadataRetry) RetryParams() (RetryParams, error)

+ func (m *MetadataRetry) String() string

+ func (x *MetadataRetry) ToProto() *destpb.MetadataRetry

+ type MetadataSQLMigration struct

+ Digest string

+ Pos Position

+ func (m *MetadataSQLMigration) Position() Position

+ func (m *MetadataSQLMigration) String() string

+ func (x *MetadataSQLMigration) ToProto() *destpb.MetadataSQLMigration

+ type MetadataSecrets struct

+ Pos Position

+ Secrets []*Ref

+ func (m *MetadataSecrets) Position() Position

+ func (m *MetadataSecrets) String() string

+ func (x *MetadataSecrets) ToProto() *destpb.MetadataSecrets

+ type MetadataSubscriber struct

+ DeadLetter bool

+ FromOffset FromOffset

+ Pos Position

+ Topic *Ref

+ func (m *MetadataSubscriber) Position() Position

+ func (m *MetadataSubscriber) String() string

+ func (x *MetadataSubscriber) ToProto() *destpb.MetadataSubscriber

+ type MetadataTypeMap struct

+ NativeName string

+ Pos Position

+ Runtime string

+ func (m *MetadataTypeMap) Position() Position

+ func (m *MetadataTypeMap) String() string

+ func (x *MetadataTypeMap) ToProto() *destpb.MetadataTypeMap

+ type Module struct

+ Builtin bool

+ Comments []string

+ Decls []Decl

+ Metadata []Metadata

+ Name string

+ Pos Position

+ Runtime *ModuleRuntime

+ func Builtins() *Module

+ func ModuleFromBytes(b []byte) (*Module, error)

+ func ModuleFromProto(s *schemapb.Module) (*Module, error)

+ func ModuleFromProtoFile(filename string) (*Module, error)

+ func ParseModule(filename string, r io.Reader) (*Module, error)

+ func ParseModuleString(filename, input string) (*Module, error)

+ func (m *Module) AddData(data *Data) int

+ func (m *Module) AddDecl(decl Decl)

+ func (m *Module) AddDecls(decls []Decl)

+ func (m *Module) Data() []*Data

+ func (m *Module) GetName() string

+ func (m *Module) GetProvisioned() ResourceSet

+ func (m *Module) Hash() (sha256.SHA256, error)

+ func (m *Module) Imports() []string

+ func (m *Module) IsExported() bool

+ func (m *Module) Position() Position

+ func (m *Module) Resolve(ref Ref) *ModuleDecl

+ func (m *Module) ResourceID() string

+ func (m *Module) Scan(src any) error

+ func (m *Module) String() string

+ func (m *Module) Value() (driver.Value, error)

+ func (m *Module) Verbs() []*Verb

+ func (x *Module) ToProto() *destpb.Module

+ type ModuleDecl struct

+ Module optional.Option[*Module]

+ Symbol Symbol

+ func ResolveAs[S Symbol](scopes Scopes, ref Ref) (symbol S, decl *ModuleDecl)

+ func ResolveTypeAs[S Symbol](scopes Scopes, t Type) (symbol S, decl *ModuleDecl)

+ type ModuleRuntime struct

+ Base ModuleRuntimeBase

+ Deployment *ModuleRuntimeDeployment

+ Scaling *ModuleRuntimeScaling

+ func ModuleRuntimeFromProto(s *schemapb.ModuleRuntime) *ModuleRuntime

+ func (m *ModuleRuntime) ApplyEvent(event ModuleRuntimeEvent)

+ func (x *ModuleRuntime) ToProto() *destpb.ModuleRuntime

+ type ModuleRuntimeBase struct

+ Arch string

+ CreateTime time.Time

+ Image string

+ Language string

+ OS string

+ func ModuleRuntimeBaseFromProto(s *schemapb.ModuleRuntimeBase) *ModuleRuntimeBase

+ func (x *ModuleRuntimeBase) ToProto() *destpb.ModuleRuntimeBase

+ type ModuleRuntimeDeployment struct

+ DeploymentKey string

+ Endpoint string

+ func ModuleRuntimeDeploymentFromProto(s *schemapb.ModuleRuntimeDeployment) *ModuleRuntimeDeployment

+ func (x *ModuleRuntimeDeployment) ToProto() *destpb.ModuleRuntimeDeployment

+ type ModuleRuntimeEvent interface

+ func ModuleRuntimeEventFromProto(s *schemapb.ModuleRuntimeEvent) ModuleRuntimeEvent

+ type ModuleRuntimeScaling struct

+ MinReplicas int32

+ func ModuleRuntimeScalingFromProto(s *schemapb.ModuleRuntimeScaling) *ModuleRuntimeScaling

+ func (x *ModuleRuntimeScaling) ToProto() *destpb.ModuleRuntimeScaling

+ type Named interface

+ GetName func() string

+ type Node interface

+ Position func() Position

+ String func() string

+ type Optional struct

+ Pos Position

+ Type Type

+ func (o *Optional) Equal(other Type) bool

+ func (o *Optional) Position() Position

+ func (o *Optional) String() string

+ func (x *Optional) ToProto() *destpb.Optional

+ type Position struct

+ Column int

+ Filename string

+ Line int

+ Offset int

+ func PosFromProto(pos *schemapb.Position) Position

+ func (p Position) String() string

+ func (p Position) ToErrorPos() builderrors.Position

+ func (p Position) ToErrorPosWithEnd(endColumn int) builderrors.Position

+ func (x *Position) ToProto() *destpb.Position

+ type Provisioned interface

+ GetProvisioned func() ResourceSet

+ ResourceID func() string

+ type ProvisionedResource struct

+ Config any

+ Kind ResourceType

+ func (r *ProvisionedResource) IsEqual(other *ProvisionedResource) bool

+ type Redactable interface

+ Redact func()

+ type Ref struct

+ Module string

+ Name string

+ Pos Position

+ TypeParameters []Type

+ func ParseRef(ref string) (*Ref, error)

+ func RefFromProto(s *schemapb.Ref) *Ref

+ func (r *Ref) Equal(other Type) bool

+ func (r *Ref) Position() Position

+ func (r *Ref) Scan(src any) error

+ func (r *Ref) String() string

+ func (r Ref) ToRefKey() RefKey

+ func (r Ref) Value() (driver.Value, error)

+ func (x *Ref) ToProto() *destpb.Ref

+ type RefKey struct

+ Module string

+ Name string

+ func (r *RefKey) Scan(src any) error

+ func (r RefKey) String() string

+ func (r RefKey) ToProto() *schemapb.Ref

+ func (r RefKey) ToRef() *Ref

+ func (r RefKey) Value() (driver.Value, error)

+ type Resolver interface

+ Resolve func(ref Ref) *ModuleDecl

+ type ResourceSet []*ProvisionedResource

+ func GetProvisionedResources(n Node) ResourceSet

+ func (s ResourceSet) FilterByType(kinds ...ResourceType) ResourceSet

+ func (s ResourceSet) Get(kind ResourceType) *ProvisionedResource

+ func (s ResourceSet) IsEqual(other ResourceSet) bool

+ type ResourceType string

+ const ResourceTypeModule

+ const ResourceTypeMysql

+ const ResourceTypePostgres

+ const ResourceTypeRunner

+ const ResourceTypeSQLMigration

+ const ResourceTypeSubscription

+ const ResourceTypeTopic

+ const ResourceTypeUnknown

+ type RetryParams struct

+ Catch optional.Option[RefKey]

+ Count int

+ MaxBackoff time.Duration

+ MinBackoff time.Duration

+ type RuntimeEvent interface

+ type Schema struct

+ Modules []*Module

+ Pos Position

+ func FromProto(s *schemapb.Schema) (*Schema, error)

+ func MustValidate(schema *Schema) *Schema

+ func Parse(filename string, r io.Reader) (*Schema, error)

+ func ParseString(filename, input string) (*Schema, error)

+ func ValidateModuleInSchema(schema *Schema, m optional.Option[*Module]) (*Schema, error)

+ func ValidateSchema(schema *Schema) (*Schema, error)

+ func (s *Schema) Hash() [sha256.Size]byte

+ func (s *Schema) Module(name string) optional.Option[*Module]

+ func (s *Schema) Position() Position

+ func (s *Schema) Resolve(ref *Ref) optional.Option[Decl]

+ func (s *Schema) ResolveMonomorphised(ref *Ref) (*Data, error)

+ func (s *Schema) ResolveRequestResponseType(ref *Ref) (Symbol, error)

+ func (s *Schema) ResolveToType(ref *Ref, out Decl) error

+ func (s *Schema) ResolveWithModule(ref *Ref) (optional.Option[Decl], optional.Option[*Module])

+ func (s *Schema) String() string

+ func (s *Schema) Upsert(module *Module)

+ func (x *Schema) ToProto() *destpb.Schema

+ type Scope map[string]ModuleDecl

+ func (s Scope) String() string

+ type Scoped interface

+ Scope func() Scope

+ type Scopes []Scope

+ func NewScopes() Scopes

+ func (s *Scopes) Add(owner optional.Option[*Module], name string, symbol Symbol) error

+ func (s Scopes) Push() Scopes

+ func (s Scopes) PushScope(scope Scope) Scopes

+ func (s Scopes) Resolve(ref Ref) *ModuleDecl

+ func (s Scopes) ResolveType(t Type) *ModuleDecl

+ func (s Scopes) String() string

+ type Secret struct

+ Comments []string

+ Name string

+ Pos Position

+ Type Type

+ func SecretFromProto(s *schemapb.Secret) *Secret

+ func (s *Secret) GetName() string

+ func (s *Secret) IsExported() bool

+ func (s *Secret) Position() Position

+ func (s *Secret) String() string

+ func (x *Secret) ToProto() *destpb.Secret

+ type String struct

+ Pos Position

+ Str bool

+ func (*String) GetName() string

+ func (*String) String() string

+ func (s *String) Equal(other Type) bool

+ func (s *String) Position() Position

+ func (x *String) ToProto() *destpb.String

+ type StringValue struct

+ Pos Position

+ Value string

+ func (s *StringValue) GetValue() any

+ func (s *StringValue) Position() Position

+ func (s *StringValue) String() string

+ func (x *StringValue) ToProto() *destpb.StringValue

+ type Symbol interface

+ type Time struct

+ Pos Position

+ Time bool

+ func (*Time) GetName() string

+ func (*Time) String() string

+ func (t *Time) Equal(other Type) bool

+ func (t *Time) Position() Position

+ func (x *Time) ToProto() *destpb.Time

+ type Topic struct

+ Comments []string

+ Event Type

+ Export bool

+ Name string

+ Pos Position

+ Runtime *TopicRuntime

+ func TopicFromProto(t *schemapb.Topic) *Topic

+ func (t *Topic) GetName() string

+ func (t *Topic) GetProvisioned() ResourceSet

+ func (t *Topic) IsExported() bool

+ func (t *Topic) Position() Position

+ func (t *Topic) ResourceID() string

+ func (t *Topic) String() string

+ func (x *Topic) ToProto() *destpb.Topic

+ type TopicRuntime struct

+ KafkaBrokers []string

+ TopicID string

+ func TopicRuntimeFromProto(t *schemapb.TopicRuntime) *TopicRuntime

+ func (x *TopicRuntime) ToProto() *destpb.TopicRuntime

+ type TopicRuntimeEvent struct

+ ID string

+ Payload *TopicRuntime

+ func TopicRuntimeEventFromProto(t *schemapb.TopicRuntimeEvent) *TopicRuntimeEvent

+ func (t *TopicRuntimeEvent) ApplyTo(m *Module)

+ func (x *TopicRuntimeEvent) ToProto() *destpb.TopicRuntimeEvent

+ type Type interface

+ Equal func(other Type) bool

+ func ParseType(filename, input string) (Type, error)

+ func TypeFromProto(s *schemapb.Type) Type

+ type TypeAlias struct

+ Comments []string

+ Export bool

+ Metadata []Metadata

+ Name string

+ Pos Position

+ Type Type

+ func TypeAliasFromProto(s *schemapb.TypeAlias) *TypeAlias

+ func (t *TypeAlias) GetName() string

+ func (t *TypeAlias) IsExported() bool

+ func (t *TypeAlias) Position() Position

+ func (t *TypeAlias) String() string

+ func (x *TypeAlias) ToProto() *destpb.TypeAlias

+ type TypeParameter struct

+ Name string

+ Pos Position

+ func (t *TypeParameter) GetName() string

+ func (t *TypeParameter) Position() Position

+ func (t *TypeParameter) String() string

+ func (x *TypeParameter) ToProto() *destpb.TypeParameter

+ type TypeValue struct

+ Pos Position

+ Value Type

+ func (t *TypeValue) GetValue() any

+ func (t *TypeValue) Position() Position

+ func (t *TypeValue) String() string

+ func (x *TypeValue) ToProto() *destpb.TypeValue

+ type Unit struct

+ Pos Position

+ Unit bool

+ func (u *Unit) Equal(other Type) bool

+ func (u *Unit) GetName() string

+ func (u *Unit) Position() Position

+ func (u *Unit) String() string

+ func (x *Unit) ToProto() *destpb.Unit

+ type Value interface

+ GetValue func() any

+ type Verb struct

+ Comments []string

+ Export bool

+ Metadata []Metadata

+ Name string

+ Pos Position

+ Request Type

+ Response Type

+ Runtime *VerbRuntime

+ func VerbFromProto(s *schemapb.Verb) *Verb

+ func (v *Verb) AddCall(verb *Ref)

+ func (v *Verb) AddConfig(config *Ref)

+ func (v *Verb) AddDatabase(db *Ref)

+ func (v *Verb) AddSecret(secret *Ref)

+ func (v *Verb) AddSubscription(sub *MetadataSubscriber)

+ func (v *Verb) AddTopicPublish(topic *Ref)

+ func (v *Verb) GetMetadataCronJob() optional.Option[*MetadataCronJob]

+ func (v *Verb) GetMetadataIngress() optional.Option[*MetadataIngress]

+ func (v *Verb) GetName() string

+ func (v *Verb) GetProvisioned() ResourceSet

+ func (v *Verb) IsExported() bool

+ func (v *Verb) Kind() VerbKind

+ func (v *Verb) Position() Position

+ func (v *Verb) ResourceID() string

+ func (v *Verb) SortMetadata()

+ func (v *Verb) String() string

+ func (x *Verb) ToProto() *destpb.Verb

+ type VerbKind string

+ const VerbKindEmpty

+ const VerbKindSink

+ const VerbKindSource

+ const VerbKindVerb

+ type VerbRuntime struct

+ Base VerbRuntimeBase

+ Subscription *VerbRuntimeSubscription

+ func (x *VerbRuntime) ToProto() *destpb.VerbRuntime

+ type VerbRuntimeBase struct

+ CreateTime time.Time

+ StartTime time.Time

+ func VerbRuntimeBaseFromProto(s *schemapb.VerbRuntimeBase) *VerbRuntimeBase

+ func (x *VerbRuntimeBase) ToProto() *destpb.VerbRuntimeBase

+ type VerbRuntimeEvent struct

+ ID string

+ Payload VerbRuntimePayload

+ func VerbRuntimeEventFromProto(p *schemapb.VerbRuntimeEvent) *VerbRuntimeEvent

+ func (v *VerbRuntimeEvent) ApplyTo(m *Module)

+ func (x *VerbRuntimeEvent) ToProto() *destpb.VerbRuntimeEvent

+ type VerbRuntimePayload interface

+ func VerbRuntimePayloadFromProto(p *schemapb.VerbRuntimePayload) VerbRuntimePayload

+ type VerbRuntimeSubscription struct

+ KafkaBrokers []string

+ func VerbRuntimeSubscriptionFromProto(s *schemapb.VerbRuntimeSubscription) *VerbRuntimeSubscription

+ func (x *VerbRuntimeSubscription) ToProto() *destpb.VerbRuntimeSubscription

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL