schema

Nov 28, 2024

Changes in this version

+ type AWSIAMAuthDatabaseConnector struct

+ Database string

+ Endpoint string

+ Pos Position

+ Username string

+ func (d *AWSIAMAuthDatabaseConnector) Position() Position

+ func (d *AWSIAMAuthDatabaseConnector) String() string

+ func (d *AWSIAMAuthDatabaseConnector) ToProto() protoreflect.ProtoMessage

Nov 28, 2024

Changes in this version

+ type FromOffset int

+ const FromOffsetBeginning

+ const FromOffsetLatest

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

+ func (o FromOffset) String() string

+ func (o FromOffset) ToProto() schemapb.FromOffset

type MetadataSubscriber

+ DeadLetter bool

+ FromOffset FromOffset

+ Topic *Ref

type VerbRuntime

+ KafkaBrokers []string

Nov 27, 2024

Changes in this version

+ type DSNDatabaseConnector struct

+ DSN string

+ Pos Position

+ func (d *DSNDatabaseConnector) Position() Position

+ func (d *DSNDatabaseConnector) String() string

+ func (d *DSNDatabaseConnector) ToProto() protoreflect.ProtoMessage

+ type DatabaseConnector interface

+ func DatabaseConnectorFromProto(s *schemapb.DatabaseConnector) DatabaseConnector

type DatabaseRuntime

+ ReadConnector DatabaseConnector

+ WriteConnector DatabaseConnector

+ func (d *DatabaseRuntime) Position() Position

+ func (d *DatabaseRuntime) String() string

type MetadataIngress

+ func (m *MetadataIngress) PathString() string

Nov 26, 2024

Changes in this version

+ type DSNDatabaseRuntime struct

+ DSN string

+ Pos Position

+ func (d *DSNDatabaseRuntime) Position() Position

+ func (d *DSNDatabaseRuntime) String() string

+ func (d *DSNDatabaseRuntime) ToProto() protoreflect.ProtoMessage

type Subscription

+ Runtime *SubscriptionRuntime

+ type SubscriptionRuntime struct

+ ConsumerGroupID string

+ KafkaBrokers []string

+ TopicID string

+ func SubscriptionRuntimeFromProto(s *schemapb.SubscriptionRuntime) *SubscriptionRuntime

+ func (s *SubscriptionRuntime) ToProto() *schemapb.SubscriptionRuntime

type Topic

+ Runtime *TopicRuntime

+ type TopicRuntime struct

+ KafkaBrokers []string

+ TopicID string

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

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

Nov 25, 2024

Changes in this version

type Verb

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

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

Nov 25, 2024

Changes in this version

type Database

+ Metadata []Metadata

+ type MetadataSQLMigration struct

+ Digest string

+ Pos Position

+ func (m *MetadataSQLMigration) Position() Position

+ func (m *MetadataSQLMigration) String() string

+ func (m *MetadataSQLMigration) ToProto() proto.Message

Nov 20, 2024

Changes in this version

+ const MySQLDatabaseType

+ type MetadataPublisher struct

+ Pos Position

+ Topics []*Ref

+ func (m *MetadataPublisher) Position() Position

+ func (m *MetadataPublisher) String() string

+ func (m *MetadataPublisher) ToProto() proto.Message

type Verb

+ func (v *Verb) SortMetadata()

Nov 7, 2024

Changes in this version

type ModuleRuntime

+ Image string

Nov 1, 2024

Changes in this version

type Verb

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

Oct 16, 2024

Changes in this version

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

type Database

+ Runtime *DatabaseRuntime

+ func (d *Database) Redact()

+ type DatabaseRuntime struct

+ DSN string

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

+ func (d *DatabaseRuntime) ToProto() *schemapb.DatabaseRuntime

+ type Redactable interface

+ Redact func()

Oct 11, 2024

Changes in this version

+ const BuiltinsSource

+ const DefaultMaxBackoff

+ const DefaultRetryCount

+ const MaxBackoffLimit

+ const MaxBackoffLimitStr

+ const MinBackoffLimit

+ const MinBackoffLimitStr

+ const PostgresDatabaseType

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

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

+ func AliasKindStrings() []string

+ func EncodeComments(comments []string) string

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

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

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

+ 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(t Type) *schemapb.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 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 AliasKind int

+ const AliasKindJson

+ 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

+ 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 (a *Any) ToProto() proto.Message

+ 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 (a *Array) ToProto() proto.Message

+ 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 (b *Bool) ToProto() proto.Message

+ 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 (b *Bytes) ToProto() proto.Message

+ 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 (s *Config) ToProto() protoreflect.ProtoMessage

+ 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 (d *Data) ToProto() proto.Message

+ type Database struct

+ Comments []string

+ Name string

+ Pos Position

+ Type string

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

+ func (d *Database) GetName() string

+ func (d *Database) IsExported() bool

+ func (d *Database) Position() Position

+ func (d *Database) String() string

+ func (d *Database) ToProto() proto.Message

+ 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) ToProto() proto.Message

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

+ type EnumVariant struct

+ Comments []string

+ Name string

+ Pos Position

+ Value Value

+ func (e *EnumVariant) Position() Position

+ func (e *EnumVariant) String() string

+ func (e *EnumVariant) ToProto() proto.Message

+ type FSM struct

+ Comments []string

+ Metadata []Metadata

+ Name string

+ Pos Position

+ Start []*Ref

+ Transitions []*FSMTransition

+ func FSMFromProto(pb *schemapb.FSM) *FSM

+ func (f *FSM) GetName() string

+ func (f *FSM) IsExported() bool

+ func (f *FSM) NextState(sch *Schema, currentState optional.Option[RefKey], event Type) optional.Option[*Ref]

+ func (f *FSM) Position() Position

+ func (f *FSM) String() string

+ func (f *FSM) TerminalStates() []*Ref

+ func (f *FSM) ToProto() protoreflect.ProtoMessage

+ type FSMTransition struct

+ Comments []string

+ From *Ref

+ Pos Position

+ To *Ref

+ func FSMTransitionFromProto(pb *schemapb.FSMTransition) *FSMTransition

+ func (f *FSMTransition) Position() Position

+ func (f *FSMTransition) String() string

+ func (f *FSMTransition) ToProto() protoreflect.ProtoMessage

+ 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 (f *Field) ToProto() proto.Message

+ 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 (f *Float) ToProto() proto.Message

+ type IngressPathComponent interface

+ type IngressPathLiteral struct

+ Pos Position

+ Text string

+ func (l *IngressPathLiteral) Position() Position

+ func (l *IngressPathLiteral) String() string

+ func (l *IngressPathLiteral) ToProto() proto.Message

+ type IngressPathParameter struct

+ Name string

+ Pos Position

+ func (l *IngressPathParameter) Position() Position

+ func (l *IngressPathParameter) String() string

+ func (l *IngressPathParameter) ToProto() proto.Message

+ 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 (i *Int) ToProto() proto.Message

+ type IntValue struct

+ Pos Position

+ Value int

+ func (i *IntValue) GetValue() any

+ func (i *IntValue) Position() Position

+ func (i *IntValue) String() string

+ func (i *IntValue) ToProto() proto.Message

+ 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 (m *Map) ToProto() proto.Message

+ type Metadata interface

+ type MetadataAlias struct

+ Alias string

+ Kind AliasKind

+ Pos Position

+ func (m *MetadataAlias) Position() Position

+ func (m *MetadataAlias) String() string

+ func (m *MetadataAlias) ToProto() protoreflect.ProtoMessage

+ type MetadataCalls struct

+ Calls []*Ref

+ Pos Position

+ func (m *MetadataCalls) Position() Position

+ func (m *MetadataCalls) String() string

+ func (m *MetadataCalls) ToProto() proto.Message

+ type MetadataConfig struct

+ Config []*Ref

+ Pos Position

+ func (m *MetadataConfig) Position() Position

+ func (m *MetadataConfig) String() string

+ func (m *MetadataConfig) ToProto() proto.Message

+ type MetadataCronJob struct

+ Cron string

+ Pos Position

+ func (m *MetadataCronJob) Position() Position

+ func (m *MetadataCronJob) String() string

+ func (m *MetadataCronJob) ToProto() proto.Message

+ type MetadataDatabases struct

+ Calls []*Ref

+ Pos Position

+ func (m *MetadataDatabases) Position() Position

+ func (m *MetadataDatabases) String() string

+ func (m *MetadataDatabases) ToProto() proto.Message

+ type MetadataEncoding struct

+ Lenient bool

+ Pos Position

+ Type string

+ func (m *MetadataEncoding) Position() Position

+ func (m *MetadataEncoding) String() string

+ func (m *MetadataEncoding) ToProto() protoreflect.ProtoMessage

+ type MetadataIngress struct

+ Method string

+ Path []IngressPathComponent

+ Pos Position

+ Type string

+ func (m *MetadataIngress) Position() Position

+ func (m *MetadataIngress) String() string

+ func (m *MetadataIngress) ToProto() proto.Message

+ 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 (m *MetadataRetry) ToProto() proto.Message

+ type MetadataSecrets struct

+ Pos Position

+ Secrets []*Ref

+ func (m *MetadataSecrets) Position() Position

+ func (m *MetadataSecrets) String() string

+ func (m *MetadataSecrets) ToProto() proto.Message

+ type MetadataSubscriber struct

+ Name string

+ Pos Position

+ func (m *MetadataSubscriber) Position() Position

+ func (m *MetadataSubscriber) String() string

+ func (m *MetadataSubscriber) ToProto() proto.Message

+ type MetadataTypeMap struct

+ NativeName string

+ Pos Position

+ Runtime string

+ func (m *MetadataTypeMap) Position() Position

+ func (m *MetadataTypeMap) String() string

+ func (m *MetadataTypeMap) ToProto() protoreflect.ProtoMessage

+ type Module struct

+ Builtin bool

+ Comments []string

+ Decls []Decl

+ 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) Imports() []string

+ func (m *Module) IsExported() bool

+ func (m *Module) Position() Position

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

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

+ func (m *Module) String() string

+ func (m *Module) ToProto() proto.Message

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

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

+ 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

+ Arch string

+ CreateTime time.Time

+ Language string

+ MinReplicas int32

+ OS string

+ type Named interface

+ GetName func() string

+ type Node interface

+ Position func() Position

+ String func() string

+ ToProto func() proto.Message

+ 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 (o *Optional) ToProto() proto.Message

+ 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 (p Position) ToProto() proto.Message

+ 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) ToProto() proto.Message

+ func (r Ref) ToRefKey() RefKey

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

+ 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 RetryParams struct

+ Catch optional.Option[RefKey]

+ Count int

+ MaxBackoff time.Duration

+ MinBackoff time.Duration

+ func RetryParamsForFSMTransition(fsm *FSM, verb *Verb) (RetryParams, error)

+ 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) ToProto() proto.Message

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

+ 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 (s *Secret) ToProto() protoreflect.ProtoMessage

+ 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 (s *String) ToProto() proto.Message

+ type StringValue struct

+ Pos Position

+ Value string

+ func (s *StringValue) GetValue() any

+ func (s *StringValue) Position() Position

+ func (s *StringValue) String() string

+ func (s *StringValue) ToProto() proto.Message

+ type Subscription struct

+ Comments []string

+ Name string

+ Pos Position

+ Topic *Ref

+ func SubscriptionFromProto(s *schemapb.Subscription) *Subscription

+ func (s *Subscription) GetName() string

+ func (s *Subscription) IsExported() bool

+ func (s *Subscription) Position() Position

+ func (s *Subscription) String() string

+ func (s *Subscription) ToProto() proto.Message

+ 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 (t *Time) ToProto() proto.Message

+ type Topic struct

+ Comments []string

+ Event Type

+ Export bool

+ Name string

+ Pos Position

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

+ func (t *Topic) GetName() string

+ func (t *Topic) IsExported() bool

+ func (t *Topic) Position() Position

+ func (t *Topic) String() string

+ func (t *Topic) ToProto() proto.Message

+ 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 (t *TypeAlias) ToProto() proto.Message

+ type TypeParameter struct

+ Name string

+ Pos Position

+ func (t *TypeParameter) GetName() string

+ func (t *TypeParameter) Position() Position

+ func (t *TypeParameter) String() string

+ func (t *TypeParameter) ToProto() protoreflect.ProtoMessage

+ type TypeValue struct

+ Pos Position

+ Value Type

+ func (t *TypeValue) GetValue() any

+ func (t *TypeValue) Position() Position

+ func (t *TypeValue) String() string

+ func (t *TypeValue) ToProto() proto.Message

+ 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 (u *Unit) ToProto() protoreflect.ProtoMessage

+ 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) AddSecret(secret *Ref)

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

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

+ func (v *Verb) GetName() string

+ func (v *Verb) IsExported() bool

+ func (v *Verb) Kind() VerbKind

+ func (v *Verb) Position() Position

+ func (v *Verb) String() string

+ func (v *Verb) ToProto() proto.Message

+ type VerbKind string

+ const VerbKindEmpty

+ const VerbKindSink

+ const VerbKindSource

+ const VerbKindVerb

+ type VerbRuntime struct

+ CreateTime time.Time

+ StartTime time.Time

+ Status VerbStatus

+ type VerbStatus int

+ const VerbStatusError

+ const VerbStatusOffline

+ const VerbStatusOnline

+ const VerbStatusStarting

+ const VerbStatusStopped

+ const VerbStatusStopping