schema

Jun 4, 2025

Changes in this version

type ProvisionedResource

+ State Runtime

May 27, 2025

Changes in this version

type ModuleRuntime

+ Image *ModuleRuntimeImage

+ func (m *ModuleRuntime) GetImage() *ModuleRuntimeImage

+ func (m *ModuleRuntime) ModImage() *ModuleRuntimeImage

+ type ModuleRuntimeImage struct

+ Image string

+ func ModuleRuntimeImageFromProto(v *destpb.ModuleRuntimeImage) (out *ModuleRuntimeImage, err error)

+ func (m *ModuleRuntimeImage) GetImage() string

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

type ResourceType

+ const ResourceTypeImage

May 26, 2025

Changes in this version

+ type YAMLFileCredentialsConnector struct

+ DSNTemplate string

+ Path string

+ Pos Position

+ func YAMLFileCredentialsConnectorFromProto(v *destpb.YAMLFileCredentialsConnector) (out *YAMLFileCredentialsConnector, err error)

+ func (d *YAMLFileCredentialsConnector) Position() Position

+ func (d *YAMLFileCredentialsConnector) String() string

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

May 7, 2025

Changes in this version

type Realm

+ func (r *Realm) ModulesByName() map[string]*Module

+ func (r *Realm) UpsertModule(module *Module)

type Schema

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

+ func (s *Schema) RemoveModule(realm, module string)

+ func (s *Schema) UpdateRealms(realms []*Realm)

type SchemaState

+ Schema *Schema

+ func (s *SchemaState) Validate() error

May 7, 2025

Changes in this version

type Config

+ func (s *Config) Validate() error

type Secret

+ func (s *Secret) Validate() error

+ type ValidatedNode interface

+ Validate func() error

May 5, 2025

Changes in this version

+ type DeclResolver interface

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

type Realm

+ func ValidateModuleInRealm(realm *Realm, m optional.Option[*Module]) (*Realm, error)

+ func (r *Realm) Validate() (*Realm, error)

type Schema

+ func (s *Schema) WithBuiltins() *Schema

May 1, 2025

Changes in this version

type Module

+ func (m *Module) GetByName(name string) optional.Option[Decl]

type Realm

+ func (r *Realm) FilterByVisibility(scope Visibility) *Realm

type RefKey

+ func OutboundEdges(n Node, ignoredRefs map[RefKey]bool) []RefKey

type Schema

+ func (s *Schema) External() *Schema

May 1, 2025

Changes in this version

type Realm

+ func (r *Realm) ModuleNames() []string

type RefKey

+ func (r RefKey) ModuleOnly() RefKey

type Schema

+ func (s *Schema) FilterModules(modules []RefKey) (*Schema, []RefKey)

+ func (s *Schema) FirstInternalRealm() optional.Option[*Realm]

Apr 30, 2025

Changes in this version

type Config

+ func (s *Config) GetVisibility() Visibility

type Data

+ Visibility Visibility

+ func (d *Data) GetVisibility() Visibility

type Database

+ func (d *Database) GetVisibility() Visibility

type Decl

+ GetVisibility func() Visibility

type Enum

+ Visibility Visibility

+ func (e *Enum) GetVisibility() Visibility

type Secret

+ func (s *Secret) GetVisibility() Visibility

type Topic

+ Visibility Visibility

+ func (t *Topic) GetVisibility() Visibility

type TypeAlias

+ Visibility Visibility

+ func (t *TypeAlias) GetVisibility() Visibility

type Verb

+ Visibility Visibility

+ func (v *Verb) GetVisibility() Visibility

+ type Visibility int

+ const VisibilityScopeModule

+ const VisibilityScopeNone

+ const VisibilityScopeRealm

+ func VisibilityFromProto(v destpb.Visibility) (Visibility, error)

+ func (v *Visibility) Parse(lex *lexer.PeekingLexer) error

+ func (v Visibility) Exported() bool

+ func (v Visibility) String() string

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

Apr 22, 2025

Changes in this version

type Any

+ func (*Any) Kind() Kind

type Array

+ func (a *Array) Kind() Kind

type Bool

+ func (*Bool) Kind() Kind

type Bytes

+ func (*Bytes) Kind() Kind

type Changeset

+ RealmChanges []*RealmChange

+ func (c *Changeset) InternalRealm() *RealmChange

+ func (c *Changeset) Realm(name string) optional.Option[*RealmChange]

type ChangesetState

+ func (s ChangesetState) String() string

type Data

+ func (d *Data) Equal(other Type) bool

+ func (d *Data) Kind() Kind

+ type EgressRuntime struct

+ Targets []EgressTarget

+ func EgressRuntimeFromProto(v *destpb.EgressRuntime) (out *EgressRuntime, err error)

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

+ type EgressTarget struct

+ Expression string

+ Target string

+ func EgressTargetFromProto(v *destpb.EgressTarget) (out *EgressTarget, err error)

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

type Enum

+ func (*Enum) Kind() Kind

+ func (e *Enum) Equal(other Type) bool

type EnumVariant

+ func (e *EnumVariant) Equal(o *EnumVariant) bool

type Float

+ func (*Float) Kind() Kind

type Int

+ func (*Int) Kind() Kind

type IntValue

+ func (i *IntValue) Equal(other Value) bool

+ type Kind int

+ const KindAny

+ const KindArray

+ const KindBool

+ const KindBytes

+ const KindData

+ const KindEnum

+ const KindFloat

+ const KindInt

+ const KindMap

+ const KindOptional

+ const KindRef

+ const KindString

+ const KindTime

+ const KindTypeAlias

+ const KindUnit

+ func (k Kind) String() string

type Map

+ func (*Map) Kind() Kind

+ type MetadataEgress struct

+ Pos Position

+ Targets []string

+ func MetadataEgressFromProto(v *destpb.MetadataEgress) (out *MetadataEgress, err error)

+ func (m *MetadataEgress) Position() Position

+ func (m *MetadataEgress) String() string

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

type Optional

+ func (*Optional) Kind() Kind

+ type RealmChange struct

+ External bool

+ Modules []*Module

+ Name string

+ RemovingModules []*Module

+ ToRemove []string

+ func RealmChangeFromProto(v *destpb.RealmChange) (out *RealmChange, err error)

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

+ type RealmState struct

+ External bool

+ Name string

+ func RealmStateFromProto(v *destpb.RealmState) (out *RealmState, err error)

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

type Ref

+ func (r *Ref) Kind() Kind

type ResourceType

+ const ResourceTypeEgress

type Schema

+ func (s *Schema) IncludeBuiltins() *Schema

+ func (s *Schema) ResolveType(ref *Ref) (Type, error)

type SchemaState

+ Realms []*RealmState

type String

+ func (*String) Kind() Kind

type StringValue

+ func (s *StringValue) Equal(other Value) bool

type Time

+ func (*Time) Kind() Kind

type Type

+ Kind func() Kind

type TypeAlias

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

+ func (t *TypeAlias) Kind() Kind

type TypeValue

+ func (t *TypeValue) Equal(other Value) bool

type Unit

+ func (u *Unit) Kind() Kind

type Value

+ Equal func(other Value) bool

type Verb

+ func (v *Verb) AddEgress(target string)

+ func (v *Verb) GetMetadataEgress() optional.Option[*MetadataEgress]

type VerbRuntime

+ EgressRuntime *EgressRuntime

Apr 11, 2025

Changes in this version

type ModuleRuntimeRunner

+ RunnerNotRequired bool

+ func (m *ModuleRuntimeRunner) GetRunnerNotRequired() bool

+ func (m *ModuleRuntimeRunner) Provisioned() bool

Apr 5, 2025

Changes in this version

+ type Realm struct

+ External bool

+ Modules []*Module

+ Name string

+ Pos Position

+ func RealmFromProto(v *destpb.Realm) (out *Realm, err error)

+ func (r *Realm) ContainsRef(ref *Ref) bool

+ func (r *Realm) Deployment(name key.Deployment) optional.Option[*Module]

+ func (r *Realm) Module(name string) optional.Option[*Module]

+ func (r *Realm) ModuleDependencies(module string) map[string]*Module

+ func (r *Realm) Position() Position

+ func (r *Realm) ResolveToType(ref *Ref, out Decl) error

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

+ func (r *Realm) String() string

+ func (r *Realm) Upsert(module *Module)

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

type Schema

+ Realms []*Realm

+ func (s *Schema) InternalModules() []*Module

+ func (s *Schema) InternalRealms() []*Realm

Apr 3, 2025

Changes in this version

type MetadataDatabases

+ Uses []*Ref

Apr 2, 2025

Changes in this version

+ type MetadataTransaction struct

+ Pos Position

+ func MetadataTransactionFromProto(v *destpb.MetadataTransaction) (out *MetadataTransaction, err error)

+ func (m *MetadataTransaction) Position() Position

+ func (m *MetadataTransaction) String() string

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

type Verb

+ func (v *Verb) IsQuery() bool

+ func (v *Verb) IsTransaction() bool

+ func (v *Verb) ResolveCalls(schema *Schema, module string) sets.Set[RefKey]

+ func (v *Verb) ResolveDatabaseUses(schema *Schema, module string) sets.Set[RefKey]

Mar 20, 2025

Changes in this version

+ type MetadataFixture struct

+ Manual bool

+ Pos Position

+ func MetadataFixtureFromProto(v *destpb.MetadataFixture) (out *MetadataFixture, err error)

+ func (m *MetadataFixture) Position() Position

+ func (m *MetadataFixture) String() string

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

type ResourceType

+ const ResourceTypeFixture

Mar 17, 2025

Changes in this version

+ func ValidateJSONCall(jsonBytes []byte, verbRef *Ref, sch *Schema) error

type MetadataCalls

+ func (m *MetadataCalls) Append(ref *Ref)

type MetadataConfig

+ func (m *MetadataConfig) Append(ref *Ref)

type MetadataDatabases

+ func (m *MetadataDatabases) Append(call *Ref)

type MetadataPublisher

+ func (m *MetadataPublisher) Append(topic *Ref)

type MetadataSecrets

+ func (m *MetadataSecrets) Append(secret *Ref)

Mar 12, 2025

Changes in this version

type Config

+ func (s *Config) IsGenerated() bool

type Data

+ func (d *Data) IsGenerated() bool

type Database

+ func (d *Database) IsGenerated() bool

type Decl

+ IsGenerated func() bool

type Enum

+ func (e *Enum) IsGenerated() bool

type Module

+ func (m *Module) ToGeneratedModule() *Module

type Secret

+ func (s *Secret) IsGenerated() bool

type Topic

+ func (t *Topic) IsGenerated() bool

type TypeAlias

+ func (t *TypeAlias) IsGenerated() bool

Mar 6, 2025

Changes in this version

+ type MetadataGenerated struct

+ Pos Position

+ func MetadataGeneratedFromProto(v *destpb.MetadataGenerated) (out *MetadataGenerated, err error)

+ func (m *MetadataGenerated) Position() Position

+ func (m *MetadataGenerated) String() string

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

+ type MetadataGit struct

+ Commit string

+ Dirty bool

+ Pos Position

+ Repository string

+ func MetadataGitFromProto(v *destpb.MetadataGit) (out *MetadataGit, err error)

+ func (m *MetadataGit) Position() Position

+ func (m *MetadataGit) String() string

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

Mar 4, 2025

Changes in this version

+ func SubscriptionConnectorToProto(value SubscriptionConnector) *destpb.SubscriptionConnector

+ type PlaintextKafkaSubscriptionConnector struct

+ KafkaBrokers []string

+ func PlaintextKafkaSubscriptionConnectorFromProto(v *destpb.PlaintextKafkaSubscriptionConnector) (out *PlaintextKafkaSubscriptionConnector, err error)

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

+ type SubscriptionConnector interface

+ func SubscriptionConnectorFromProto(v *destpb.SubscriptionConnector) (SubscriptionConnector, error)

type VerbRuntime

+ SubscriptionConnector SubscriptionConnector

Mar 3, 2025

Changes in this version

+ func EBNF() string

type DSNDatabaseConnector

+ Database string

type Type

+ func ParseTypeWithLexer(pl *lexer.PeekingLexer) (Type, error)

Feb 25, 2025

Changes in this version

+ func VisitWithParents(n Node, parents []Node, ...) error

Feb 18, 2025

Changes in this version

type ProvisionedResource

+ DeploymentSpecific bool

type Schema

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

Feb 11, 2025

Changes in this version

+ type ChangesetRollingBackEvent struct

+ Error string

+ Key key.Changeset

+ func ChangesetRollingBackEventFromProto(v *destpb.ChangesetRollingBackEvent) (out *ChangesetRollingBackEvent, err error)

+ func (e *ChangesetRollingBackEvent) DebugString() string

+ func (e *ChangesetRollingBackEvent) Validate() error

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

type ChangesetRollingBackNotification

+ Changeset *Changeset

Feb 6, 2025

Changes in this version

type SchemaState

+ ChangesetEvents []*DeploymentRuntimeEvent

+ DeploymentEvents []*DeploymentRuntimeEvent

Feb 6, 2025

Changes in this version

+ func NotificationToProto(value Notification) *destpb.Notification

+ func RuntimeToProto(value Runtime) *destpb.Runtime

+ type ChangesetCommittedNotification struct

+ Changeset *Changeset

+ func ChangesetCommittedNotificationFromProto(v *destpb.ChangesetCommittedNotification) (out *ChangesetCommittedNotification, err error)

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

+ type ChangesetCreatedNotification struct

+ Changeset *Changeset

+ func ChangesetCreatedNotificationFromProto(v *destpb.ChangesetCreatedNotification) (out *ChangesetCreatedNotification, err error)

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

+ type ChangesetDrainedNotification struct

+ Key key.Changeset

+ func ChangesetDrainedNotificationFromProto(v *destpb.ChangesetDrainedNotification) (out *ChangesetDrainedNotification, err error)

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

+ type ChangesetFailedNotification struct

+ Error string

+ Key key.Changeset

+ func ChangesetFailedNotificationFromProto(v *destpb.ChangesetFailedNotification) (out *ChangesetFailedNotification, err error)

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

+ type ChangesetFinalizedNotification struct

+ Key key.Changeset

+ func ChangesetFinalizedNotificationFromProto(v *destpb.ChangesetFinalizedNotification) (out *ChangesetFinalizedNotification, err error)

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

+ type ChangesetPreparedNotification struct

+ Key key.Changeset

+ func ChangesetPreparedNotificationFromProto(v *destpb.ChangesetPreparedNotification) (out *ChangesetPreparedNotification, err error)

+ func (e *ChangesetPreparedNotification) DebugString() string

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

+ type ChangesetRollingBackNotification struct

+ Error string

+ Key key.Changeset

+ func ChangesetRollingBackNotificationFromProto(v *destpb.ChangesetRollingBackNotification) (out *ChangesetRollingBackNotification, err error)

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

+ type DeploymentRuntimeEvent struct

+ Changeset *key.Changeset

+ Payload *RuntimeElement

+ func DeploymentRuntimeEventFromProto(v *destpb.DeploymentRuntimeEvent) (out *DeploymentRuntimeEvent, err error)

+ func (e *DeploymentRuntimeEvent) ChangesetKey() optional.Option[key.Changeset]

+ func (e *DeploymentRuntimeEvent) DebugString() string

+ func (e *DeploymentRuntimeEvent) DeploymentKey() key.Deployment

+ func (e *DeploymentRuntimeEvent) Validate() error

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

+ type DeploymentRuntimeNotification struct

+ Changeset *key.Changeset

+ Payload *RuntimeElement

+ func DeploymentRuntimeNotificationFromProto(v *destpb.DeploymentRuntimeNotification) (out *DeploymentRuntimeNotification, err error)

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

+ type FullSchemaNotification struct

+ Changesets []*Changeset

+ Schema *Schema

+ func FullSchemaNotificationFromProto(v *destpb.FullSchemaNotification) (out *FullSchemaNotification, err error)

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

+ type Notification interface

+ func NotificationFromProto(v *destpb.Notification) (Notification, error)

+ type Runtime interface

+ func RuntimeFromProto(v *destpb.Runtime) (Runtime, error)

+ type RuntimeElement struct

+ Deployment key.Deployment

+ Element Runtime

+ Name optional.Option[string]

+ func RuntimeElementFromProto(v *destpb.RuntimeElement) (out *RuntimeElement, err error)

+ func (x *RuntimeElement) ApplyToModule(state *Module) error

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

Feb 5, 2025

Changes in this version

type ChangesetCommittedEvent

+ func (e *ChangesetCommittedEvent) DebugString() string

type ChangesetCreatedEvent

+ func (e *ChangesetCreatedEvent) DebugString() string

type ChangesetDrainedEvent

+ func (e *ChangesetDrainedEvent) DebugString() string

type ChangesetFailedEvent

+ func (e *ChangesetFailedEvent) DebugString() string

type ChangesetFinalizedEvent

+ func (e *ChangesetFinalizedEvent) DebugString() string

type ChangesetPreparedEvent

+ func (e *ChangesetPreparedEvent) DebugString() string

type DatabaseRuntimeEvent

+ Deployment key.Deployment

+ func (e *DatabaseRuntimeEvent) ChangesetKey() optional.Option[key.Changeset]

+ func (e *DatabaseRuntimeEvent) DebugString() string

+ func (e *DatabaseRuntimeEvent) DeploymentKey() key.Deployment

type DeploymentActivatedEvent

+ func (r *DeploymentActivatedEvent) DebugString() string

type DeploymentCreatedEvent

+ func (r *DeploymentCreatedEvent) DebugString() string

type DeploymentDeactivatedEvent

+ func (r *DeploymentDeactivatedEvent) DebugString() string

type DeploymentReplicasUpdatedEvent

+ func (r *DeploymentReplicasUpdatedEvent) DebugString() string

type DeploymentSchemaUpdatedEvent

+ func (r *DeploymentSchemaUpdatedEvent) DebugString() string

type Event

+ DebugString func() string

type ModuleRuntime

+ Runner *ModuleRuntimeRunner

+ func (m *ModuleRuntime) GetRunner() *ModuleRuntimeRunner

+ func (m *ModuleRuntime) ModRunner() *ModuleRuntimeRunner

type ModuleRuntimeEvent

+ Key key.Deployment

+ Runner optional.Option[ModuleRuntimeRunner]

+ func (e *ModuleRuntimeEvent) ChangesetKey() optional.Option[key.Changeset]

+ func (e *ModuleRuntimeEvent) DebugString() string

+ type ModuleRuntimeRunner struct

+ Endpoint string

+ func ModuleRuntimeRunnerFromProto(v *destpb.ModuleRuntimeRunner) (out *ModuleRuntimeRunner, err error)

+ func (m *ModuleRuntimeRunner) GetEndpoint() string

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

type RuntimeEvent

+ ChangesetKey func() optional.Option[key.Changeset]

+ DebugString func() string

+ DeploymentKey func() key.Deployment

+ Validate func() error

type SchemaState

+ RuntimeEvents []RuntimeEvent

type TopicRuntimeEvent

+ Deployment key.Deployment

+ func (e *TopicRuntimeEvent) ChangesetKey() optional.Option[key.Changeset]

+ func (e *TopicRuntimeEvent) DebugString() string

+ func (e *TopicRuntimeEvent) DeploymentKey() key.Deployment

type VerbRuntimeEvent

+ Deployment key.Deployment

+ func (e *VerbRuntimeEvent) ChangesetKey() optional.Option[key.Changeset]

+ func (e *VerbRuntimeEvent) DebugString() string

+ func (e *VerbRuntimeEvent) DeploymentKey() key.Deployment

Feb 4, 2025

Changes in this version

type Changeset

+ func (c *Changeset) ModulesAreCanonical() bool

+ func (c *Changeset) OwnedModules() []*Module

+ type ChangesetDrainedEvent struct

+ Key key.Changeset

+ func ChangesetDrainedEventFromProto(v *destpb.ChangesetDrainedEvent) (out *ChangesetDrainedEvent, err error)

+ func (e *ChangesetDrainedEvent) Validate() error

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

+ type ChangesetFinalizedEvent struct

+ Key key.Changeset

+ func ChangesetFinalizedEventFromProto(v *destpb.ChangesetFinalizedEvent) (out *ChangesetFinalizedEvent, err error)

+ func (e *ChangesetFinalizedEvent) Validate() error

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

type ChangesetState

+ const ChangesetStateDrained

+ const ChangesetStateFinalized

Feb 3, 2025

Changes in this version

+ func ValidateModuleName(name string) bool

+ type Changeset struct

+ CreatedAt time.Time

+ Error string

+ Key key.Changeset

+ Modules []*Module

+ RemovingModules []*Module

+ State ChangesetState

+ ToRemove []string

+ func ChangesetFromProto(v *destpb.Changeset) (out *Changeset, err error)

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

+ type ChangesetCommittedEvent struct

+ Key key.Changeset

+ func ChangesetCommittedEventFromProto(v *destpb.ChangesetCommittedEvent) (out *ChangesetCommittedEvent, err error)

+ func (e *ChangesetCommittedEvent) Validate() error

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

+ type ChangesetCreatedEvent struct

+ Changeset *Changeset

+ func ChangesetCreatedEventFromProto(v *destpb.ChangesetCreatedEvent) (out *ChangesetCreatedEvent, err error)

+ func (e *ChangesetCreatedEvent) Validate() error

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

+ type ChangesetFailedEvent struct

+ Error string

+ Key key.Changeset

+ func ChangesetFailedEventFromProto(v *destpb.ChangesetFailedEvent) (out *ChangesetFailedEvent, err error)

+ func (e *ChangesetFailedEvent) Validate() error

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

+ type ChangesetPreparedEvent struct

+ Key key.Changeset

+ func ChangesetPreparedEventFromProto(v *destpb.ChangesetPreparedEvent) (out *ChangesetPreparedEvent, err error)

+ func (e *ChangesetPreparedEvent) Validate() error

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

+ type ChangesetState int

+ const ChangesetStateCleaningUp

+ const ChangesetStateCommitted

+ const ChangesetStateFailed

+ const ChangesetStatePrepared

+ const ChangesetStatePreparing

+ const ChangesetStateRollingBack

+ const ChangesetStateUnspecified

+ func ChangesetStateFromProto(v destpb.ChangesetState) (ChangesetState, error)

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

type DatabaseRuntimeEvent

+ Changeset key.Changeset

+ func (e *DatabaseRuntimeEvent) Validate() error

type DeploymentActivatedEvent

+ Changeset *key.Changeset

+ func (r *DeploymentActivatedEvent) Validate() error

type DeploymentCreatedEvent

+ Changeset *key.Changeset

+ func (r *DeploymentCreatedEvent) Validate() error

type DeploymentDeactivatedEvent

+ Changeset *key.Changeset

+ func (r *DeploymentDeactivatedEvent) Validate() error

type DeploymentReplicasUpdatedEvent

+ Changeset *key.Changeset

+ func (r *DeploymentReplicasUpdatedEvent) Validate() error

type DeploymentSchemaUpdatedEvent

+ Changeset key.Changeset

+ func (r *DeploymentSchemaUpdatedEvent) Validate() error

+ type DeploymentState int

+ const DeploymentStateCanary

+ const DeploymentStateCanonical

+ const DeploymentStateDeProvisioning

+ const DeploymentStateDeleted

+ const DeploymentStateDraining

+ const DeploymentStateFailed

+ const DeploymentStateProvisioning

+ const DeploymentStateReady

+ const DeploymentStateUnspecified

+ func DeploymentStateFromProto(v destpb.DeploymentState) (DeploymentState, error)

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

type Event

+ Validate func() error

type ModuleRuntimeDeployment

+ State DeploymentState

type ModuleRuntimeEvent

+ Changeset *key.Changeset

+ func (e *ModuleRuntimeEvent) Validate() error

+ type SchemaState struct

+ Changesets []*Changeset

+ Modules []*Module

+ func SchemaStateFromProto(v *destpb.SchemaState) (out *SchemaState, err error)

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

type TopicRuntimeEvent

+ Changeset key.Changeset

+ func (e *TopicRuntimeEvent) Validate() error

type VerbRuntimeEvent

+ Changeset key.Changeset

+ func (e *VerbRuntimeEvent) Validate() error

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]

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

Jan 20, 2025

Changes in this version

type Verb

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

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)

Jan 15, 2025

Changes in this version

type Verb

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

+ func (v *Verb) IsGenerated() bool

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

Jan 14, 2025

Changes in this version

type ModuleRuntimeDeployment

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

+ func (m *ModuleRuntimeDeployment) GetDeploymentKey() string

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

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

Dec 21, 2024

Changes in this version

+ func DeadLetterNameForSubscriber(verb string) string

Dec 19, 2024

Changes in this version

type Schema

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

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