generator

Documentation

Index

• func BuildNodeTypeSchema(node nodes.Node) schema.NodeType
• func RegisterTypes(typesToRegister *refutil.TypeFactory)
• func WriteMermaid(a App, out io.Writer) error
• type App
  • func (a *App) ApplyGraph(jsonPayload []byte) error
  • func (a *App) FindNodeByID(nodeId string) nodes.Node
  • func (a App) Generate(outputPath string) error
  • func (a *App) GetParameter(nodeId string) Parameter
  • func (a *App) Graph() []byte
  • func (a *App) Run(args []string) error
  • func (a *App) Schema() schema.App
  • func (a *App) SetupProducers()
  • func (a App) SwaggerSpec() swagger.Spec
  • func (a App) WriteSwagger(out io.Writer) error
  • func (a App) WriteZip(out io.Writer) error
• type AppServer
  • func (as *AppServer) AutosaveGraph()
  • func (as *AppServer) MermaidEndpoint(w http.ResponseWriter, r *http.Request)
  • func (as *AppServer) ProducerEndpoint(w http.ResponseWriter, r *http.Request)
  • func (as *AppServer) SceneEndpoint(w http.ResponseWriter, r *http.Request)
  • func (as *AppServer) SchemaEndpoint(w http.ResponseWriter, r *http.Request)
  • func (as *AppServer) Serve() error
  • func (as *AppServer) StartedEndpoint(w http.ResponseWriter, r *http.Request)
  • func (as *AppServer) SwaggerEndpoint(w http.ResponseWriter, r *http.Request)
  • func (as *AppServer) UpdateParameter(key string, msg []byte) (bool, error)
  • func (as *AppServer) ZipEndpoint(w http.ResponseWriter, r *http.Request)
• type Author
• type AuthorContact
• type CustomGraphSerialization
• type Graph
• type GraphNodeInstance
• type NestedSyncMap
  • func NewNestedSyncMap() *NestedSyncMap
  • func (sm *NestedSyncMap) Delete(key string)
  • func (sm *NestedSyncMap) Get(key string) any
  • func (sm *NestedSyncMap) OverwriteData(data map[string]any)
  • func (sm *NestedSyncMap) PathExists(key string) bool
  • func (sm *NestedSyncMap) Set(key string, value any)
• type Parameter
• type SwaggerParameter
• type SyncMap
  • func NewSyncMap[Key comparable, Value any]() *SyncMap[Key, Value]
  • func (sm *SyncMap[Key, Value]) Get(key Key) Value
  • func (sm *SyncMap[Key, Value]) Set(key Key, value Value)

Functions

func BuildNodeTypeSchema

func BuildNodeTypeSchema(node nodes.Node) schema.NodeType

func RegisterTypes

func RegisterTypes(typesToRegister *refutil.TypeFactory)

func WriteMermaid

func WriteMermaid(a App, out io.Writer) error

Types

type App

type App struct {
	Name        string
	Version     string
	Description string
	WebScene    *room.WebScene
	Authors     []Author
	Producers   map[string]nodes.NodeOutput[artifact.Artifact]

	Out io.Writer
	// contains filtered or unexported fields
}

func (*App) ApplyGraph

func (a *App) ApplyGraph(jsonPayload []byte) error

func (*App) FindNodeByID

func (a *App) FindNodeByID(nodeId string) nodes.Node

func (App) Generate

func (a App) Generate(outputPath string) error

func (*App) GetParameter

func (a *App) GetParameter(nodeId string) Parameter

func (*App) Graph

func (a *App) Graph() []byte

func (*App) Run

func (a *App) Run(args []string) error

func (*App) Schema

func (a *App) Schema() schema.App

func (*App) SetupProducers

func (a *App) SetupProducers()

func (App) SwaggerSpec

func (a App) SwaggerSpec() swagger.Spec

func (App) WriteSwagger

func (a App) WriteSwagger(out io.Writer) error

func (App) WriteZip

func (a App) WriteZip(out io.Writer) error

type AppServer

type AppServer struct {
	// contains filtered or unexported fields
}

func (*AppServer) AutosaveGraph

func (as *AppServer) AutosaveGraph()

func (*AppServer) MermaidEndpoint

func (as *AppServer) MermaidEndpoint(w http.ResponseWriter, r *http.Request)

func (*AppServer) ProducerEndpoint

func (as *AppServer) ProducerEndpoint(w http.ResponseWriter, r *http.Request)

func (*AppServer) SceneEndpoint

func (as *AppServer) SceneEndpoint(w http.ResponseWriter, r *http.Request)

func (*AppServer) SchemaEndpoint

func (as *AppServer) SchemaEndpoint(w http.ResponseWriter, r *http.Request)

func (*AppServer) Serve

func (as *AppServer) Serve() error

func (*AppServer) StartedEndpoint

func (as *AppServer) StartedEndpoint(w http.ResponseWriter, r *http.Request)

func (*AppServer) SwaggerEndpoint

func (as *AppServer) SwaggerEndpoint(w http.ResponseWriter, r *http.Request)

func (*AppServer) UpdateParameter

func (as *AppServer) UpdateParameter(key string, msg []byte) (bool, error)

func (*AppServer) ZipEndpoint

func (as *AppServer) ZipEndpoint(w http.ResponseWriter, r *http.Request)

type Author

type Author struct {
	Name        string          `json:"name"`
	ContactInfo []AuthorContact `json:"contactInfo,omitempty"`
}

type AuthorContact

type AuthorContact struct {
	Medium string `json:"medium"`
	Value  string `json:"value"`
}

type CustomGraphSerialization

type CustomGraphSerialization interface {
	ToJSON(encoder *jbtf.Encoder) ([]byte, error)
	FromJSON(decoder jbtf.Decoder, body []byte) error
}

type Graph

type Graph struct {
	Name        string                       `json:"name,omitempty"`
	Version     string                       `json:"version,omitempty"`
	Description string                       `json:"description,omitempty"`
	Authors     []Author                     `json:"authors,omitempty"`
	WebScene    *room.WebScene               `json:"webScene,omitempty"`
	Producers   map[string]schema.Producer   `json:"producers"`
	Nodes       map[string]GraphNodeInstance `json:"nodes"`
	Metadata    map[string]any               `json:"metadata,omitempty"`
}

type GraphNodeInstance

type GraphNodeInstance struct {
	Type         string                  `json:"type"`
	Dependencies []schema.NodeDependency `json:"dependencies,omitempty"`
	Data         json.RawMessage         `json:"data,omitempty"`
}

type NestedSyncMap

type NestedSyncMap struct {
	// contains filtered or unexported fields
}

func NewNestedSyncMap

func NewNestedSyncMap() *NestedSyncMap

func (*NestedSyncMap) Delete

func (sm *NestedSyncMap) Delete(key string)

func (*NestedSyncMap) Get

func (sm *NestedSyncMap) Get(key string) any

func (*NestedSyncMap) OverwriteData

func (sm *NestedSyncMap) OverwriteData(data map[string]any)

func (*NestedSyncMap) PathExists

func (sm *NestedSyncMap) PathExists(key string) bool

func (*NestedSyncMap) Set

func (sm *NestedSyncMap) Set(key string, value any)

type Parameter

type Parameter interface {
	DisplayName() string
	Schema() schema.Parameter
	InitializeForCLI(set *flag.FlagSet)
	SetName(name string)
	SetDescription(name string)

	ApplyMessage(msg []byte) (bool, error)
	ToMessage() []byte
}

type SwaggerParameter

type SwaggerParameter interface {
	Parameter

	SwaggerProperty() swagger.Property
}

type SyncMap

type SyncMap[Key comparable, Value any] struct {
	// contains filtered or unexported fields
}

func NewSyncMap

func NewSyncMap[Key comparable, Value any]() *SyncMap[Key, Value]

func (*SyncMap[Key, Value]) Get

func (sm *SyncMap[Key, Value]) Get(key Key) Value

func (*SyncMap[Key, Value]) Set

func (sm *SyncMap[Key, Value]) Set(key Key, value Value)