Versions in this module Expand all Collapse all v0 v0.411.0 Dec 14, 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
Go to main page