schema

package
v0.113.1 Latest Latest
Warning

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

 Go to latest Published: Feb 1, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Lexer = lexer.MustSimple([]lexer.SimpleRule{
		{Name: "Whitespace", Pattern: `\s+`},
		{Name: "Ident", Pattern: `\b[a-zA-Z_][a-zA-Z0-9_]*\b`},
		{Name: "Comment", Pattern: `//.*`},
		{Name: "String", Pattern: `"(?:\\.|[^"])*"`},
		{Name: "Number", Pattern: `[0-9]+(?:\.[0-9]+)?`},
		{Name: "Punct", Pattern: `[%/\-\_:[\]{}<>()*+?.,\\^$|#~!\'@]`},
	})
)

Functions

func DataToJSONSchema added in v0.1.1 

func DataToJSONSchema(schema *Schema, dataRef DataRef) (*jsonschema.Schema, error)

DataToJSONSchema converts the schema for a Data object to a JSON Schema.

It takes in the full schema in order to resolve and define references.

func ModuleToBytes added in v0.111.2 

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

func Normalise 

func Normalise[T Node](n T) T

Normalise clones and normalises (zeroes) positional information in schema Nodes.

func ProtobufSchema 

func ProtobufSchema() string

ProtobufSchema returns a string containing the equivalent protobuf schema for the FTL schema.

func TypeName added in v0.98.11 

func TypeName(v any) string

func ValidateModule 

func ValidateModule(module *Module) error

ValidateModule performs the subset of semantic validation possible on a single module.

It ignores references to other modules.

func ValidateName added in v0.99.0 

func ValidateName(name string) bool

ValidateName validates an FTL name.

func Visit 

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

Visit all nodes in the schema.

Types

type AbstractRef added in v0.93.0 

type AbstractRef[Proto RefProto] Ref

AbstractRef is an abstract reference to a function or data type.

func ParseRef 

func ParseRef[Proto RefProto](ref string) (*AbstractRef[Proto], error)

func (*AbstractRef[Proto]) Position added in v0.100.0 

func (a *AbstractRef[Proto]) Position() Position

func (*AbstractRef[Proto]) String added in v0.93.0 

func (a *AbstractRef[Proto]) String() string

func (*AbstractRef[Proto]) ToProto added in v0.93.0 

func (a *AbstractRef[Proto]) ToProto() proto.Message

func (*AbstractRef[Proto]) Untyped added in v0.100.0 

func (a *AbstractRef[Proto]) Untyped() Ref

Untyped converts a typed reference to an untyped reference.

type Any added in v0.100.0 

type Any struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Any bool `parser:"@'Any'" protobuf:"-"`
}

func (*Any) Position added in v0.100.0 

func (a *Any) Position() Position

func (*Any) String added in v0.100.0 

func (*Any) String() string

func (*Any) ToProto added in v0.100.0 

func (a *Any) ToProto() proto.Message

type Array 

type Array struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Element Type `parser:"'[' @@ ']'" protobuf:"2"`
}

func (*Array) Position added in v0.100.0 

func (a *Array) Position() Position

func (*Array) String 

func (a *Array) String() string

func (*Array) ToProto 

func (a *Array) ToProto() proto.Message

type Bool 

type Bool struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Bool bool `parser:"@'Bool'" protobuf:"-"`
}

func (*Bool) Position added in v0.100.0 

func (b *Bool) Position() Position

func (*Bool) String 

func (*Bool) String() string

func (*Bool) ToProto 

func (b *Bool) ToProto() proto.Message

type Bytes added in v0.88.0 

type Bytes struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Bytes bool `parser:"@'Bytes'" protobuf:"-"`
}

func (*Bytes) Position added in v0.100.0 

func (b *Bytes) Position() Position

func (*Bytes) String added in v0.88.0 

func (*Bytes) String() string

func (*Bytes) ToProto added in v0.88.0 

func (b *Bytes) ToProto() proto.Message

type Data 

type Data struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Comments       []string         `parser:"@Comment*" protobuf:"2"`
	Name           string           `parser:"'data' @Ident" protobuf:"3"`
	TypeParameters []*TypeParameter `parser:"( '<' @@ (',' @@)* '>' )?" protobuf:"6"`
	Fields         []*Field         `parser:"'{' @@* '}'" protobuf:"4"`
	Metadata       []Metadata       `parser:"@@*" protobuf:"5"`
}

A Data structure.

func DataToSchema 

func DataToSchema(s *schemapb.Data) *Data

func (*Data) Monomorphise added in v0.104.0 

func (d *Data) Monomorphise(types ...Type) (*Data, error)

Monomorphise this data type with the given type arguments.

Will return nil if it is not a parametric type.

This will return a new Data structure with all type parameters replaced with the given types.

func (*Data) Position added in v0.100.0 

func (d *Data) Position() Position

func (*Data) Scope added in v0.101.0 

func (d *Data) Scope() Scope

func (*Data) String 

func (d *Data) String() string

func (*Data) ToProto 

func (d *Data) ToProto() proto.Message

type DataRef 

type DataRef struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Module         string `parser:"(@Ident '.')?" protobuf:"3"`
	Name           string `parser:"@Ident" protobuf:"2"`
	TypeParameters []Type `parser:"[ '<' @@ (',' @@)* '>' ]" protobuf:"4"`
}

DataRef is a reference to a data structure.

func DataRefFromProto added in v0.93.0 

func DataRefFromProto(s *schemapb.DataRef) *DataRef

func ParseDataRef added in v0.93.0 

func ParseDataRef(ref string) (*DataRef, error)

func (*DataRef) Position added in v0.100.0 

func (d *DataRef) Position() Position

func (*DataRef) String 

func (d *DataRef) String() string

func (*DataRef) ToProto 

func (d *DataRef) ToProto() protoreflect.ProtoMessage

func (*DataRef) Untyped added in v0.100.0 

func (d *DataRef) Untyped() Ref

Untyped converts a typed reference to an untyped reference.

type Database added in v0.95.0 

type Database struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Comments []string `parser:"@Comment*" protobuf:"3"`
	Name     string   `parser:"'database' @Ident" protobuf:"2"`
}

func DatabaseToSchema added in v0.95.0 

func DatabaseToSchema(s *schemapb.Database) *Database

func (*Database) Position added in v0.100.0 

func (d *Database) Position() Position

func (*Database) String added in v0.95.0 

func (d *Database) String() string

func (*Database) ToProto added in v0.95.0 

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

type Decl 

type Decl interface {
	Node
	// contains filtered or unexported methods
}

Decl represents a type declaration in the schema grammar.

type Field 

type Field struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Comments []string `parser:"@Comment*" protobuf:"3"`
	Name     string   `parser:"@Ident" protobuf:"2"`
	Type     Type     `parser:"@@" protobuf:"4"`
	Alias    string   `parser:"('alias' @Ident)?" protobuf:"5"`
}

func (*Field) Position added in v0.100.0 

func (f *Field) Position() Position

func (*Field) String 

func (f *Field) String() string

func (*Field) ToProto 

func (f *Field) ToProto() proto.Message

type Float 

type Float struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Float bool `parser:"@'Float'" protobuf:"-"`
}

func (*Float) Position added in v0.100.0 

func (f *Float) Position() Position

func (*Float) String 

func (*Float) String() string

func (*Float) ToProto 

func (f *Float) ToProto() proto.Message

type IngressPathComponent added in v0.85.5 

type IngressPathComponent interface {
	Node
	// contains filtered or unexported methods
}

type IngressPathLiteral added in v0.85.5 

type IngressPathLiteral struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Text string `parser:"@~(Whitespace | '/' | '{' | '}')+" protobuf:"2"`
}

func (*IngressPathLiteral) Position added in v0.100.0 

func (l *IngressPathLiteral) Position() Position

func (*IngressPathLiteral) String added in v0.85.5 

func (l *IngressPathLiteral) String() string

func (*IngressPathLiteral) ToProto added in v0.85.5 

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

type IngressPathParameter added in v0.85.5 

type IngressPathParameter struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Name string `parser:"'{' @Ident '}'" protobuf:"2"`
}

func (*IngressPathParameter) Position added in v0.100.0 

func (l *IngressPathParameter) Position() Position

func (*IngressPathParameter) String added in v0.85.5 

func (l *IngressPathParameter) String() string

func (*IngressPathParameter) ToProto added in v0.85.5 

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

type Int 

type Int struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Int bool `parser:"@'Int'" protobuf:"-"`
}

func (*Int) Position added in v0.100.0 

func (i *Int) Position() Position

func (*Int) String 

func (*Int) String() string

func (*Int) ToProto 

func (i *Int) ToProto() proto.Message

type Map 

type Map struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Key   Type `parser:"'{' @@" protobuf:"2"`
	Value Type `parser:"':' @@ '}'" protobuf:"3"`
}

func (*Map) Position added in v0.100.0 

func (m *Map) Position() Position

func (*Map) String 

func (m *Map) String() string

func (*Map) ToProto 

func (m *Map) ToProto() proto.Message

type Metadata 

type Metadata interface {
	Node
	// contains filtered or unexported methods
}

Metadata represents a metadata Node in the schema grammar.

type MetadataCalls 

type MetadataCalls struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Calls []*VerbRef `parser:"'calls' @@ (',' @@)*" protobuf:"2"`
}

func (*MetadataCalls) Position added in v0.100.0 

func (m *MetadataCalls) Position() Position

func (*MetadataCalls) String 

func (m *MetadataCalls) String() string

func (*MetadataCalls) ToProto 

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

type MetadataDatabases added in v0.95.0 

type MetadataDatabases struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Calls []*Database `parser:"'database' 'calls' @@ (',' @@)*" protobuf:"2"`
}

func (*MetadataDatabases) Position added in v0.100.0 

func (m *MetadataDatabases) Position() Position

func (*MetadataDatabases) String added in v0.95.0 

func (m *MetadataDatabases) String() string

func (*MetadataDatabases) ToProto added in v0.95.0 

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

type MetadataIngress 

type MetadataIngress struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Type   string                 `parser:"'ingress' @('http' | 'ftl')?" protobuf:"2"`
	Method string                 `parser:"@('GET' | 'POST' | 'PUT' | 'DELETE')" protobuf:"3"`
	Path   []IngressPathComponent `parser:"('/' @@)+" protobuf:"4"`
}

func (*MetadataIngress) Position added in v0.100.0 

func (m *MetadataIngress) Position() Position

func (*MetadataIngress) String 

func (m *MetadataIngress) String() string

func (*MetadataIngress) ToProto 

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

type Module 

type Module struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Comments []string `parser:"@Comment*" protobuf:"2"`
	Builtin  bool     `parser:"@'builtin'?" protobuf:"3"`
	Name     string   `parser:"'module' @Ident '{'" protobuf:"4"`
	Decls    []Decl   `parser:"@@* '}'" protobuf:"5"`
}

func Builtins added in v0.89.0 

func Builtins() *Module

Builtins returns a Module containing built-in types.

func ModuleFromBytes 

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

func ModuleFromProto 

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

ModuleFromProto converts a protobuf Module to a Module and validates it.

func ParseModule 

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

func ParseModuleString 

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

func (*Module) AddData 

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

AddData and return its index.

func (*Module) Data 

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

func (*Module) Imports added in v0.61.0 

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

Imports returns the modules imported by this module.

func (*Module) Position added in v0.100.0 

func (m *Module) Position() Position

func (*Module) Resolve added in v0.100.0 

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

Resolve returns the declaration in this module with the given name, or nil

func (*Module) Scan added in v0.113.1 

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

func (*Module) Scope added in v0.101.0 

func (m *Module) Scope() Scope

Scope returns a scope containing all the declarations in this module.

func (*Module) String 

func (m *Module) String() string

func (*Module) ToProto 

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

func (*Module) Value added in v0.113.1 

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

func (*Module) Verbs 

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

type ModuleDecl added in v0.100.0 

type ModuleDecl struct {
	Module *Module // May be nil.
	Decl   Decl
}

ModuleDecl is a declaration associated with a module.

type Node 

type Node interface {
	String() string
	ToProto() proto.Message
	Position() Position
	// contains filtered or unexported methods
}

A Node in the schema grammar.

type Optional added in v0.78.0 

type Optional struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Type Type `parser:"@@" protobuf:"2,optional"`
}

Optional represents a Type whose value may be optional.

func (*Optional) Position added in v0.100.0 

func (o *Optional) Position() Position

func (*Optional) String added in v0.78.0 

func (o *Optional) String() string

func (*Optional) ToProto added in v0.78.0 

func (o *Optional) ToProto() proto.Message

type Position 

type Position struct {
	Filename string `protobuf:"1"`
	Offset   int    `parser:"" protobuf:"-"`
	Line     int    `protobuf:"2"`
	Column   int    `protobuf:"3"`
}

func (Position) String 

func (p Position) String() string

func (Position) ToProto 

func (p Position) ToProto() proto.Message

type Ref 

type Ref struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Module string `parser:"(@Ident '.')?" protobuf:"3"`
	Name   string `parser:"@Ident" protobuf:"2"`
}

Ref is an untyped reference to a symbol.

func (*Ref) Position added in v0.100.0 

func (b *Ref) Position() Position

func (*Ref) String 

func (b *Ref) String() string

type RefProto added in v0.93.0 

type RefProto interface {
	schemapb.VerbRef | schemapb.DataRef | schemapb.SinkRef | schemapb.SourceRef
}

RefProto is a constraint on the type of proto that can be used in a Ref.

type Resolver added in v0.100.0 

type Resolver interface {
	// Resolve a reference to a symbol declaration or nil.
	Resolve(ref Ref) *ModuleDecl
}

Resolver may be implemented be a node in the AST to resolve references within itself.

type Schema 

type Schema struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Modules []*Module `parser:"@@*" protobuf:"2"`
}

func FromProto 

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

FromProto converts a protobuf Schema to a Schema and validates it.

func MustValidate added in v0.89.0 

func MustValidate(schema *Schema) *Schema

MustValidate panics if a schema is invalid.

This is useful for testing.

func Parse 

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

func ParseString 

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

func Validate 

func Validate(schema *Schema) (*Schema, error)

Validate clones, normalises and semantically valies a schema.

func (*Schema) DataMap added in v0.53.2 

func (s *Schema) DataMap() map[Ref]*Data

func (*Schema) Hash 

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

func (*Schema) Module added in v0.89.0 

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

Module returns the named module if it exists.

func (*Schema) Position added in v0.100.0 

func (s *Schema) Position() Position

func (*Schema) ResolveDataRef added in v0.80.0 

func (s *Schema) ResolveDataRef(ref *DataRef) *Data

func (*Schema) ResolveDataRefMonomorphised added in v0.113.0 

func (s *Schema) ResolveDataRefMonomorphised(ref *DataRef) (*Data, error)

func (*Schema) ResolveVerbRef added in v0.80.0 

func (s *Schema) ResolveVerbRef(ref *VerbRef) *Verb

func (*Schema) String 

func (s *Schema) String() string

func (*Schema) ToProto 

func (s *Schema) ToProto() proto.Message

func (*Schema) Upsert 

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

Upsert inserts or replaces a module.

type Scope added in v0.100.0 

type Scope map[string]ModuleDecl

Scope maps relative names to fully qualified types.

func (Scope) String added in v0.100.0 

func (s Scope) String() string

type Scoped added in v0.101.0 

type Scoped interface {
	Scope() Scope
}

Scoped is implemented by nodes that wish to introduce a new scope.

type Scopes added in v0.100.0 

type Scopes []Scope

Scopes to search during type resolution.

func NewScopes added in v0.100.0 

func NewScopes() Scopes

NewScopes constructs a new type resolution stack with builtins pre-populated.

func (*Scopes) Add added in v0.100.0 

func (s *Scopes) Add(owner *Module, name string, decl Decl) error

Add a declaration to the current scope.

func (Scopes) Push added in v0.100.0 

func (s Scopes) Push() Scopes

Push a new Scope onto the stack.

This contains references to previous Scopes so that updates are preserved.

func (Scopes) PushScope added in v0.101.0 

func (s Scopes) PushScope(scope Scope) Scopes

func (Scopes) Resolve added in v0.100.0 

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

Resolve a reference to a symbol declaration or nil.

func (Scopes) String added in v0.100.0 

func (s Scopes) String() string

type SinkRef added in v0.93.0 

type SinkRef = AbstractRef[schemapb.SinkRef]

SinkRef is a reference to a Sink.

func ParseSinkRef added in v0.93.0 

func ParseSinkRef(ref string) (*SinkRef, error)

func SinkRefFromProto added in v0.93.0 

func SinkRefFromProto(s *schemapb.SinkRef) *SinkRef

type SourceRef added in v0.93.0 

type SourceRef = AbstractRef[schemapb.SourceRef]

SourceRef is a reference to a Source.

func ParseSourceRef added in v0.93.0 

func ParseSourceRef(ref string) (*SourceRef, error)

func SourceRefFromProto added in v0.93.0 

func SourceRefFromProto(s *schemapb.SourceRef) *SourceRef

type String 

type String struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Str bool `parser:"@'String'" protobuf:"-"`
}

func (*String) Position added in v0.100.0 

func (s *String) Position() Position

func (*String) String 

func (*String) String() string

func (*String) ToProto 

func (s *String) ToProto() proto.Message

type Time 

type Time struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Time bool `parser:"@'Time'" protobuf:"-"`
}

func (*Time) Position added in v0.100.0 

func (t *Time) Position() Position

func (*Time) String 

func (*Time) String() string

func (*Time) ToProto 

func (t *Time) ToProto() proto.Message

type Type 

type Type interface {
	Node
	// contains filtered or unexported methods
}

Type represents a Type Node in the schema grammar.

type TypeParameter added in v0.101.0 

type TypeParameter struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Name string `parser:"@Ident" protobuf:"2"`
}

func (*TypeParameter) Position added in v0.101.0 

func (t *TypeParameter) Position() Position

func (*TypeParameter) String added in v0.101.0 

func (t *TypeParameter) String() string

func (*TypeParameter) ToProto added in v0.101.0 

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

type Unit added in v0.94.0 

type Unit struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Unit bool `parser:"@'Unit'" protobuf:"-"`
}

func (*Unit) Position added in v0.100.0 

func (u *Unit) Position() Position

func (*Unit) String added in v0.94.0 

func (u *Unit) String() string

func (*Unit) ToProto added in v0.94.0 

func (u *Unit) ToProto() protoreflect.ProtoMessage

type Verb 

type Verb struct {
	Pos Position `parser:"" protobuf:"1,optional"`

	Comments []string   `parser:"@Comment*" protobuf:"3"`
	Name     string     `parser:"'verb' @Ident" protobuf:"2"`
	Request  Type       `parser:"'(' @@ ')'" protobuf:"4"`
	Response Type       `parser:"@@" protobuf:"5"`
	Metadata []Metadata `parser:"@@*" protobuf:"6"`
}

func VerbToSchema 

func VerbToSchema(s *schemapb.Verb) *Verb

func (*Verb) AddCall 

func (v *Verb) AddCall(verb *VerbRef)

AddCall adds a call reference to the Verb.

func (*Verb) GetMetadataIngress added in v0.91.0 

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

func (*Verb) Position added in v0.100.0 

func (v *Verb) Position() Position

func (*Verb) String 

func (v *Verb) String() string

func (*Verb) ToProto 

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

type VerbRef 

type VerbRef = AbstractRef[schemapb.VerbRef]

VerbRef is a reference to a Verb.

func ParseVerbRef added in v0.93.0 

func ParseVerbRef(ref string) (*VerbRef, error)

func VerbRefFromProto 

func VerbRefFromProto(s *schemapb.VerbRef) *VerbRef

Source Files

View all Source files

Jump to

Keyboard shortcuts

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