Help us shape the future of Go! Take the 2026 Go Developer Survey

s4wave_flowgraph

package
v0.57.29 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2026 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Overview

Package s4wave_flowgraph stores and edits authored compositions in a World.

Index

Constants

View Source 
const (
	// FlowgraphRunTypeID is the World type of a Flowgraph run.
	FlowgraphRunTypeID = "flowgraph-run"
	// SpendOutputName is the reserved Step output reporting an activation's
	// spend as a decimal integer blob.
	SpendOutputName = "spend"
)
View Source 
const (
	// FlowgraphTypeID is the World type of an authored Flowgraph.
	FlowgraphTypeID = "flowgraph"
	// TCPPortNodeTypeID selects a Device's TCP stream output.
	TCPPortNodeTypeID = "tcp-port"
	// LocalPortNodeTypeID selects a Device's local stream listener.
	LocalPortNodeTypeID = "local-port"
	// CheckoutRootNodeTypeID selects a checkout root a Device advertises.
	CheckoutRootNodeTypeID = "checkout-root"
	// RemoteShellNodeTypeID selects the remote shell a Device serves.
	RemoteShellNodeTypeID = "remote-shell"
	// ForgeWorkerNodeTypeID selects the Forge Worker a Device hosts.
	ForgeWorkerNodeTypeID = "forge-worker"
	// StepNodeTypeID selects a node that runs once per activation.
	StepNodeTypeID = "step"
	// EventSourceNodeTypeID selects a node bound to an object that serves
	// EventSourceService. The standing run's controller turns the object's
	// events into arrivals.
	EventSourceNodeTypeID = "flowgraph/event-source"
)
View Source 
const (
	// DevicePlacementPredicate links a Flowgraph to a Device, labelled by node ID.
	DevicePlacementPredicate = "<flowgraph/device>"
	// ActorPlacementPredicate links a Flowgraph to an actor, labelled by node ID.
	ActorPlacementPredicate = "<flowgraph/actor>"
)
View Source 
const CreateFlowgraphOpTypeID = "flowgraph/create"

CreateFlowgraphOpTypeID is the type ID of CreateFlowgraphOp.

View Source 
const SRPCFlowgraphResourceServiceServiceID = "s4wave.flowgraph.FlowgraphResourceService"

Variables

View Source 
var (
	FlowgraphPortDirection_name = map[int32]string{
		0: "FLOWGRAPH_PORT_DIRECTION_UNKNOWN",
		1: "FLOWGRAPH_PORT_DIRECTION_INPUT",
		2: "FLOWGRAPH_PORT_DIRECTION_OUTPUT",
	}
	FlowgraphPortDirection_value = map[string]int32{
		"FLOWGRAPH_PORT_DIRECTION_UNKNOWN": 0,
		"FLOWGRAPH_PORT_DIRECTION_INPUT":   1,
		"FLOWGRAPH_PORT_DIRECTION_OUTPUT":  2,
	}
)

Enum value maps for FlowgraphPortDirection.

View Source 
var (
	FlowgraphPlacementKind_name = map[int32]string{
		0: "FLOWGRAPH_PLACEMENT_KIND_UNKNOWN",
		1: "FLOWGRAPH_PLACEMENT_KIND_DEVICE",
		2: "FLOWGRAPH_PLACEMENT_KIND_ACTOR",
	}
	FlowgraphPlacementKind_value = map[string]int32{
		"FLOWGRAPH_PLACEMENT_KIND_UNKNOWN": 0,
		"FLOWGRAPH_PLACEMENT_KIND_DEVICE":  1,
		"FLOWGRAPH_PLACEMENT_KIND_ACTOR":   2,
	}
)

Enum value maps for FlowgraphPlacementKind.

View Source 
var (
	FlowgraphBindingState_name = map[int32]string{
		0: "FLOWGRAPH_BINDING_STATE_UNKNOWN",
		1: "FLOWGRAPH_BINDING_STATE_UNBOUND",
		2: "FLOWGRAPH_BINDING_STATE_BOUND",
		3: "FLOWGRAPH_BINDING_STATE_UNREGISTERED",
		4: "FLOWGRAPH_BINDING_STATE_UNAVAILABLE",
	}
	FlowgraphBindingState_value = map[string]int32{
		"FLOWGRAPH_BINDING_STATE_UNKNOWN":      0,
		"FLOWGRAPH_BINDING_STATE_UNBOUND":      1,
		"FLOWGRAPH_BINDING_STATE_BOUND":        2,
		"FLOWGRAPH_BINDING_STATE_UNREGISTERED": 3,
		"FLOWGRAPH_BINDING_STATE_UNAVAILABLE":  4,
	}
)

Enum value maps for FlowgraphBindingState.

View Source 
var (
	FlowgraphRunState_name = map[int32]string{
		0: "FLOWGRAPH_RUN_STATE_UNKNOWN",
		1: "FLOWGRAPH_RUN_STATE_RUNNING",
		2: "FLOWGRAPH_RUN_STATE_PAUSED",
		3: "FLOWGRAPH_RUN_STATE_COMPLETE",
	}
	FlowgraphRunState_value = map[string]int32{
		"FLOWGRAPH_RUN_STATE_UNKNOWN":  0,
		"FLOWGRAPH_RUN_STATE_RUNNING":  1,
		"FLOWGRAPH_RUN_STATE_PAUSED":   2,
		"FLOWGRAPH_RUN_STATE_COMPLETE": 3,
	}
)

Enum value maps for FlowgraphRunState.

View Source 
var FlowgraphTypes = []typeid.Type{
	{ID: CreateFlowgraphOpTypeID, New: func() any { return new(CreateFlowgraphOp) }},
}

FlowgraphTypes lists the typed messages of flowgraph.proto.

Functions

func FlowgraphObjectKey 

func FlowgraphObjectKey(id string) (string, error)

FlowgraphObjectKey builds an independently addressed Flowgraph key.

func IsNodeCapabilityID 

func IsNodeCapabilityID(id string) bool

IsNodeCapabilityID reports whether a Device capability ID belongs to a placed node. The Device's Flowgraph reconciler owns these capabilities, even when a node type gives one another kind.

func NewFlowgraphBlock 

func NewFlowgraphBlock() block.Block

NewFlowgraphBlock constructs the stored authored body.

func NewFlowgraphRunBlock 

func NewFlowgraphRunBlock() block.Block

NewFlowgraphRunBlock constructs the stored run state.

func NewSRPCFlowgraphResourceServiceHandler 

func NewSRPCFlowgraphResourceServiceHandler(impl SRPCFlowgraphResourceServiceServer, serviceID string) srpc.Handler

NewSRPCFlowgraphResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.flowgraph.FlowgraphResourceService

func ParseFlowgraphObjectKey 

func ParseFlowgraphObjectKey(key string) (string, error)

ParseFlowgraphObjectKey returns the ID in a Flowgraph object key.

func PlacementQuad 

func PlacementQuad(graphKey, nodeID string, placement *FlowgraphPlacement) (world.GraphQuad, error)

PlacementQuad constructs the graph edge for one node's placement.

func ReadBindings 

func ReadBindings(ctx context.Context, ws world.WorldState, b bus.Bus, engineID string, graph *Flowgraph) (map[string]*FlowgraphBinding, error)

ReadBindings derives the binding of each node that names a Space object. A node with no object key has no entry. The state is read from the World and the object type registry on b; a nil bus has no registry, so every existing object reads UNREGISTERED. engineID scopes the registry lookup to the plugins demanded by the World engine, as an object type factory's context does.

func ReadPlacements 

func ReadPlacements(ctx context.Context, ws world.WorldState, graphKey string) (map[string]*FlowgraphPlacement, error)

ReadPlacements reads the placement edges of this graph, keyed by node ID.

func SRPCRegisterFlowgraphResourceService 

func SRPCRegisterFlowgraphResourceService(mux srpc.Mux, impl SRPCFlowgraphResourceServiceServer) error

SRPCRegisterFlowgraphResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.flowgraph.FlowgraphResourceService

func ValidatePlacement 

func ValidatePlacement(ctx context.Context, ws world.WorldState, node *FlowgraphNode, placement *FlowgraphPlacement) error

ValidatePlacement checks the destination without interpreting actor objects.

Types

type BindingWatch 

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

BindingWatch follows the derived binding of one Space object, as WatchFlowgraph follows the bindings of a graph: it wakes when the object appears, is retyped or is deleted, and when a plugin registers or releases its type. Only one goroutine calls its methods at a time.

func NewBindingWatch 

func NewBindingWatch(b bus.Bus, engine world.Engine, engineID, objectKey string) *BindingWatch

NewBindingWatch constructs a watch of the binding of objectKey. Call Close to stop its registry watch.

func (*BindingWatch) Close 

func (w *BindingWatch) Close()

Close stops the registry watch.

func (*BindingWatch) Next 

func (w *BindingWatch) Next(ctx context.Context) (*FlowgraphBinding, error)

Next returns the binding as it is now on the first call, and afterwards waits until the binding differs from the one the last call returned. It returns the context's error when ctx ends first, and a later call resumes the wait.

type CreateFlowgraphOp 

type CreateFlowgraphOp struct {

	// ObjectKey is the new Flowgraph's identity, of the form flowgraph/<id>.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// Name is the graph's display name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

CreateFlowgraphOp creates one independently addressed Flowgraph.

func (*CreateFlowgraphOp) ApplyWorldOp 

func (o *CreateFlowgraphOp) ApplyWorldOp(ctx context.Context, _ *logrus.Entry, ws world.WorldState, _ peer.ID) (bool, error)

ApplyWorldOp creates the authored body and its type edge in the caller's transaction.

func (*CreateFlowgraphOp) CloneMessageVT 

func (m *CreateFlowgraphOp) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*CreateFlowgraphOp) CloneVT 

func (m *CreateFlowgraphOp) CloneVT() *CreateFlowgraphOp

func (*CreateFlowgraphOp) EqualMessageVT 

func (this *CreateFlowgraphOp) EqualMessageVT(thatMsg any) bool

func (*CreateFlowgraphOp) EqualVT 

func (this *CreateFlowgraphOp) EqualVT(that *CreateFlowgraphOp) bool

func (*CreateFlowgraphOp) GetName 

func (x *CreateFlowgraphOp) GetName() string

func (*CreateFlowgraphOp) GetObjectKey 

func (x *CreateFlowgraphOp) GetObjectKey() string

func (*CreateFlowgraphOp) MarshalJSON 

func (x *CreateFlowgraphOp) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CreateFlowgraphOp to JSON.

func (*CreateFlowgraphOp) MarshalProtoJSON 

func (x *CreateFlowgraphOp) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CreateFlowgraphOp message to JSON.

func (*CreateFlowgraphOp) MarshalProtoText 

func (x *CreateFlowgraphOp) MarshalProtoText() string

func (*CreateFlowgraphOp) MarshalToSizedBufferVT 

func (m *CreateFlowgraphOp) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateFlowgraphOp) MarshalToVT 

func (m *CreateFlowgraphOp) MarshalToVT(dAtA []byte) (int, error)

func (*CreateFlowgraphOp) MarshalVT 

func (m *CreateFlowgraphOp) MarshalVT() (dAtA []byte, err error)

func (*CreateFlowgraphOp) ProtoMessage 

func (*CreateFlowgraphOp) ProtoMessage()

func (*CreateFlowgraphOp) Reset 

func (x *CreateFlowgraphOp) Reset()

func (*CreateFlowgraphOp) SizeVT 

func (m *CreateFlowgraphOp) SizeVT() (n int)

func (*CreateFlowgraphOp) String 

func (x *CreateFlowgraphOp) String() string

func (*CreateFlowgraphOp) TypeID 

func (*CreateFlowgraphOp) TypeID() string

TypeID returns the type ID of CreateFlowgraphOp.

func (*CreateFlowgraphOp) UnmarshalJSON 

func (x *CreateFlowgraphOp) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CreateFlowgraphOp from JSON.

func (*CreateFlowgraphOp) UnmarshalProtoJSON 

func (x *CreateFlowgraphOp) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CreateFlowgraphOp message from JSON.

func (*CreateFlowgraphOp) UnmarshalVT 

func (m *CreateFlowgraphOp) UnmarshalVT(dAtA []byte) error

func (*CreateFlowgraphOp) Validate 

func (o *CreateFlowgraphOp) Validate() error

Validate requires an independently addressed Flowgraph key.

type Flowgraph 

type Flowgraph struct {

	// Name is the display name of this graph.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Nodes contains nodes keyed by their graph-local ID.
	Nodes map[string]*FlowgraphNode `` /* 151-byte string literal not displayed */
	// Connections contains connections keyed by their graph-local ID.
	Connections map[string]*FlowgraphConnection `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

Flowgraph holds an authored composition of Device nodes and Steps.

func UnmarshalFlowgraph 

func UnmarshalFlowgraph(ctx context.Context, cursor *block.Cursor) (*Flowgraph, error)

UnmarshalFlowgraph reads a Flowgraph from a block cursor.

func (*Flowgraph) CloneMessageVT 

func (m *Flowgraph) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*Flowgraph) CloneVT 

func (m *Flowgraph) CloneVT() *Flowgraph

func (*Flowgraph) EqualMessageVT 

func (this *Flowgraph) EqualMessageVT(thatMsg any) bool

func (*Flowgraph) EqualVT 

func (this *Flowgraph) EqualVT(that *Flowgraph) bool

func (*Flowgraph) GetConnections 

func (x *Flowgraph) GetConnections() map[string]*FlowgraphConnection

func (*Flowgraph) GetName 

func (x *Flowgraph) GetName() string

func (*Flowgraph) GetNodes 

func (x *Flowgraph) GetNodes() map[string]*FlowgraphNode

func (*Flowgraph) MarshalJSON 

func (x *Flowgraph) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Flowgraph to JSON.

func (*Flowgraph) MarshalProtoJSON 

func (x *Flowgraph) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Flowgraph message to JSON.

func (*Flowgraph) MarshalProtoText 

func (x *Flowgraph) MarshalProtoText() string

func (*Flowgraph) MarshalToSizedBufferVT 

func (m *Flowgraph) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Flowgraph) MarshalToVT 

func (m *Flowgraph) MarshalToVT(dAtA []byte) (int, error)

func (*Flowgraph) MarshalVT 

func (m *Flowgraph) MarshalVT() (dAtA []byte, err error)

func (*Flowgraph) ProtoMessage 

func (*Flowgraph) ProtoMessage()

func (*Flowgraph) Reset 

func (x *Flowgraph) Reset()

func (*Flowgraph) SizeVT 

func (m *Flowgraph) SizeVT() (n int)

func (*Flowgraph) String 

func (x *Flowgraph) String() string

func (*Flowgraph) UnmarshalJSON 

func (x *Flowgraph) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Flowgraph from JSON.

func (*Flowgraph) UnmarshalProtoJSON 

func (x *Flowgraph) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Flowgraph message from JSON.

func (*Flowgraph) UnmarshalVT 

func (m *Flowgraph) UnmarshalVT(dAtA []byte) error

func (*Flowgraph) Validate 

func (g *Flowgraph) Validate() error

Validate checks node identities, port contracts, and connection endpoints against the ports each node authors.

func (*Flowgraph) ValidateBound 

func (g *Flowgraph) ValidateBound(bindings map[string]*FlowgraphBinding, previous *Flowgraph) error

ValidateBound checks the graph as Validate does, except that a node bound to an object also offers the ports the object's type declares while its binding is BOUND, so a connection may name either an authored or a declared port. A declared port wins over an authored port of the same name. A node with no BOUND binding offers its authored ports only, but a connection that is unchanged from previous keeps standing when it names a port that cannot be read now, since the object or its plugin may return. bindings is the snapshot's bindings by node ID; previous is the graph before the edit, or nil.

type FlowgraphActivation 

type FlowgraphActivation struct {

	// NodeId is the activated Step.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"nodeId,omitempty"`
	// TaskKey is the activation's Task in the run's Job.
	TaskKey string `protobuf:"bytes,2,opt,name=task_key,json=taskKey,proto3" json:"taskKey,omitempty"`
	// Inputs are the arrivals the activation consumed, kept so a failed
	// activation can run again with the same context.
	Inputs []*FlowgraphArrival `protobuf:"bytes,3,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Done is set once the run has routed the activation's outcome.
	Done bool `protobuf:"varint,4,opt,name=done,proto3" json:"done,omitempty"`
	// Output is the Step output port the activation chose.
	Output string `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"`
	// Key is the arrival key of a keyed Step's activation, empty for an unkeyed
	// Step. A run holds at most one running activation per Step and key.
	Key string `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	// Inbox holds the live inputs delivered to the running activation and not
	// yet acknowledged, in sequence order. When the activation ends, the run
	// returns them to its arrivals.
	Inbox []*FlowgraphLiveInput `protobuf:"bytes,7,rep,name=inbox,proto3" json:"inbox,omitempty"`
	// LastInputSeq is the sequence number of the latest live input. It only
	// grows, so a sequence number is never reused after an acknowledgement.
	LastInputSeq uint64 `protobuf:"varint,8,opt,name=last_input_seq,json=lastInputSeq,proto3" json:"lastInputSeq,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphActivation is one activation of a Step, run as one Forge Task.

func (*FlowgraphActivation) CloneMessageVT 

func (m *FlowgraphActivation) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphActivation) CloneVT 

func (m *FlowgraphActivation) CloneVT() *FlowgraphActivation

func (*FlowgraphActivation) EqualMessageVT 

func (this *FlowgraphActivation) EqualMessageVT(thatMsg any) bool

func (*FlowgraphActivation) EqualVT 

func (this *FlowgraphActivation) EqualVT(that *FlowgraphActivation) bool

func (*FlowgraphActivation) GetDone 

func (x *FlowgraphActivation) GetDone() bool

func (*FlowgraphActivation) GetInbox 

func (x *FlowgraphActivation) GetInbox() []*FlowgraphLiveInput

func (*FlowgraphActivation) GetInputs 

func (x *FlowgraphActivation) GetInputs() []*FlowgraphArrival

func (*FlowgraphActivation) GetKey 

func (x *FlowgraphActivation) GetKey() string

func (*FlowgraphActivation) GetLastInputSeq 

func (x *FlowgraphActivation) GetLastInputSeq() uint64

func (*FlowgraphActivation) GetNodeId 

func (x *FlowgraphActivation) GetNodeId() string

func (*FlowgraphActivation) GetOutput 

func (x *FlowgraphActivation) GetOutput() string

func (*FlowgraphActivation) GetTaskKey 

func (x *FlowgraphActivation) GetTaskKey() string

func (*FlowgraphActivation) MarshalJSON 

func (x *FlowgraphActivation) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphActivation to JSON.

func (*FlowgraphActivation) MarshalProtoJSON 

func (x *FlowgraphActivation) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphActivation message to JSON.

func (*FlowgraphActivation) MarshalProtoText 

func (x *FlowgraphActivation) MarshalProtoText() string

func (*FlowgraphActivation) MarshalToSizedBufferVT 

func (m *FlowgraphActivation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphActivation) MarshalToVT 

func (m *FlowgraphActivation) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphActivation) MarshalVT 

func (m *FlowgraphActivation) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphActivation) ProtoMessage 

func (*FlowgraphActivation) ProtoMessage()

func (*FlowgraphActivation) Reset 

func (x *FlowgraphActivation) Reset()

func (*FlowgraphActivation) SizeVT 

func (m *FlowgraphActivation) SizeVT() (n int)

func (*FlowgraphActivation) String 

func (x *FlowgraphActivation) String() string

func (*FlowgraphActivation) UnmarshalJSON 

func (x *FlowgraphActivation) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphActivation from JSON.

func (*FlowgraphActivation) UnmarshalProtoJSON 

func (x *FlowgraphActivation) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphActivation message from JSON.

func (*FlowgraphActivation) UnmarshalVT 

func (m *FlowgraphActivation) UnmarshalVT(dAtA []byte) error

type FlowgraphArrival 

type FlowgraphArrival struct {

	// NodeId is the receiving Step.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"nodeId,omitempty"`
	// Port is the receiving input port, or empty for a run's start.
	Port string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	// Key routes the arrival to a keyed Step activation. It is empty for an
	// ordinary arrival.
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Source is where the arrival came from. It is unset for a run's start.
	//
	// Types that are assignable to Source:
	//	*FlowgraphArrival_TaskOutput
	//	*FlowgraphArrival_Event
	Source isFlowgraphArrival_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

FlowgraphArrival is an output or event delivered to a Step's input port.

func (*FlowgraphArrival) CloneMessageVT 

func (m *FlowgraphArrival) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphArrival) CloneVT 

func (m *FlowgraphArrival) CloneVT() *FlowgraphArrival

func (*FlowgraphArrival) EqualMessageVT 

func (this *FlowgraphArrival) EqualMessageVT(thatMsg any) bool

func (*FlowgraphArrival) EqualVT 

func (this *FlowgraphArrival) EqualVT(that *FlowgraphArrival) bool

func (*FlowgraphArrival) GetEvent 

func (x *FlowgraphArrival) GetEvent() *FlowgraphEvent

func (*FlowgraphArrival) GetKey 

func (x *FlowgraphArrival) GetKey() string

func (*FlowgraphArrival) GetNodeId 

func (x *FlowgraphArrival) GetNodeId() string

func (*FlowgraphArrival) GetPort 

func (x *FlowgraphArrival) GetPort() string

func (*FlowgraphArrival) GetSource 

func (m *FlowgraphArrival) GetSource() isFlowgraphArrival_Source

func (*FlowgraphArrival) GetTaskOutput 

func (x *FlowgraphArrival) GetTaskOutput() *FlowgraphTaskOutput

func (*FlowgraphArrival) MarshalJSON 

func (x *FlowgraphArrival) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphArrival to JSON.

func (*FlowgraphArrival) MarshalProtoJSON 

func (x *FlowgraphArrival) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphArrival message to JSON.

func (*FlowgraphArrival) MarshalProtoText 

func (x *FlowgraphArrival) MarshalProtoText() string

func (*FlowgraphArrival) MarshalToSizedBufferVT 

func (m *FlowgraphArrival) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphArrival) MarshalToVT 

func (m *FlowgraphArrival) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphArrival) MarshalVT 

func (m *FlowgraphArrival) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphArrival) ProtoMessage 

func (*FlowgraphArrival) ProtoMessage()

func (*FlowgraphArrival) Reset 

func (x *FlowgraphArrival) Reset()

func (*FlowgraphArrival) SizeVT 

func (m *FlowgraphArrival) SizeVT() (n int)

func (*FlowgraphArrival) String 

func (x *FlowgraphArrival) String() string

func (*FlowgraphArrival) UnmarshalJSON 

func (x *FlowgraphArrival) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphArrival from JSON.

func (*FlowgraphArrival) UnmarshalProtoJSON 

func (x *FlowgraphArrival) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphArrival message from JSON.

func (*FlowgraphArrival) UnmarshalVT 

func (m *FlowgraphArrival) UnmarshalVT(dAtA []byte) error

type FlowgraphArrival_Event 

type FlowgraphArrival_Event struct {
	// Event is an event on a World object.
	Event *FlowgraphEvent `protobuf:"bytes,5,opt,name=event,proto3,oneof"`
}

func (*FlowgraphArrival_Event) CloneOneofVT 

func (m *FlowgraphArrival_Event) CloneOneofVT() isFlowgraphArrival_Source

func (*FlowgraphArrival_Event) CloneVT 

func (m *FlowgraphArrival_Event) CloneVT() *FlowgraphArrival_Event

func (*FlowgraphArrival_Event) EqualVT 

func (this *FlowgraphArrival_Event) EqualVT(thatIface isFlowgraphArrival_Source) bool

func (*FlowgraphArrival_Event) MarshalToSizedBufferVT 

func (m *FlowgraphArrival_Event) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphArrival_Event) MarshalToVT 

func (m *FlowgraphArrival_Event) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphArrival_Event) SizeVT 

func (m *FlowgraphArrival_Event) SizeVT() (n int)

type FlowgraphArrival_TaskOutput 

type FlowgraphArrival_TaskOutput struct {
	// TaskOutput is an output of a completed Task.
	TaskOutput *FlowgraphTaskOutput `protobuf:"bytes,4,opt,name=task_output,json=taskOutput,proto3,oneof"`
}

func (*FlowgraphArrival_TaskOutput) CloneOneofVT 

func (m *FlowgraphArrival_TaskOutput) CloneOneofVT() isFlowgraphArrival_Source

func (*FlowgraphArrival_TaskOutput) CloneVT 

func (m *FlowgraphArrival_TaskOutput) CloneVT() *FlowgraphArrival_TaskOutput

func (*FlowgraphArrival_TaskOutput) EqualVT 

func (this *FlowgraphArrival_TaskOutput) EqualVT(thatIface isFlowgraphArrival_Source) bool

func (*FlowgraphArrival_TaskOutput) MarshalToSizedBufferVT 

func (m *FlowgraphArrival_TaskOutput) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphArrival_TaskOutput) MarshalToVT 

func (m *FlowgraphArrival_TaskOutput) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphArrival_TaskOutput) SizeVT 

func (m *FlowgraphArrival_TaskOutput) SizeVT() (n int)

type FlowgraphBinding 

type FlowgraphBinding struct {

	// ObjectKey is the bound object, copied from the node.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// TypeId is the object's World type, empty when the object is absent.
	TypeId string `protobuf:"bytes,2,opt,name=type_id,json=typeId,proto3" json:"typeId,omitempty"`
	// State is the binding state derived from the World and the type registry.
	State FlowgraphBindingState `protobuf:"varint,3,opt,name=state,proto3" json:"state,omitempty"`
	// Ports lists the ports the object's registered type declares. The node's
	// connections may name these ports. It is empty unless the state is BOUND.
	Ports []*FlowgraphPort `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphBinding is a readback of a node's bound Space object. This message is never stored in the Flowgraph body.

func (*FlowgraphBinding) CloneMessageVT 

func (m *FlowgraphBinding) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphBinding) CloneVT 

func (m *FlowgraphBinding) CloneVT() *FlowgraphBinding

func (*FlowgraphBinding) EqualMessageVT 

func (this *FlowgraphBinding) EqualMessageVT(thatMsg any) bool

func (*FlowgraphBinding) EqualVT 

func (this *FlowgraphBinding) EqualVT(that *FlowgraphBinding) bool

func (*FlowgraphBinding) FindPort 

func (b *FlowgraphBinding) FindPort(name string) *FlowgraphPort

FindPort returns a port the bound object's type declares, or nil when the binding declares none by that name.

func (*FlowgraphBinding) GetObjectKey 

func (x *FlowgraphBinding) GetObjectKey() string

func (*FlowgraphBinding) GetPorts 

func (x *FlowgraphBinding) GetPorts() []*FlowgraphPort

func (*FlowgraphBinding) GetState 

func (x *FlowgraphBinding) GetState() FlowgraphBindingState

func (*FlowgraphBinding) GetTypeId 

func (x *FlowgraphBinding) GetTypeId() string

func (*FlowgraphBinding) MarshalJSON 

func (x *FlowgraphBinding) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphBinding to JSON.

func (*FlowgraphBinding) MarshalProtoJSON 

func (x *FlowgraphBinding) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphBinding message to JSON.

func (*FlowgraphBinding) MarshalProtoText 

func (x *FlowgraphBinding) MarshalProtoText() string

func (*FlowgraphBinding) MarshalToSizedBufferVT 

func (m *FlowgraphBinding) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphBinding) MarshalToVT 

func (m *FlowgraphBinding) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphBinding) MarshalVT 

func (m *FlowgraphBinding) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphBinding) ProtoMessage 

func (*FlowgraphBinding) ProtoMessage()

func (*FlowgraphBinding) Reset 

func (x *FlowgraphBinding) Reset()

func (*FlowgraphBinding) SizeVT 

func (m *FlowgraphBinding) SizeVT() (n int)

func (*FlowgraphBinding) String 

func (x *FlowgraphBinding) String() string

func (*FlowgraphBinding) UnmarshalJSON 

func (x *FlowgraphBinding) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphBinding from JSON.

func (*FlowgraphBinding) UnmarshalProtoJSON 

func (x *FlowgraphBinding) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphBinding message from JSON.

func (*FlowgraphBinding) UnmarshalVT 

func (m *FlowgraphBinding) UnmarshalVT(dAtA []byte) error

type FlowgraphBindingState 

type FlowgraphBindingState int32

FlowgraphBindingState is the derived state of a node's bound Space object. 

const (
	// FLOWGRAPH_BINDING_STATE_UNKNOWN is unset.
	FlowgraphBindingState_FLOWGRAPH_BINDING_STATE_UNKNOWN FlowgraphBindingState = 0
	// FLOWGRAPH_BINDING_STATE_UNBOUND means the node names no object.
	FlowgraphBindingState_FLOWGRAPH_BINDING_STATE_UNBOUND FlowgraphBindingState = 1
	// FLOWGRAPH_BINDING_STATE_BOUND means the object exists and its type is
	// registered, so the declared ports are known.
	FlowgraphBindingState_FLOWGRAPH_BINDING_STATE_BOUND FlowgraphBindingState = 2
	// FLOWGRAPH_BINDING_STATE_UNREGISTERED means the object exists but no loaded
	// plugin registers its type.
	FlowgraphBindingState_FLOWGRAPH_BINDING_STATE_UNREGISTERED FlowgraphBindingState = 3
	// FLOWGRAPH_BINDING_STATE_UNAVAILABLE means the object does not exist.
	FlowgraphBindingState_FLOWGRAPH_BINDING_STATE_UNAVAILABLE FlowgraphBindingState = 4
)

func (FlowgraphBindingState) Enum 

func (x FlowgraphBindingState) Enum() *FlowgraphBindingState

func (FlowgraphBindingState) MarshalJSON 

func (x FlowgraphBindingState) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphBindingState to JSON.

func (FlowgraphBindingState) MarshalProtoJSON 

func (x FlowgraphBindingState) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphBindingState to JSON.

func (FlowgraphBindingState) MarshalProtoText 

func (x FlowgraphBindingState) MarshalProtoText() string

func (FlowgraphBindingState) MarshalText 

func (x FlowgraphBindingState) MarshalText() ([]byte, error)

MarshalText marshals the FlowgraphBindingState to text.

func (FlowgraphBindingState) String 

func (x FlowgraphBindingState) String() string

func (*FlowgraphBindingState) UnmarshalJSON 

func (x *FlowgraphBindingState) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphBindingState from JSON.

func (*FlowgraphBindingState) UnmarshalProtoJSON 

func (x *FlowgraphBindingState) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphBindingState from JSON.

func (*FlowgraphBindingState) UnmarshalText 

func (x *FlowgraphBindingState) UnmarshalText(b []byte) error

UnmarshalText unmarshals the FlowgraphBindingState from text.

type FlowgraphBound 

type FlowgraphBound struct {

	// MaxVisits is the number of activations the Step may have.
	MaxVisits uint32 `protobuf:"varint,1,opt,name=max_visits,json=maxVisits,proto3" json:"maxVisits,omitempty"`
	// MaxSpend is the total spend the Step's activations may report.
	MaxSpend uint64 `protobuf:"varint,2,opt,name=max_spend,json=maxSpend,proto3" json:"maxSpend,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphBound limits the visits and the reported spend of a Step in a run. A run that would exceed a limit pauses at the Step. Zero is unlimited.

func (*FlowgraphBound) CloneMessageVT 

func (m *FlowgraphBound) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphBound) CloneVT 

func (m *FlowgraphBound) CloneVT() *FlowgraphBound

func (*FlowgraphBound) EqualMessageVT 

func (this *FlowgraphBound) EqualMessageVT(thatMsg any) bool

func (*FlowgraphBound) EqualVT 

func (this *FlowgraphBound) EqualVT(that *FlowgraphBound) bool

func (*FlowgraphBound) GetMaxSpend 

func (x *FlowgraphBound) GetMaxSpend() uint64

func (*FlowgraphBound) GetMaxVisits 

func (x *FlowgraphBound) GetMaxVisits() uint32

func (*FlowgraphBound) MarshalJSON 

func (x *FlowgraphBound) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphBound to JSON.

func (*FlowgraphBound) MarshalProtoJSON 

func (x *FlowgraphBound) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphBound message to JSON.

func (*FlowgraphBound) MarshalProtoText 

func (x *FlowgraphBound) MarshalProtoText() string

func (*FlowgraphBound) MarshalToSizedBufferVT 

func (m *FlowgraphBound) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphBound) MarshalToVT 

func (m *FlowgraphBound) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphBound) MarshalVT 

func (m *FlowgraphBound) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphBound) ProtoMessage 

func (*FlowgraphBound) ProtoMessage()

func (*FlowgraphBound) Reset 

func (x *FlowgraphBound) Reset()

func (*FlowgraphBound) SizeVT 

func (m *FlowgraphBound) SizeVT() (n int)

func (*FlowgraphBound) String 

func (x *FlowgraphBound) String() string

func (*FlowgraphBound) UnmarshalJSON 

func (x *FlowgraphBound) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphBound from JSON.

func (*FlowgraphBound) UnmarshalProtoJSON 

func (x *FlowgraphBound) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphBound message from JSON.

func (*FlowgraphBound) UnmarshalVT 

func (m *FlowgraphBound) UnmarshalVT(dAtA []byte) error

type FlowgraphChange 

type FlowgraphChange struct {

	// Seqno is the World changelog seqno that recorded the revision.
	Seqno uint64 `protobuf:"varint,1,opt,name=seqno,proto3" json:"seqno,omitempty"`
	// Created is set when the revision created the graph.
	Created bool `protobuf:"varint,2,opt,name=created,proto3" json:"created,omitempty"`
	// Edit is the change from the preceding revision, as an update request.
	Edit *UpdateFlowgraphRequest `protobuf:"bytes,3,opt,name=edit,proto3" json:"edit,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphChange is one revision of a graph, read from the World changelog.

func (*FlowgraphChange) CloneMessageVT 

func (m *FlowgraphChange) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphChange) CloneVT 

func (m *FlowgraphChange) CloneVT() *FlowgraphChange

func (*FlowgraphChange) EqualMessageVT 

func (this *FlowgraphChange) EqualMessageVT(thatMsg any) bool

func (*FlowgraphChange) EqualVT 

func (this *FlowgraphChange) EqualVT(that *FlowgraphChange) bool

func (*FlowgraphChange) GetCreated 

func (x *FlowgraphChange) GetCreated() bool

func (*FlowgraphChange) GetEdit 

func (x *FlowgraphChange) GetEdit() *UpdateFlowgraphRequest

func (*FlowgraphChange) GetSeqno 

func (x *FlowgraphChange) GetSeqno() uint64

func (*FlowgraphChange) MarshalJSON 

func (x *FlowgraphChange) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphChange to JSON.

func (*FlowgraphChange) MarshalProtoJSON 

func (x *FlowgraphChange) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphChange message to JSON.

func (*FlowgraphChange) MarshalProtoText 

func (x *FlowgraphChange) MarshalProtoText() string

func (*FlowgraphChange) MarshalToSizedBufferVT 

func (m *FlowgraphChange) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphChange) MarshalToVT 

func (m *FlowgraphChange) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphChange) MarshalVT 

func (m *FlowgraphChange) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphChange) ProtoMessage 

func (*FlowgraphChange) ProtoMessage()

func (*FlowgraphChange) Reset 

func (x *FlowgraphChange) Reset()

func (*FlowgraphChange) SizeVT 

func (m *FlowgraphChange) SizeVT() (n int)

func (*FlowgraphChange) String 

func (x *FlowgraphChange) String() string

func (*FlowgraphChange) UnmarshalJSON 

func (x *FlowgraphChange) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphChange from JSON.

func (*FlowgraphChange) UnmarshalProtoJSON 

func (x *FlowgraphChange) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphChange message from JSON.

func (*FlowgraphChange) UnmarshalVT 

func (m *FlowgraphChange) UnmarshalVT(dAtA []byte) error

type FlowgraphConnection 

type FlowgraphConnection struct {

	// OutputNode is the graph-local ID of the supplying node.
	OutputNode string `protobuf:"bytes,1,opt,name=output_node,json=outputNode,proto3" json:"outputNode,omitempty"`
	// OutputPort is the supplying node's output port name.
	OutputPort string `protobuf:"bytes,2,opt,name=output_port,json=outputPort,proto3" json:"outputPort,omitempty"`
	// InputNode is the graph-local ID of the receiving node.
	InputNode string `protobuf:"bytes,3,opt,name=input_node,json=inputNode,proto3" json:"inputNode,omitempty"`
	// InputPort is the receiving node's input port name.
	InputPort string `protobuf:"bytes,4,opt,name=input_port,json=inputPort,proto3" json:"inputPort,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphConnection connects an output to an input within the graph.

func (*FlowgraphConnection) CloneMessageVT 

func (m *FlowgraphConnection) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphConnection) CloneVT 

func (m *FlowgraphConnection) CloneVT() *FlowgraphConnection

func (*FlowgraphConnection) EqualMessageVT 

func (this *FlowgraphConnection) EqualMessageVT(thatMsg any) bool

func (*FlowgraphConnection) EqualVT 

func (this *FlowgraphConnection) EqualVT(that *FlowgraphConnection) bool

func (*FlowgraphConnection) GetInputNode 

func (x *FlowgraphConnection) GetInputNode() string

func (*FlowgraphConnection) GetInputPort 

func (x *FlowgraphConnection) GetInputPort() string

func (*FlowgraphConnection) GetOutputNode 

func (x *FlowgraphConnection) GetOutputNode() string

func (*FlowgraphConnection) GetOutputPort 

func (x *FlowgraphConnection) GetOutputPort() string

func (*FlowgraphConnection) MarshalJSON 

func (x *FlowgraphConnection) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphConnection to JSON.

func (*FlowgraphConnection) MarshalProtoJSON 

func (x *FlowgraphConnection) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphConnection message to JSON.

func (*FlowgraphConnection) MarshalProtoText 

func (x *FlowgraphConnection) MarshalProtoText() string

func (*FlowgraphConnection) MarshalToSizedBufferVT 

func (m *FlowgraphConnection) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphConnection) MarshalToVT 

func (m *FlowgraphConnection) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphConnection) MarshalVT 

func (m *FlowgraphConnection) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphConnection) ProtoMessage 

func (*FlowgraphConnection) ProtoMessage()

func (*FlowgraphConnection) Reset 

func (x *FlowgraphConnection) Reset()

func (*FlowgraphConnection) SizeVT 

func (m *FlowgraphConnection) SizeVT() (n int)

func (*FlowgraphConnection) String 

func (x *FlowgraphConnection) String() string

func (*FlowgraphConnection) UnmarshalJSON 

func (x *FlowgraphConnection) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphConnection from JSON.

func (*FlowgraphConnection) UnmarshalProtoJSON 

func (x *FlowgraphConnection) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphConnection message from JSON.

func (*FlowgraphConnection) UnmarshalVT 

func (m *FlowgraphConnection) UnmarshalVT(dAtA []byte) error

type FlowgraphEvent 

type FlowgraphEvent struct {

	// ObjectKey is the World object the event happened on. The receiving Step's
	// Task reads it as a WORLD_OBJECT input.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// EventId identifies the event within its event source.
	EventId string `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"eventId,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphEvent names one event on a World object.

func (*FlowgraphEvent) CloneMessageVT 

func (m *FlowgraphEvent) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphEvent) CloneVT 

func (m *FlowgraphEvent) CloneVT() *FlowgraphEvent

func (*FlowgraphEvent) EqualMessageVT 

func (this *FlowgraphEvent) EqualMessageVT(thatMsg any) bool

func (*FlowgraphEvent) EqualVT 

func (this *FlowgraphEvent) EqualVT(that *FlowgraphEvent) bool

func (*FlowgraphEvent) GetEventId 

func (x *FlowgraphEvent) GetEventId() string

func (*FlowgraphEvent) GetObjectKey 

func (x *FlowgraphEvent) GetObjectKey() string

func (*FlowgraphEvent) MarshalJSON 

func (x *FlowgraphEvent) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphEvent to JSON.

func (*FlowgraphEvent) MarshalProtoJSON 

func (x *FlowgraphEvent) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphEvent message to JSON.

func (*FlowgraphEvent) MarshalProtoText 

func (x *FlowgraphEvent) MarshalProtoText() string

func (*FlowgraphEvent) MarshalToSizedBufferVT 

func (m *FlowgraphEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphEvent) MarshalToVT 

func (m *FlowgraphEvent) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphEvent) MarshalVT 

func (m *FlowgraphEvent) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphEvent) ProtoMessage 

func (*FlowgraphEvent) ProtoMessage()

func (*FlowgraphEvent) Reset 

func (x *FlowgraphEvent) Reset()

func (*FlowgraphEvent) SizeVT 

func (m *FlowgraphEvent) SizeVT() (n int)

func (*FlowgraphEvent) String 

func (x *FlowgraphEvent) String() string

func (*FlowgraphEvent) UnmarshalJSON 

func (x *FlowgraphEvent) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphEvent from JSON.

func (*FlowgraphEvent) UnmarshalProtoJSON 

func (x *FlowgraphEvent) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphEvent message from JSON.

func (*FlowgraphEvent) UnmarshalVT 

func (m *FlowgraphEvent) UnmarshalVT(dAtA []byte) error

type FlowgraphLiveInput 

type FlowgraphLiveInput struct {

	// Seq orders the activation's live inputs, from one.
	Seq uint64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	// Arrival is the arrival that reached the activation, with its key.
	Arrival *FlowgraphArrival `protobuf:"bytes,2,opt,name=arrival,proto3" json:"arrival,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphLiveInput is an arrival delivered to a running keyed activation.

func (*FlowgraphLiveInput) CloneMessageVT 

func (m *FlowgraphLiveInput) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphLiveInput) CloneVT 

func (m *FlowgraphLiveInput) CloneVT() *FlowgraphLiveInput

func (*FlowgraphLiveInput) EqualMessageVT 

func (this *FlowgraphLiveInput) EqualMessageVT(thatMsg any) bool

func (*FlowgraphLiveInput) EqualVT 

func (this *FlowgraphLiveInput) EqualVT(that *FlowgraphLiveInput) bool

func (*FlowgraphLiveInput) GetArrival 

func (x *FlowgraphLiveInput) GetArrival() *FlowgraphArrival

func (*FlowgraphLiveInput) GetSeq 

func (x *FlowgraphLiveInput) GetSeq() uint64

func (*FlowgraphLiveInput) MarshalJSON 

func (x *FlowgraphLiveInput) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphLiveInput to JSON.

func (*FlowgraphLiveInput) MarshalProtoJSON 

func (x *FlowgraphLiveInput) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphLiveInput message to JSON.

func (*FlowgraphLiveInput) MarshalProtoText 

func (x *FlowgraphLiveInput) MarshalProtoText() string

func (*FlowgraphLiveInput) MarshalToSizedBufferVT 

func (m *FlowgraphLiveInput) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphLiveInput) MarshalToVT 

func (m *FlowgraphLiveInput) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphLiveInput) MarshalVT 

func (m *FlowgraphLiveInput) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphLiveInput) ProtoMessage 

func (*FlowgraphLiveInput) ProtoMessage()

func (*FlowgraphLiveInput) Reset 

func (x *FlowgraphLiveInput) Reset()

func (*FlowgraphLiveInput) SizeVT 

func (m *FlowgraphLiveInput) SizeVT() (n int)

func (*FlowgraphLiveInput) String 

func (x *FlowgraphLiveInput) String() string

func (*FlowgraphLiveInput) UnmarshalJSON 

func (x *FlowgraphLiveInput) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphLiveInput from JSON.

func (*FlowgraphLiveInput) UnmarshalProtoJSON 

func (x *FlowgraphLiveInput) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphLiveInput message from JSON.

func (*FlowgraphLiveInput) UnmarshalVT 

func (m *FlowgraphLiveInput) UnmarshalVT(dAtA []byte) error

type FlowgraphNode 

type FlowgraphNode struct {

	// TypeId selects the node type supplied by a core or plugin controller.
	TypeId string `protobuf:"bytes,1,opt,name=type_id,json=typeId,proto3" json:"typeId,omitempty"`
	// Parameters contains named settings interpreted by the node type.
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// Ports declares the node's inputs and outputs.
	Ports []*FlowgraphPort `protobuf:"bytes,3,rep,name=ports,proto3" json:"ports,omitempty"`
	// Step holds instructions for a node that runs once per activation.
	Step *FlowgraphStep `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"`
	// ObjectKey binds the node to a Space object, such as a chat room or a
	// repository. It is empty for an unbound node. The binding state is derived
	// from the World when the graph is read and is never stored.
	ObjectKey string `protobuf:"bytes,5,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphNode holds the authored settings and ports of one node.

func (*FlowgraphNode) CloneMessageVT 

func (m *FlowgraphNode) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphNode) CloneVT 

func (m *FlowgraphNode) CloneVT() *FlowgraphNode

func (*FlowgraphNode) EqualMessageVT 

func (this *FlowgraphNode) EqualMessageVT(thatMsg any) bool

func (*FlowgraphNode) EqualVT 

func (this *FlowgraphNode) EqualVT(that *FlowgraphNode) bool

func (*FlowgraphNode) FindPort 

func (n *FlowgraphNode) FindPort(name string) *FlowgraphPort

FindPort returns a port by name, or nil when it is absent.

func (*FlowgraphNode) GetObjectKey 

func (x *FlowgraphNode) GetObjectKey() string

func (*FlowgraphNode) GetParameters 

func (x *FlowgraphNode) GetParameters() map[string]string

func (*FlowgraphNode) GetPorts 

func (x *FlowgraphNode) GetPorts() []*FlowgraphPort

func (*FlowgraphNode) GetStep 

func (x *FlowgraphNode) GetStep() *FlowgraphStep

func (*FlowgraphNode) GetTypeId 

func (x *FlowgraphNode) GetTypeId() string

func (*FlowgraphNode) MarshalJSON 

func (x *FlowgraphNode) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphNode to JSON.

func (*FlowgraphNode) MarshalProtoJSON 

func (x *FlowgraphNode) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphNode message to JSON.

func (*FlowgraphNode) MarshalProtoText 

func (x *FlowgraphNode) MarshalProtoText() string

func (*FlowgraphNode) MarshalToSizedBufferVT 

func (m *FlowgraphNode) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphNode) MarshalToVT 

func (m *FlowgraphNode) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphNode) MarshalVT 

func (m *FlowgraphNode) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphNode) ProtoMessage 

func (*FlowgraphNode) ProtoMessage()

func (*FlowgraphNode) Reset 

func (x *FlowgraphNode) Reset()

func (*FlowgraphNode) SizeVT 

func (m *FlowgraphNode) SizeVT() (n int)

func (*FlowgraphNode) String 

func (x *FlowgraphNode) String() string

func (*FlowgraphNode) UnmarshalJSON 

func (x *FlowgraphNode) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphNode from JSON.

func (*FlowgraphNode) UnmarshalProtoJSON 

func (x *FlowgraphNode) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphNode message from JSON.

func (*FlowgraphNode) UnmarshalVT 

func (m *FlowgraphNode) UnmarshalVT(dAtA []byte) error

func (*FlowgraphNode) Validate 

func (n *FlowgraphNode) Validate() error

Validate checks the node type and unique, directed ports.

type FlowgraphNodeCapability 

type FlowgraphNodeCapability interface {
	// GetCapability returns the capability the node shows: its kind, label,
	// link, policy and checkout root. The Device sets the ID and the state. It
	// returns an error to reject the node, such as when the object the link
	// names is not in ws.
	GetCapability(ctx context.Context, ws world.WorldState, node *PlacedFlowgraphNode) (*s4wave_device.DeviceCapability, error)
}

FlowgraphNodeCapability is implemented by a node type whose placed node shows a Device capability of its own, in place of the default flowgraph-node capability. A Device keeps the first node, in Flowgraph key and node ID order, that shows each kind and checkout root name, and rejects the rest.

type FlowgraphNodeType 

type FlowgraphNodeType interface {
	// GetDisplayName returns the name shown for the node type.
	GetDisplayName() string
	// GetPorts returns the ports a new node of this type declares.
	GetPorts() []*FlowgraphPort
	// GetConfigIDs returns every config ID that Compile may emit. A Device
	// rejects an entry whose config ID the type did not declare.
	GetConfigIDs() []string
	// Compile returns the controller configs that run the placed node, keyed by
	// entry name. The name is unique among the node's entries.
	Compile(ctx context.Context, node *PlacedFlowgraphNode) (map[string]config.Config, error)
}

FlowgraphNodeType is the behavior behind a node's type_id. A controller supplies it by resolving LookupFlowgraphNodeType.

func ExLookupFlowgraphNodeType 

func ExLookupFlowgraphNodeType(
	ctx context.Context,
	b bus.Bus,
	typeID string,
) (FlowgraphNodeType, directive.Reference, error)

ExLookupFlowgraphNodeType looks up a node type on the bus. It waits until a controller supplies the type, so a type from a controller that loads later resolves then. Release the reference when done with the node type.

type FlowgraphNode_ParametersEntry 

type FlowgraphNode_ParametersEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowgraphNode_ParametersEntry) GetKey 

func (x *FlowgraphNode_ParametersEntry) GetKey() string

func (*FlowgraphNode_ParametersEntry) GetValue 

func (x *FlowgraphNode_ParametersEntry) GetValue() string

func (*FlowgraphNode_ParametersEntry) MarshalJSON 

func (x *FlowgraphNode_ParametersEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphNode_ParametersEntry to JSON.

func (*FlowgraphNode_ParametersEntry) MarshalProtoJSON 

func (x *FlowgraphNode_ParametersEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphNode_ParametersEntry message to JSON.

func (*FlowgraphNode_ParametersEntry) MarshalProtoText 

func (x *FlowgraphNode_ParametersEntry) MarshalProtoText() string

func (*FlowgraphNode_ParametersEntry) ProtoMessage 

func (*FlowgraphNode_ParametersEntry) ProtoMessage()

func (*FlowgraphNode_ParametersEntry) Reset 

func (x *FlowgraphNode_ParametersEntry) Reset()

func (*FlowgraphNode_ParametersEntry) String 

func (x *FlowgraphNode_ParametersEntry) String() string

func (*FlowgraphNode_ParametersEntry) UnmarshalJSON 

func (x *FlowgraphNode_ParametersEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphNode_ParametersEntry from JSON.

func (*FlowgraphNode_ParametersEntry) UnmarshalProtoJSON 

func (x *FlowgraphNode_ParametersEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphNode_ParametersEntry message from JSON.

type FlowgraphPlacement 

type FlowgraphPlacement struct {

	// Kind selects the Device or actor placement predicate.
	Kind FlowgraphPlacementKind `protobuf:"varint,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// ObjectKey is the edge's destination, supplied to or read from the graph.
	// This message is never stored in the Flowgraph body.
	ObjectKey string `protobuf:"bytes,2,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphPlacement is a command or readback of a placement graph edge.

func (*FlowgraphPlacement) CloneMessageVT 

func (m *FlowgraphPlacement) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphPlacement) CloneVT 

func (m *FlowgraphPlacement) CloneVT() *FlowgraphPlacement

func (*FlowgraphPlacement) EqualMessageVT 

func (this *FlowgraphPlacement) EqualMessageVT(thatMsg any) bool

func (*FlowgraphPlacement) EqualVT 

func (this *FlowgraphPlacement) EqualVT(that *FlowgraphPlacement) bool

func (*FlowgraphPlacement) GetKind 

func (x *FlowgraphPlacement) GetKind() FlowgraphPlacementKind

func (*FlowgraphPlacement) GetObjectKey 

func (x *FlowgraphPlacement) GetObjectKey() string

func (*FlowgraphPlacement) MarshalJSON 

func (x *FlowgraphPlacement) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphPlacement to JSON.

func (*FlowgraphPlacement) MarshalProtoJSON 

func (x *FlowgraphPlacement) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphPlacement message to JSON.

func (*FlowgraphPlacement) MarshalProtoText 

func (x *FlowgraphPlacement) MarshalProtoText() string

func (*FlowgraphPlacement) MarshalToSizedBufferVT 

func (m *FlowgraphPlacement) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphPlacement) MarshalToVT 

func (m *FlowgraphPlacement) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphPlacement) MarshalVT 

func (m *FlowgraphPlacement) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphPlacement) ProtoMessage 

func (*FlowgraphPlacement) ProtoMessage()

func (*FlowgraphPlacement) Reset 

func (x *FlowgraphPlacement) Reset()

func (*FlowgraphPlacement) SizeVT 

func (m *FlowgraphPlacement) SizeVT() (n int)

func (*FlowgraphPlacement) String 

func (x *FlowgraphPlacement) String() string

func (*FlowgraphPlacement) UnmarshalJSON 

func (x *FlowgraphPlacement) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphPlacement from JSON.

func (*FlowgraphPlacement) UnmarshalProtoJSON 

func (x *FlowgraphPlacement) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphPlacement message from JSON.

func (*FlowgraphPlacement) UnmarshalVT 

func (m *FlowgraphPlacement) UnmarshalVT(dAtA []byte) error

type FlowgraphPlacementKind 

type FlowgraphPlacementKind int32

FlowgraphPlacementKind selects the component that runs a node. 

const (
	// FLOWGRAPH_PLACEMENT_KIND_UNKNOWN is unset.
	FlowgraphPlacementKind_FLOWGRAPH_PLACEMENT_KIND_UNKNOWN FlowgraphPlacementKind = 0
	// FLOWGRAPH_PLACEMENT_KIND_DEVICE places a standing node on a Device.
	FlowgraphPlacementKind_FLOWGRAPH_PLACEMENT_KIND_DEVICE FlowgraphPlacementKind = 1
	// FLOWGRAPH_PLACEMENT_KIND_ACTOR places a Step on an actor.
	FlowgraphPlacementKind_FLOWGRAPH_PLACEMENT_KIND_ACTOR FlowgraphPlacementKind = 2
)

func (FlowgraphPlacementKind) Enum 

func (x FlowgraphPlacementKind) Enum() *FlowgraphPlacementKind

func (FlowgraphPlacementKind) MarshalJSON 

func (x FlowgraphPlacementKind) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphPlacementKind to JSON.

func (FlowgraphPlacementKind) MarshalProtoJSON 

func (x FlowgraphPlacementKind) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphPlacementKind to JSON.

func (FlowgraphPlacementKind) MarshalProtoText 

func (x FlowgraphPlacementKind) MarshalProtoText() string

func (FlowgraphPlacementKind) MarshalText 

func (x FlowgraphPlacementKind) MarshalText() ([]byte, error)

MarshalText marshals the FlowgraphPlacementKind to text.

func (FlowgraphPlacementKind) String 

func (x FlowgraphPlacementKind) String() string

func (*FlowgraphPlacementKind) UnmarshalJSON 

func (x *FlowgraphPlacementKind) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphPlacementKind from JSON.

func (*FlowgraphPlacementKind) UnmarshalProtoJSON 

func (x *FlowgraphPlacementKind) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphPlacementKind from JSON.

func (*FlowgraphPlacementKind) UnmarshalText 

func (x *FlowgraphPlacementKind) UnmarshalText(b []byte) error

UnmarshalText unmarshals the FlowgraphPlacementKind from text.

type FlowgraphPort 

type FlowgraphPort struct {

	// Name is unique among this node's ports.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Direction selects input or output.
	Direction FlowgraphPortDirection `protobuf:"varint,2,opt,name=direction,proto3" json:"direction,omitempty"`
	// TypeId is the data contract of the port, such as stream or activation.
	TypeId string `protobuf:"bytes,3,opt,name=type_id,json=typeId,proto3" json:"typeId,omitempty"`
	// Condition states when an activation takes this Step output.
	Condition string `protobuf:"bytes,4,opt,name=condition,proto3" json:"condition,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphPort declares a node-local connection endpoint.

func (*FlowgraphPort) CloneMessageVT 

func (m *FlowgraphPort) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphPort) CloneVT 

func (m *FlowgraphPort) CloneVT() *FlowgraphPort

func (*FlowgraphPort) EqualMessageVT 

func (this *FlowgraphPort) EqualMessageVT(thatMsg any) bool

func (*FlowgraphPort) EqualVT 

func (this *FlowgraphPort) EqualVT(that *FlowgraphPort) bool

func (*FlowgraphPort) GetCondition 

func (x *FlowgraphPort) GetCondition() string

func (*FlowgraphPort) GetDirection 

func (x *FlowgraphPort) GetDirection() FlowgraphPortDirection

func (*FlowgraphPort) GetName 

func (x *FlowgraphPort) GetName() string

func (*FlowgraphPort) GetTypeId 

func (x *FlowgraphPort) GetTypeId() string

func (*FlowgraphPort) MarshalJSON 

func (x *FlowgraphPort) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphPort to JSON.

func (*FlowgraphPort) MarshalProtoJSON 

func (x *FlowgraphPort) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphPort message to JSON.

func (*FlowgraphPort) MarshalProtoText 

func (x *FlowgraphPort) MarshalProtoText() string

func (*FlowgraphPort) MarshalToSizedBufferVT 

func (m *FlowgraphPort) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphPort) MarshalToVT 

func (m *FlowgraphPort) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphPort) MarshalVT 

func (m *FlowgraphPort) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphPort) ProtoMessage 

func (*FlowgraphPort) ProtoMessage()

func (*FlowgraphPort) Reset 

func (x *FlowgraphPort) Reset()

func (*FlowgraphPort) SizeVT 

func (m *FlowgraphPort) SizeVT() (n int)

func (*FlowgraphPort) String 

func (x *FlowgraphPort) String() string

func (*FlowgraphPort) UnmarshalJSON 

func (x *FlowgraphPort) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphPort from JSON.

func (*FlowgraphPort) UnmarshalProtoJSON 

func (x *FlowgraphPort) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphPort message from JSON.

func (*FlowgraphPort) UnmarshalVT 

func (m *FlowgraphPort) UnmarshalVT(dAtA []byte) error

type FlowgraphPortDirection 

type FlowgraphPortDirection int32

FlowgraphPortDirection selects the end of a directed connection. 

const (
	// FLOWGRAPH_PORT_DIRECTION_UNKNOWN is unset.
	FlowgraphPortDirection_FLOWGRAPH_PORT_DIRECTION_UNKNOWN FlowgraphPortDirection = 0
	// FLOWGRAPH_PORT_DIRECTION_INPUT accepts data or an activation.
	FlowgraphPortDirection_FLOWGRAPH_PORT_DIRECTION_INPUT FlowgraphPortDirection = 1
	// FLOWGRAPH_PORT_DIRECTION_OUTPUT supplies data or routes an activation.
	FlowgraphPortDirection_FLOWGRAPH_PORT_DIRECTION_OUTPUT FlowgraphPortDirection = 2
)

func (FlowgraphPortDirection) Enum 

func (x FlowgraphPortDirection) Enum() *FlowgraphPortDirection

func (FlowgraphPortDirection) MarshalJSON 

func (x FlowgraphPortDirection) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphPortDirection to JSON.

func (FlowgraphPortDirection) MarshalProtoJSON 

func (x FlowgraphPortDirection) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphPortDirection to JSON.

func (FlowgraphPortDirection) MarshalProtoText 

func (x FlowgraphPortDirection) MarshalProtoText() string

func (FlowgraphPortDirection) MarshalText 

func (x FlowgraphPortDirection) MarshalText() ([]byte, error)

MarshalText marshals the FlowgraphPortDirection to text.

func (FlowgraphPortDirection) String 

func (x FlowgraphPortDirection) String() string

func (*FlowgraphPortDirection) UnmarshalJSON 

func (x *FlowgraphPortDirection) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphPortDirection from JSON.

func (*FlowgraphPortDirection) UnmarshalProtoJSON 

func (x *FlowgraphPortDirection) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphPortDirection from JSON.

func (*FlowgraphPortDirection) UnmarshalText 

func (x *FlowgraphPortDirection) UnmarshalText(b []byte) error

UnmarshalText unmarshals the FlowgraphPortDirection from text.

type FlowgraphResource 

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

FlowgraphResource exposes an authored graph through its granted World capability.

func NewFlowgraphResource 

func NewFlowgraphResource(ws world.WorldState, engine world.Engine, b bus.Bus, engineID, key string) *FlowgraphResource

NewFlowgraphResource constructs a graph Resource without retaining object handles. b and engineID resolve the object types of the nodes' bound objects.

func (*FlowgraphResource) GetFlowgraph 

func (r *FlowgraphResource) GetFlowgraph(ctx context.Context, _ *GetFlowgraphRequest) (*GetFlowgraphResponse, error)

GetFlowgraph reads the granted snapshot or a fresh committed graph.

func (*FlowgraphResource) GetMux 

func (r *FlowgraphResource) GetMux() srpc.Mux

GetMux returns the graph's Resource invoker.

func (*FlowgraphResource) ListFlowgraphChanges 

func (r *FlowgraphResource) ListFlowgraphChanges(ctx context.Context, request *ListFlowgraphChangesRequest) (*ListFlowgraphChangesResponse, error)

ListFlowgraphChanges reads the graph's revisions from the World changelog.

func (*FlowgraphResource) UpdateFlowgraph 

func (r *FlowgraphResource) UpdateFlowgraph(ctx context.Context, request *UpdateFlowgraphRequest) (*UpdateFlowgraphResponse, error)

UpdateFlowgraph commits one authored change and returns that change's snapshot.

func (*FlowgraphResource) WatchFlowgraph 

func (r *FlowgraphResource) WatchFlowgraph(_ *WatchFlowgraphRequest, stream SRPCFlowgraphResourceService_WatchFlowgraphStream) error

WatchFlowgraph streams committed graph changes until the stream is canceled. It also sends a snapshot when a bound object appears, changes type or is deleted, or when a plugin registers or releases the type of a bound object, since each of those changes the node's derived binding.

type FlowgraphRun 

type FlowgraphRun struct {

	// FlowgraphKey is the Flowgraph this run executes.
	FlowgraphKey string `protobuf:"bytes,1,opt,name=flowgraph_key,json=flowgraphKey,proto3" json:"flowgraphKey,omitempty"`
	// FlowgraphRevision is the Flowgraph revision the run executes.
	FlowgraphRevision uint64 `protobuf:"varint,2,opt,name=flowgraph_revision,json=flowgraphRevision,proto3" json:"flowgraphRevision,omitempty"`
	// GraphRef is the Flowgraph body at flowgraph_revision.
	GraphRef *block.BlockRef `protobuf:"bytes,3,opt,name=graph_ref,json=graphRef,proto3" json:"graphRef,omitempty"`
	// JobKey is the Forge Job holding one Task per activation.
	JobKey string `protobuf:"bytes,4,opt,name=job_key,json=jobKey,proto3" json:"jobKey,omitempty"`
	// State is the run's lifecycle state.
	State FlowgraphRunState `protobuf:"varint,5,opt,name=state,proto3" json:"state,omitempty"`
	// Activations lists every Step activation in start order.
	Activations []*FlowgraphActivation `protobuf:"bytes,6,rep,name=activations,proto3" json:"activations,omitempty"`
	// Arrivals holds outputs delivered to Step inputs and not yet consumed.
	Arrivals []*FlowgraphArrival `protobuf:"bytes,7,rep,name=arrivals,proto3" json:"arrivals,omitempty"`
	// Visits counts activations and reported spend by Step node ID.
	Visits map[string]*FlowgraphVisits `` /* 153-byte string literal not displayed */
	// PausedNode is the Step the run paused at.
	PausedNode string `protobuf:"bytes,9,opt,name=paused_node,json=pausedNode,proto3" json:"pausedNode,omitempty"`
	// PauseReason says why the run paused.
	PauseReason string `protobuf:"bytes,10,opt,name=pause_reason,json=pauseReason,proto3" json:"pauseReason,omitempty"`
	// Standing marks the run a graph's event sources feed. A graph has at most
	// one standing run.
	Standing bool `protobuf:"varint,11,opt,name=standing,proto3" json:"standing,omitempty"`
	// Cursor holds the opaque position after the last event delivered from each
	// event-source node, by node ID. A delivery applies only when it names the
	// stored cursor, so two readers of the same events deliver each once.
	Cursor map[string][]byte `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

FlowgraphRun is the state of one run of a Flowgraph's Steps on a Forge Job. The run, not the Job, says whether the run is done: the Job reads COMPLETE whenever no activation is running.

func ReadFlowgraphRun 

func ReadFlowgraphRun(ctx context.Context, ws world.WorldState, key string) (*FlowgraphRun, uint64, error)

ReadFlowgraphRun reads a run's body and the object revision it was read at.

func UnmarshalFlowgraphRun 

func UnmarshalFlowgraphRun(ctx context.Context, cursor *block.Cursor) (*FlowgraphRun, error)

UnmarshalFlowgraphRun reads a run from a block cursor.

func (*FlowgraphRun) ApplyBlockRef 

func (r *FlowgraphRun) ApplyBlockRef(id uint32, ptr *block.BlockRef) error

ApplyBlockRef applies the pinned graph reference.

func (*FlowgraphRun) CloneMessageVT 

func (m *FlowgraphRun) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphRun) CloneVT 

func (m *FlowgraphRun) CloneVT() *FlowgraphRun

func (*FlowgraphRun) EqualMessageVT 

func (this *FlowgraphRun) EqualMessageVT(thatMsg any) bool

func (*FlowgraphRun) EqualVT 

func (this *FlowgraphRun) EqualVT(that *FlowgraphRun) bool

func (*FlowgraphRun) FollowGraph 

func (r *FlowgraphRun) FollowGraph(ctx context.Context, cursor *block.Cursor) (*Flowgraph, error)

FollowGraph reads the pinned Flowgraph body. cursor points to the run.

func (*FlowgraphRun) GetActivations 

func (x *FlowgraphRun) GetActivations() []*FlowgraphActivation

func (*FlowgraphRun) GetArrivals 

func (x *FlowgraphRun) GetArrivals() []*FlowgraphArrival

func (*FlowgraphRun) GetBlockRefCtor 

func (r *FlowgraphRun) GetBlockRefCtor(id uint32) block.Ctor

GetBlockRefCtor returns the Flowgraph constructor for the pinned graph.

func (*FlowgraphRun) GetBlockRefs 

func (r *FlowgraphRun) GetBlockRefs() (map[uint32]*block.BlockRef, error)

GetBlockRefs returns the pinned graph reference.

func (*FlowgraphRun) GetCursor 

func (x *FlowgraphRun) GetCursor() map[string][]byte

func (*FlowgraphRun) GetFlowgraphKey 

func (x *FlowgraphRun) GetFlowgraphKey() string

func (*FlowgraphRun) GetFlowgraphRevision 

func (x *FlowgraphRun) GetFlowgraphRevision() uint64

func (*FlowgraphRun) GetGraphRef 

func (x *FlowgraphRun) GetGraphRef() *block.BlockRef

func (*FlowgraphRun) GetJobKey 

func (x *FlowgraphRun) GetJobKey() string

func (*FlowgraphRun) GetPauseReason 

func (x *FlowgraphRun) GetPauseReason() string

func (*FlowgraphRun) GetPausedNode 

func (x *FlowgraphRun) GetPausedNode() string

func (*FlowgraphRun) GetStanding 

func (x *FlowgraphRun) GetStanding() bool

func (*FlowgraphRun) GetState 

func (x *FlowgraphRun) GetState() FlowgraphRunState

func (*FlowgraphRun) GetVisits 

func (x *FlowgraphRun) GetVisits() map[string]*FlowgraphVisits

func (*FlowgraphRun) MarshalJSON 

func (x *FlowgraphRun) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphRun to JSON.

func (*FlowgraphRun) MarshalProtoJSON 

func (x *FlowgraphRun) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphRun message to JSON.

func (*FlowgraphRun) MarshalProtoText 

func (x *FlowgraphRun) MarshalProtoText() string

func (*FlowgraphRun) MarshalToSizedBufferVT 

func (m *FlowgraphRun) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphRun) MarshalToVT 

func (m *FlowgraphRun) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphRun) MarshalVT 

func (m *FlowgraphRun) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphRun) ProtoMessage 

func (*FlowgraphRun) ProtoMessage()

func (*FlowgraphRun) Reset 

func (x *FlowgraphRun) Reset()

func (*FlowgraphRun) SetGraph 

func (r *FlowgraphRun) SetGraph(cursor *block.Cursor, graph *Flowgraph, revision uint64)

SetGraph pins a Flowgraph body and its revision. cursor points to the run; the caller writes the run block afterwards.

func (*FlowgraphRun) SizeVT 

func (m *FlowgraphRun) SizeVT() (n int)

func (*FlowgraphRun) String 

func (x *FlowgraphRun) String() string

func (*FlowgraphRun) UnmarshalJSON 

func (x *FlowgraphRun) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphRun from JSON.

func (*FlowgraphRun) UnmarshalProtoJSON 

func (x *FlowgraphRun) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphRun message from JSON.

func (*FlowgraphRun) UnmarshalVT 

func (m *FlowgraphRun) UnmarshalVT(dAtA []byte) error

type FlowgraphRunState 

type FlowgraphRunState int32

FlowgraphRunState is the lifecycle state of a run. 

const (
	// FLOWGRAPH_RUN_STATE_UNKNOWN is unset.
	FlowgraphRunState_FLOWGRAPH_RUN_STATE_UNKNOWN FlowgraphRunState = 0
	// FLOWGRAPH_RUN_STATE_RUNNING starts each Step whose inputs have arrived.
	FlowgraphRunState_FLOWGRAPH_RUN_STATE_RUNNING FlowgraphRunState = 1
	// FLOWGRAPH_RUN_STATE_PAUSED starts no Step until its owner resumes it.
	FlowgraphRunState_FLOWGRAPH_RUN_STATE_PAUSED FlowgraphRunState = 2
	// FLOWGRAPH_RUN_STATE_COMPLETE has no activation running or waiting.
	FlowgraphRunState_FLOWGRAPH_RUN_STATE_COMPLETE FlowgraphRunState = 3
)

func (FlowgraphRunState) Enum 

func (x FlowgraphRunState) Enum() *FlowgraphRunState

func (FlowgraphRunState) MarshalJSON 

func (x FlowgraphRunState) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphRunState to JSON.

func (FlowgraphRunState) MarshalProtoJSON 

func (x FlowgraphRunState) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphRunState to JSON.

func (FlowgraphRunState) MarshalProtoText 

func (x FlowgraphRunState) MarshalProtoText() string

func (FlowgraphRunState) MarshalText 

func (x FlowgraphRunState) MarshalText() ([]byte, error)

MarshalText marshals the FlowgraphRunState to text.

func (FlowgraphRunState) String 

func (x FlowgraphRunState) String() string

func (*FlowgraphRunState) UnmarshalJSON 

func (x *FlowgraphRunState) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphRunState from JSON.

func (*FlowgraphRunState) UnmarshalProtoJSON 

func (x *FlowgraphRunState) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphRunState from JSON.

func (*FlowgraphRunState) UnmarshalText 

func (x *FlowgraphRunState) UnmarshalText(b []byte) error

UnmarshalText unmarshals the FlowgraphRunState from text.

type FlowgraphRun_CursorEntry 

type FlowgraphRun_CursorEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowgraphRun_CursorEntry) GetKey 

func (x *FlowgraphRun_CursorEntry) GetKey() string

func (*FlowgraphRun_CursorEntry) GetValue 

func (x *FlowgraphRun_CursorEntry) GetValue() []byte

func (*FlowgraphRun_CursorEntry) MarshalJSON 

func (x *FlowgraphRun_CursorEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphRun_CursorEntry to JSON.

func (*FlowgraphRun_CursorEntry) MarshalProtoJSON 

func (x *FlowgraphRun_CursorEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphRun_CursorEntry message to JSON.

func (*FlowgraphRun_CursorEntry) MarshalProtoText 

func (x *FlowgraphRun_CursorEntry) MarshalProtoText() string

func (*FlowgraphRun_CursorEntry) ProtoMessage 

func (*FlowgraphRun_CursorEntry) ProtoMessage()

func (*FlowgraphRun_CursorEntry) Reset 

func (x *FlowgraphRun_CursorEntry) Reset()

func (*FlowgraphRun_CursorEntry) String 

func (x *FlowgraphRun_CursorEntry) String() string

func (*FlowgraphRun_CursorEntry) UnmarshalJSON 

func (x *FlowgraphRun_CursorEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphRun_CursorEntry from JSON.

func (*FlowgraphRun_CursorEntry) UnmarshalProtoJSON 

func (x *FlowgraphRun_CursorEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphRun_CursorEntry message from JSON.

type FlowgraphRun_VisitsEntry 

type FlowgraphRun_VisitsEntry struct {
	Key   string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *FlowgraphVisits `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowgraphRun_VisitsEntry) GetKey 

func (x *FlowgraphRun_VisitsEntry) GetKey() string

func (*FlowgraphRun_VisitsEntry) GetValue 

func (x *FlowgraphRun_VisitsEntry) GetValue() *FlowgraphVisits

func (*FlowgraphRun_VisitsEntry) MarshalJSON 

func (x *FlowgraphRun_VisitsEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphRun_VisitsEntry to JSON.

func (*FlowgraphRun_VisitsEntry) MarshalProtoJSON 

func (x *FlowgraphRun_VisitsEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphRun_VisitsEntry message to JSON.

func (*FlowgraphRun_VisitsEntry) MarshalProtoText 

func (x *FlowgraphRun_VisitsEntry) MarshalProtoText() string

func (*FlowgraphRun_VisitsEntry) ProtoMessage 

func (*FlowgraphRun_VisitsEntry) ProtoMessage()

func (*FlowgraphRun_VisitsEntry) Reset 

func (x *FlowgraphRun_VisitsEntry) Reset()

func (*FlowgraphRun_VisitsEntry) String 

func (x *FlowgraphRun_VisitsEntry) String() string

func (*FlowgraphRun_VisitsEntry) UnmarshalJSON 

func (x *FlowgraphRun_VisitsEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphRun_VisitsEntry from JSON.

func (*FlowgraphRun_VisitsEntry) UnmarshalProtoJSON 

func (x *FlowgraphRun_VisitsEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphRun_VisitsEntry message from JSON.

type FlowgraphSkill 

type FlowgraphSkill struct {

	// Name selects the skill.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Parameters contains the invocation's named settings.
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

FlowgraphSkill declares an allowed skill invocation.

func (*FlowgraphSkill) CloneMessageVT 

func (m *FlowgraphSkill) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphSkill) CloneVT 

func (m *FlowgraphSkill) CloneVT() *FlowgraphSkill

func (*FlowgraphSkill) EqualMessageVT 

func (this *FlowgraphSkill) EqualMessageVT(thatMsg any) bool

func (*FlowgraphSkill) EqualVT 

func (this *FlowgraphSkill) EqualVT(that *FlowgraphSkill) bool

func (*FlowgraphSkill) GetName 

func (x *FlowgraphSkill) GetName() string

func (*FlowgraphSkill) GetParameters 

func (x *FlowgraphSkill) GetParameters() map[string]string

func (*FlowgraphSkill) MarshalJSON 

func (x *FlowgraphSkill) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphSkill to JSON.

func (*FlowgraphSkill) MarshalProtoJSON 

func (x *FlowgraphSkill) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphSkill message to JSON.

func (*FlowgraphSkill) MarshalProtoText 

func (x *FlowgraphSkill) MarshalProtoText() string

func (*FlowgraphSkill) MarshalToSizedBufferVT 

func (m *FlowgraphSkill) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphSkill) MarshalToVT 

func (m *FlowgraphSkill) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphSkill) MarshalVT 

func (m *FlowgraphSkill) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphSkill) ProtoMessage 

func (*FlowgraphSkill) ProtoMessage()

func (*FlowgraphSkill) Reset 

func (x *FlowgraphSkill) Reset()

func (*FlowgraphSkill) SizeVT 

func (m *FlowgraphSkill) SizeVT() (n int)

func (*FlowgraphSkill) String 

func (x *FlowgraphSkill) String() string

func (*FlowgraphSkill) UnmarshalJSON 

func (x *FlowgraphSkill) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphSkill from JSON.

func (*FlowgraphSkill) UnmarshalProtoJSON 

func (x *FlowgraphSkill) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphSkill message from JSON.

func (*FlowgraphSkill) UnmarshalVT 

func (m *FlowgraphSkill) UnmarshalVT(dAtA []byte) error

type FlowgraphSkill_ParametersEntry 

type FlowgraphSkill_ParametersEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowgraphSkill_ParametersEntry) GetKey 

func (x *FlowgraphSkill_ParametersEntry) GetKey() string

func (*FlowgraphSkill_ParametersEntry) GetValue 

func (x *FlowgraphSkill_ParametersEntry) GetValue() string

func (*FlowgraphSkill_ParametersEntry) MarshalJSON 

func (x *FlowgraphSkill_ParametersEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphSkill_ParametersEntry to JSON.

func (*FlowgraphSkill_ParametersEntry) MarshalProtoJSON 

func (x *FlowgraphSkill_ParametersEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphSkill_ParametersEntry message to JSON.

func (*FlowgraphSkill_ParametersEntry) MarshalProtoText 

func (x *FlowgraphSkill_ParametersEntry) MarshalProtoText() string

func (*FlowgraphSkill_ParametersEntry) ProtoMessage 

func (*FlowgraphSkill_ParametersEntry) ProtoMessage()

func (*FlowgraphSkill_ParametersEntry) Reset 

func (x *FlowgraphSkill_ParametersEntry) Reset()

func (*FlowgraphSkill_ParametersEntry) String 

func (x *FlowgraphSkill_ParametersEntry) String() string

func (*FlowgraphSkill_ParametersEntry) UnmarshalJSON 

func (x *FlowgraphSkill_ParametersEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphSkill_ParametersEntry from JSON.

func (*FlowgraphSkill_ParametersEntry) UnmarshalProtoJSON 

func (x *FlowgraphSkill_ParametersEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphSkill_ParametersEntry message from JSON.

type FlowgraphSnapshot 

type FlowgraphSnapshot struct {

	// State is the authored object body.
	State *Flowgraph `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// Placements contains placement edges keyed by node ID.
	Placements map[string]*FlowgraphPlacement `` /* 161-byte string literal not displayed */
	// Revision is the object's revision observed by this read.
	Revision uint64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	// Bindings contains the binding of each node that names an object, keyed by
	// node ID. An unbound node has no entry.
	Bindings map[string]*FlowgraphBinding `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

FlowgraphSnapshot reads authored state and its placement edges together.

func ReadFlowgraph 

func ReadFlowgraph(ctx context.Context, ws world.WorldState, key string) (*FlowgraphSnapshot, error)

ReadFlowgraph reads a graph's body, placement edges, and object revision. Call with a transaction to keep the body and edges in one snapshot.

func UpdateBoundFlowgraph 

func UpdateBoundFlowgraph(ctx context.Context, ws world.WorldState, b bus.Bus, engineID, key string, request *UpdateFlowgraphRequest) (*FlowgraphSnapshot, error)

UpdateBoundFlowgraph changes the graph as UpdateFlowgraph does, and checks connections to a node bound to an object against the ports the object's type declares on b, scoped to engineID. The returned snapshot carries the bindings read from the same transaction.

func UpdateFlowgraph 

func UpdateFlowgraph(ctx context.Context, ws world.WorldState, key string, request *UpdateFlowgraphRequest) (*FlowgraphSnapshot, error)

UpdateFlowgraph changes the body and placement graph in the caller's transaction. The caller commits on success or discards the transaction on error. It has no object type registry, so a bound node offers its authored ports only.

func (*FlowgraphSnapshot) CloneMessageVT 

func (m *FlowgraphSnapshot) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphSnapshot) CloneVT 

func (m *FlowgraphSnapshot) CloneVT() *FlowgraphSnapshot

func (*FlowgraphSnapshot) EqualMessageVT 

func (this *FlowgraphSnapshot) EqualMessageVT(thatMsg any) bool

func (*FlowgraphSnapshot) EqualVT 

func (this *FlowgraphSnapshot) EqualVT(that *FlowgraphSnapshot) bool

func (*FlowgraphSnapshot) GetBindings 

func (x *FlowgraphSnapshot) GetBindings() map[string]*FlowgraphBinding

func (*FlowgraphSnapshot) GetPlacements 

func (x *FlowgraphSnapshot) GetPlacements() map[string]*FlowgraphPlacement

func (*FlowgraphSnapshot) GetRevision 

func (x *FlowgraphSnapshot) GetRevision() uint64

func (*FlowgraphSnapshot) GetState 

func (x *FlowgraphSnapshot) GetState() *Flowgraph

func (*FlowgraphSnapshot) MarshalJSON 

func (x *FlowgraphSnapshot) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphSnapshot to JSON.

func (*FlowgraphSnapshot) MarshalProtoJSON 

func (x *FlowgraphSnapshot) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphSnapshot message to JSON.

func (*FlowgraphSnapshot) MarshalProtoText 

func (x *FlowgraphSnapshot) MarshalProtoText() string

func (*FlowgraphSnapshot) MarshalToSizedBufferVT 

func (m *FlowgraphSnapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphSnapshot) MarshalToVT 

func (m *FlowgraphSnapshot) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphSnapshot) MarshalVT 

func (m *FlowgraphSnapshot) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphSnapshot) ProtoMessage 

func (*FlowgraphSnapshot) ProtoMessage()

func (*FlowgraphSnapshot) Reset 

func (x *FlowgraphSnapshot) Reset()

func (*FlowgraphSnapshot) SizeVT 

func (m *FlowgraphSnapshot) SizeVT() (n int)

func (*FlowgraphSnapshot) String 

func (x *FlowgraphSnapshot) String() string

func (*FlowgraphSnapshot) UnmarshalJSON 

func (x *FlowgraphSnapshot) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphSnapshot from JSON.

func (*FlowgraphSnapshot) UnmarshalProtoJSON 

func (x *FlowgraphSnapshot) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphSnapshot message from JSON.

func (*FlowgraphSnapshot) UnmarshalVT 

func (m *FlowgraphSnapshot) UnmarshalVT(dAtA []byte) error

type FlowgraphSnapshot_BindingsEntry 

type FlowgraphSnapshot_BindingsEntry struct {
	Key   string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *FlowgraphBinding `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowgraphSnapshot_BindingsEntry) GetKey 

func (x *FlowgraphSnapshot_BindingsEntry) GetKey() string

func (*FlowgraphSnapshot_BindingsEntry) GetValue 

func (x *FlowgraphSnapshot_BindingsEntry) GetValue() *FlowgraphBinding

func (*FlowgraphSnapshot_BindingsEntry) MarshalJSON 

func (x *FlowgraphSnapshot_BindingsEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphSnapshot_BindingsEntry to JSON.

func (*FlowgraphSnapshot_BindingsEntry) MarshalProtoJSON 

func (x *FlowgraphSnapshot_BindingsEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphSnapshot_BindingsEntry message to JSON.

func (*FlowgraphSnapshot_BindingsEntry) MarshalProtoText 

func (x *FlowgraphSnapshot_BindingsEntry) MarshalProtoText() string

func (*FlowgraphSnapshot_BindingsEntry) ProtoMessage 

func (*FlowgraphSnapshot_BindingsEntry) ProtoMessage()

func (*FlowgraphSnapshot_BindingsEntry) Reset 

func (x *FlowgraphSnapshot_BindingsEntry) Reset()

func (*FlowgraphSnapshot_BindingsEntry) String 

func (x *FlowgraphSnapshot_BindingsEntry) String() string

func (*FlowgraphSnapshot_BindingsEntry) UnmarshalJSON 

func (x *FlowgraphSnapshot_BindingsEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphSnapshot_BindingsEntry from JSON.

func (*FlowgraphSnapshot_BindingsEntry) UnmarshalProtoJSON 

func (x *FlowgraphSnapshot_BindingsEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphSnapshot_BindingsEntry message from JSON.

type FlowgraphSnapshot_PlacementsEntry 

type FlowgraphSnapshot_PlacementsEntry struct {
	Key   string              `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *FlowgraphPlacement `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowgraphSnapshot_PlacementsEntry) GetKey 

func (x *FlowgraphSnapshot_PlacementsEntry) GetKey() string

func (*FlowgraphSnapshot_PlacementsEntry) GetValue 

func (x *FlowgraphSnapshot_PlacementsEntry) GetValue() *FlowgraphPlacement

func (*FlowgraphSnapshot_PlacementsEntry) MarshalJSON 

func (x *FlowgraphSnapshot_PlacementsEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphSnapshot_PlacementsEntry to JSON.

func (*FlowgraphSnapshot_PlacementsEntry) MarshalProtoJSON 

func (x *FlowgraphSnapshot_PlacementsEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphSnapshot_PlacementsEntry message to JSON.

func (*FlowgraphSnapshot_PlacementsEntry) MarshalProtoText 

func (x *FlowgraphSnapshot_PlacementsEntry) MarshalProtoText() string

func (*FlowgraphSnapshot_PlacementsEntry) ProtoMessage 

func (*FlowgraphSnapshot_PlacementsEntry) ProtoMessage()

func (*FlowgraphSnapshot_PlacementsEntry) Reset 

func (x *FlowgraphSnapshot_PlacementsEntry) Reset()

func (*FlowgraphSnapshot_PlacementsEntry) String 

func (x *FlowgraphSnapshot_PlacementsEntry) String() string

func (*FlowgraphSnapshot_PlacementsEntry) UnmarshalJSON 

func (x *FlowgraphSnapshot_PlacementsEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphSnapshot_PlacementsEntry from JSON.

func (*FlowgraphSnapshot_PlacementsEntry) UnmarshalProtoJSON 

func (x *FlowgraphSnapshot_PlacementsEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphSnapshot_PlacementsEntry message from JSON.

type FlowgraphStep 

type FlowgraphStep struct {

	// Prompt contains the actor's instructions.
	Prompt string `protobuf:"bytes,1,opt,name=prompt,proto3" json:"prompt,omitempty"`
	// Skills lists the skills the actor may invoke.
	Skills []*FlowgraphSkill `protobuf:"bytes,2,rep,name=skills,proto3" json:"skills,omitempty"`
	// Target contains the execution definition for the Step. It declares one
	// EXEC output per Step output port, named after the port, and its exec sets
	// exactly one of them. It may also set a spend output.
	//
	// A code Step's exec runs its code. An actor Step's exec is the runner
	// controller for the actor's object type, configured with the Step's prompt
	// and each output port's condition. The runner gives the actor the prompt,
	// the conditions and the activation inputs, and sets the chosen port's
	// output to a World object snapshot of the actor's conclusion, which records
	// a confidence and a reason for every output port. A runner whose actor
	// concludes nothing sets no port, so the run pauses with its inputs kept.
	Target *target.Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// Bound limits this Step's activations within one run.
	Bound *FlowgraphBound `protobuf:"bytes,4,opt,name=bound,proto3" json:"bound,omitempty"`
	// Keyed makes the Step hold one running activation per arrival key. Its
	// input ports are satisfied by arrivals that carry the same key, and an
	// arrival for a key that has a running activation reaches that activation's
	// inbox. An unkeyed Step ignores the key.
	Keyed bool `protobuf:"varint,5,opt,name=keyed,proto3" json:"keyed,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphStep holds the instructions for an actor or code Step.

func (*FlowgraphStep) CloneMessageVT 

func (m *FlowgraphStep) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphStep) CloneVT 

func (m *FlowgraphStep) CloneVT() *FlowgraphStep

func (*FlowgraphStep) EqualMessageVT 

func (this *FlowgraphStep) EqualMessageVT(thatMsg any) bool

func (*FlowgraphStep) EqualVT 

func (this *FlowgraphStep) EqualVT(that *FlowgraphStep) bool

func (*FlowgraphStep) GetBound 

func (x *FlowgraphStep) GetBound() *FlowgraphBound

func (*FlowgraphStep) GetKeyed 

func (x *FlowgraphStep) GetKeyed() bool

func (*FlowgraphStep) GetPrompt 

func (x *FlowgraphStep) GetPrompt() string

func (*FlowgraphStep) GetSkills 

func (x *FlowgraphStep) GetSkills() []*FlowgraphSkill

func (*FlowgraphStep) GetTarget 

func (x *FlowgraphStep) GetTarget() *target.Target

func (*FlowgraphStep) MarshalJSON 

func (x *FlowgraphStep) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphStep to JSON.

func (*FlowgraphStep) MarshalProtoJSON 

func (x *FlowgraphStep) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphStep message to JSON.

func (*FlowgraphStep) MarshalProtoText 

func (x *FlowgraphStep) MarshalProtoText() string

func (*FlowgraphStep) MarshalToSizedBufferVT 

func (m *FlowgraphStep) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphStep) MarshalToVT 

func (m *FlowgraphStep) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphStep) MarshalVT 

func (m *FlowgraphStep) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphStep) ProtoMessage 

func (*FlowgraphStep) ProtoMessage()

func (*FlowgraphStep) Reset 

func (x *FlowgraphStep) Reset()

func (*FlowgraphStep) SizeVT 

func (m *FlowgraphStep) SizeVT() (n int)

func (*FlowgraphStep) String 

func (x *FlowgraphStep) String() string

func (*FlowgraphStep) UnmarshalJSON 

func (x *FlowgraphStep) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphStep from JSON.

func (*FlowgraphStep) UnmarshalProtoJSON 

func (x *FlowgraphStep) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphStep message from JSON.

func (*FlowgraphStep) UnmarshalVT 

func (m *FlowgraphStep) UnmarshalVT(dAtA []byte) error

type FlowgraphTaskOutput 

type FlowgraphTaskOutput struct {

	// TaskKey is the Task whose output arrived.
	TaskKey string `protobuf:"bytes,1,opt,name=task_key,json=taskKey,proto3" json:"taskKey,omitempty"`
	// OutputName is the arriving output of that Task.
	OutputName string `protobuf:"bytes,2,opt,name=output_name,json=outputName,proto3" json:"outputName,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphTaskOutput names an output of a Forge Task.

func (*FlowgraphTaskOutput) CloneMessageVT 

func (m *FlowgraphTaskOutput) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphTaskOutput) CloneVT 

func (m *FlowgraphTaskOutput) CloneVT() *FlowgraphTaskOutput

func (*FlowgraphTaskOutput) EqualMessageVT 

func (this *FlowgraphTaskOutput) EqualMessageVT(thatMsg any) bool

func (*FlowgraphTaskOutput) EqualVT 

func (this *FlowgraphTaskOutput) EqualVT(that *FlowgraphTaskOutput) bool

func (*FlowgraphTaskOutput) GetOutputName 

func (x *FlowgraphTaskOutput) GetOutputName() string

func (*FlowgraphTaskOutput) GetTaskKey 

func (x *FlowgraphTaskOutput) GetTaskKey() string

func (*FlowgraphTaskOutput) MarshalJSON 

func (x *FlowgraphTaskOutput) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphTaskOutput to JSON.

func (*FlowgraphTaskOutput) MarshalProtoJSON 

func (x *FlowgraphTaskOutput) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphTaskOutput message to JSON.

func (*FlowgraphTaskOutput) MarshalProtoText 

func (x *FlowgraphTaskOutput) MarshalProtoText() string

func (*FlowgraphTaskOutput) MarshalToSizedBufferVT 

func (m *FlowgraphTaskOutput) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphTaskOutput) MarshalToVT 

func (m *FlowgraphTaskOutput) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphTaskOutput) MarshalVT 

func (m *FlowgraphTaskOutput) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphTaskOutput) ProtoMessage 

func (*FlowgraphTaskOutput) ProtoMessage()

func (*FlowgraphTaskOutput) Reset 

func (x *FlowgraphTaskOutput) Reset()

func (*FlowgraphTaskOutput) SizeVT 

func (m *FlowgraphTaskOutput) SizeVT() (n int)

func (*FlowgraphTaskOutput) String 

func (x *FlowgraphTaskOutput) String() string

func (*FlowgraphTaskOutput) UnmarshalJSON 

func (x *FlowgraphTaskOutput) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphTaskOutput from JSON.

func (*FlowgraphTaskOutput) UnmarshalProtoJSON 

func (x *FlowgraphTaskOutput) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphTaskOutput message from JSON.

func (*FlowgraphTaskOutput) UnmarshalVT 

func (m *FlowgraphTaskOutput) UnmarshalVT(dAtA []byte) error

type FlowgraphVisits 

type FlowgraphVisits struct {

	// Count is the number of activations started.
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// Spend is the total spend the completed activations reported.
	Spend uint64 `protobuf:"varint,2,opt,name=spend,proto3" json:"spend,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphVisits counts one Step's activations in a run.

func (*FlowgraphVisits) CloneMessageVT 

func (m *FlowgraphVisits) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*FlowgraphVisits) CloneVT 

func (m *FlowgraphVisits) CloneVT() *FlowgraphVisits

func (*FlowgraphVisits) EqualMessageVT 

func (this *FlowgraphVisits) EqualMessageVT(thatMsg any) bool

func (*FlowgraphVisits) EqualVT 

func (this *FlowgraphVisits) EqualVT(that *FlowgraphVisits) bool

func (*FlowgraphVisits) GetCount 

func (x *FlowgraphVisits) GetCount() uint32

func (*FlowgraphVisits) GetSpend 

func (x *FlowgraphVisits) GetSpend() uint64

func (*FlowgraphVisits) MarshalJSON 

func (x *FlowgraphVisits) MarshalJSON() ([]byte, error)

MarshalJSON marshals the FlowgraphVisits to JSON.

func (*FlowgraphVisits) MarshalProtoJSON 

func (x *FlowgraphVisits) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the FlowgraphVisits message to JSON.

func (*FlowgraphVisits) MarshalProtoText 

func (x *FlowgraphVisits) MarshalProtoText() string

func (*FlowgraphVisits) MarshalToSizedBufferVT 

func (m *FlowgraphVisits) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FlowgraphVisits) MarshalToVT 

func (m *FlowgraphVisits) MarshalToVT(dAtA []byte) (int, error)

func (*FlowgraphVisits) MarshalVT 

func (m *FlowgraphVisits) MarshalVT() (dAtA []byte, err error)

func (*FlowgraphVisits) ProtoMessage 

func (*FlowgraphVisits) ProtoMessage()

func (*FlowgraphVisits) Reset 

func (x *FlowgraphVisits) Reset()

func (*FlowgraphVisits) SizeVT 

func (m *FlowgraphVisits) SizeVT() (n int)

func (*FlowgraphVisits) String 

func (x *FlowgraphVisits) String() string

func (*FlowgraphVisits) UnmarshalJSON 

func (x *FlowgraphVisits) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the FlowgraphVisits from JSON.

func (*FlowgraphVisits) UnmarshalProtoJSON 

func (x *FlowgraphVisits) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the FlowgraphVisits message from JSON.

func (*FlowgraphVisits) UnmarshalVT 

func (m *FlowgraphVisits) UnmarshalVT(dAtA []byte) error

type Flowgraph_ConnectionsEntry 

type Flowgraph_ConnectionsEntry struct {
	Key   string               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *FlowgraphConnection `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Flowgraph_ConnectionsEntry) GetKey 

func (x *Flowgraph_ConnectionsEntry) GetKey() string

func (*Flowgraph_ConnectionsEntry) GetValue 

func (x *Flowgraph_ConnectionsEntry) GetValue() *FlowgraphConnection

func (*Flowgraph_ConnectionsEntry) MarshalJSON 

func (x *Flowgraph_ConnectionsEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Flowgraph_ConnectionsEntry to JSON.

func (*Flowgraph_ConnectionsEntry) MarshalProtoJSON 

func (x *Flowgraph_ConnectionsEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Flowgraph_ConnectionsEntry message to JSON.

func (*Flowgraph_ConnectionsEntry) MarshalProtoText 

func (x *Flowgraph_ConnectionsEntry) MarshalProtoText() string

func (*Flowgraph_ConnectionsEntry) ProtoMessage 

func (*Flowgraph_ConnectionsEntry) ProtoMessage()

func (*Flowgraph_ConnectionsEntry) Reset 

func (x *Flowgraph_ConnectionsEntry) Reset()

func (*Flowgraph_ConnectionsEntry) String 

func (x *Flowgraph_ConnectionsEntry) String() string

func (*Flowgraph_ConnectionsEntry) UnmarshalJSON 

func (x *Flowgraph_ConnectionsEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Flowgraph_ConnectionsEntry from JSON.

func (*Flowgraph_ConnectionsEntry) UnmarshalProtoJSON 

func (x *Flowgraph_ConnectionsEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Flowgraph_ConnectionsEntry message from JSON.

type Flowgraph_NodesEntry 

type Flowgraph_NodesEntry struct {
	Key   string         `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *FlowgraphNode `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Flowgraph_NodesEntry) GetKey 

func (x *Flowgraph_NodesEntry) GetKey() string

func (*Flowgraph_NodesEntry) GetValue 

func (x *Flowgraph_NodesEntry) GetValue() *FlowgraphNode

func (*Flowgraph_NodesEntry) MarshalJSON 

func (x *Flowgraph_NodesEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Flowgraph_NodesEntry to JSON.

func (*Flowgraph_NodesEntry) MarshalProtoJSON 

func (x *Flowgraph_NodesEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Flowgraph_NodesEntry message to JSON.

func (*Flowgraph_NodesEntry) MarshalProtoText 

func (x *Flowgraph_NodesEntry) MarshalProtoText() string

func (*Flowgraph_NodesEntry) ProtoMessage 

func (*Flowgraph_NodesEntry) ProtoMessage()

func (*Flowgraph_NodesEntry) Reset 

func (x *Flowgraph_NodesEntry) Reset()

func (*Flowgraph_NodesEntry) String 

func (x *Flowgraph_NodesEntry) String() string

func (*Flowgraph_NodesEntry) UnmarshalJSON 

func (x *Flowgraph_NodesEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Flowgraph_NodesEntry from JSON.

func (*Flowgraph_NodesEntry) UnmarshalProtoJSON 

func (x *Flowgraph_NodesEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Flowgraph_NodesEntry message from JSON.

type GetFlowgraphRequest 

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

GetFlowgraphRequest reads the mounted graph.

func (*GetFlowgraphRequest) CloneMessageVT 

func (m *GetFlowgraphRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetFlowgraphRequest) CloneVT 

func (m *GetFlowgraphRequest) CloneVT() *GetFlowgraphRequest

func (*GetFlowgraphRequest) EqualMessageVT 

func (this *GetFlowgraphRequest) EqualMessageVT(thatMsg any) bool

func (*GetFlowgraphRequest) EqualVT 

func (this *GetFlowgraphRequest) EqualVT(that *GetFlowgraphRequest) bool

func (*GetFlowgraphRequest) MarshalJSON 

func (x *GetFlowgraphRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetFlowgraphRequest to JSON.

func (*GetFlowgraphRequest) MarshalProtoJSON 

func (x *GetFlowgraphRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetFlowgraphRequest message to JSON.

func (*GetFlowgraphRequest) MarshalProtoText 

func (x *GetFlowgraphRequest) MarshalProtoText() string

func (*GetFlowgraphRequest) MarshalToSizedBufferVT 

func (m *GetFlowgraphRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetFlowgraphRequest) MarshalToVT 

func (m *GetFlowgraphRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetFlowgraphRequest) MarshalVT 

func (m *GetFlowgraphRequest) MarshalVT() (dAtA []byte, err error)

func (*GetFlowgraphRequest) ProtoMessage 

func (*GetFlowgraphRequest) ProtoMessage()

func (*GetFlowgraphRequest) Reset 

func (x *GetFlowgraphRequest) Reset()

func (*GetFlowgraphRequest) SizeVT 

func (m *GetFlowgraphRequest) SizeVT() (n int)

func (*GetFlowgraphRequest) String 

func (x *GetFlowgraphRequest) String() string

func (*GetFlowgraphRequest) UnmarshalJSON 

func (x *GetFlowgraphRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetFlowgraphRequest from JSON.

func (*GetFlowgraphRequest) UnmarshalProtoJSON 

func (x *GetFlowgraphRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetFlowgraphRequest message from JSON.

func (*GetFlowgraphRequest) UnmarshalVT 

func (m *GetFlowgraphRequest) UnmarshalVT(dAtA []byte) error

type GetFlowgraphResponse 

type GetFlowgraphResponse struct {

	// Snapshot is the graph at the observed revision.
	Snapshot *FlowgraphSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

GetFlowgraphResponse contains the current graph snapshot.

func (*GetFlowgraphResponse) CloneMessageVT 

func (m *GetFlowgraphResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetFlowgraphResponse) CloneVT 

func (m *GetFlowgraphResponse) CloneVT() *GetFlowgraphResponse

func (*GetFlowgraphResponse) EqualMessageVT 

func (this *GetFlowgraphResponse) EqualMessageVT(thatMsg any) bool

func (*GetFlowgraphResponse) EqualVT 

func (this *GetFlowgraphResponse) EqualVT(that *GetFlowgraphResponse) bool

func (*GetFlowgraphResponse) GetSnapshot 

func (x *GetFlowgraphResponse) GetSnapshot() *FlowgraphSnapshot

func (*GetFlowgraphResponse) MarshalJSON 

func (x *GetFlowgraphResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetFlowgraphResponse to JSON.

func (*GetFlowgraphResponse) MarshalProtoJSON 

func (x *GetFlowgraphResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetFlowgraphResponse message to JSON.

func (*GetFlowgraphResponse) MarshalProtoText 

func (x *GetFlowgraphResponse) MarshalProtoText() string

func (*GetFlowgraphResponse) MarshalToSizedBufferVT 

func (m *GetFlowgraphResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetFlowgraphResponse) MarshalToVT 

func (m *GetFlowgraphResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetFlowgraphResponse) MarshalVT 

func (m *GetFlowgraphResponse) MarshalVT() (dAtA []byte, err error)

func (*GetFlowgraphResponse) ProtoMessage 

func (*GetFlowgraphResponse) ProtoMessage()

func (*GetFlowgraphResponse) Reset 

func (x *GetFlowgraphResponse) Reset()

func (*GetFlowgraphResponse) SizeVT 

func (m *GetFlowgraphResponse) SizeVT() (n int)

func (*GetFlowgraphResponse) String 

func (x *GetFlowgraphResponse) String() string

func (*GetFlowgraphResponse) UnmarshalJSON 

func (x *GetFlowgraphResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetFlowgraphResponse from JSON.

func (*GetFlowgraphResponse) UnmarshalProtoJSON 

func (x *GetFlowgraphResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetFlowgraphResponse message from JSON.

func (*GetFlowgraphResponse) UnmarshalVT 

func (m *GetFlowgraphResponse) UnmarshalVT(dAtA []byte) error

type ListFlowgraphChangesRequest 

type ListFlowgraphChangesRequest struct {

	// Limit bounds the number of changes returned; zero returns all retained.
	Limit uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

ListFlowgraphChangesRequest reads the mounted graph's history.

func (*ListFlowgraphChangesRequest) CloneMessageVT 

func (m *ListFlowgraphChangesRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ListFlowgraphChangesRequest) CloneVT 

func (m *ListFlowgraphChangesRequest) CloneVT() *ListFlowgraphChangesRequest

func (*ListFlowgraphChangesRequest) EqualMessageVT 

func (this *ListFlowgraphChangesRequest) EqualMessageVT(thatMsg any) bool

func (*ListFlowgraphChangesRequest) EqualVT 

func (this *ListFlowgraphChangesRequest) EqualVT(that *ListFlowgraphChangesRequest) bool

func (*ListFlowgraphChangesRequest) GetLimit 

func (x *ListFlowgraphChangesRequest) GetLimit() uint32

func (*ListFlowgraphChangesRequest) MarshalJSON 

func (x *ListFlowgraphChangesRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListFlowgraphChangesRequest to JSON.

func (*ListFlowgraphChangesRequest) MarshalProtoJSON 

func (x *ListFlowgraphChangesRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListFlowgraphChangesRequest message to JSON.

func (*ListFlowgraphChangesRequest) MarshalProtoText 

func (x *ListFlowgraphChangesRequest) MarshalProtoText() string

func (*ListFlowgraphChangesRequest) MarshalToSizedBufferVT 

func (m *ListFlowgraphChangesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListFlowgraphChangesRequest) MarshalToVT 

func (m *ListFlowgraphChangesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ListFlowgraphChangesRequest) MarshalVT 

func (m *ListFlowgraphChangesRequest) MarshalVT() (dAtA []byte, err error)

func (*ListFlowgraphChangesRequest) ProtoMessage 

func (*ListFlowgraphChangesRequest) ProtoMessage()

func (*ListFlowgraphChangesRequest) Reset 

func (x *ListFlowgraphChangesRequest) Reset()

func (*ListFlowgraphChangesRequest) SizeVT 

func (m *ListFlowgraphChangesRequest) SizeVT() (n int)

func (*ListFlowgraphChangesRequest) String 

func (x *ListFlowgraphChangesRequest) String() string

func (*ListFlowgraphChangesRequest) UnmarshalJSON 

func (x *ListFlowgraphChangesRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListFlowgraphChangesRequest from JSON.

func (*ListFlowgraphChangesRequest) UnmarshalProtoJSON 

func (x *ListFlowgraphChangesRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListFlowgraphChangesRequest message from JSON.

func (*ListFlowgraphChangesRequest) UnmarshalVT 

func (m *ListFlowgraphChangesRequest) UnmarshalVT(dAtA []byte) error

type ListFlowgraphChangesResponse 

type ListFlowgraphChangesResponse struct {

	// Changes contains the revisions, newest first.
	Changes []*FlowgraphChange `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"`
	// ChangelogDisabled is set when the World keeps no changelog, so the graph
	// has no history.
	ChangelogDisabled bool `protobuf:"varint,2,opt,name=changelog_disabled,json=changelogDisabled,proto3" json:"changelogDisabled,omitempty"`
	// Complete is set when changes reach back to the graph's creation.
	Complete bool `protobuf:"varint,3,opt,name=complete,proto3" json:"complete,omitempty"`
	// contains filtered or unexported fields
}

ListFlowgraphChangesResponse contains the graph's retained revisions.

func ReadFlowgraphChanges 

func ReadFlowgraphChanges(ctx context.Context, ws world.WorldState, key string, limit uint32) (*ListFlowgraphChangesResponse, error)

ReadFlowgraphChanges reads up to limit revisions of the graph at key from the World changelog, newest first. A zero limit reads every retained revision. A World without a changelog keeps no history and reports so.

Each revision ends with a World change to the graph's object and includes the placement edges changed since the preceding revision. UpdateFlowgraph writes the object last, so each revision is one authored edit.

func (*ListFlowgraphChangesResponse) CloneMessageVT 

func (m *ListFlowgraphChangesResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ListFlowgraphChangesResponse) CloneVT 

func (m *ListFlowgraphChangesResponse) CloneVT() *ListFlowgraphChangesResponse

func (*ListFlowgraphChangesResponse) EqualMessageVT 

func (this *ListFlowgraphChangesResponse) EqualMessageVT(thatMsg any) bool

func (*ListFlowgraphChangesResponse) EqualVT 

func (this *ListFlowgraphChangesResponse) EqualVT(that *ListFlowgraphChangesResponse) bool

func (*ListFlowgraphChangesResponse) GetChangelogDisabled 

func (x *ListFlowgraphChangesResponse) GetChangelogDisabled() bool

func (*ListFlowgraphChangesResponse) GetChanges 

func (x *ListFlowgraphChangesResponse) GetChanges() []*FlowgraphChange

func (*ListFlowgraphChangesResponse) GetComplete 

func (x *ListFlowgraphChangesResponse) GetComplete() bool

func (*ListFlowgraphChangesResponse) MarshalJSON 

func (x *ListFlowgraphChangesResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListFlowgraphChangesResponse to JSON.

func (*ListFlowgraphChangesResponse) MarshalProtoJSON 

func (x *ListFlowgraphChangesResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListFlowgraphChangesResponse message to JSON.

func (*ListFlowgraphChangesResponse) MarshalProtoText 

func (x *ListFlowgraphChangesResponse) MarshalProtoText() string

func (*ListFlowgraphChangesResponse) MarshalToSizedBufferVT 

func (m *ListFlowgraphChangesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListFlowgraphChangesResponse) MarshalToVT 

func (m *ListFlowgraphChangesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ListFlowgraphChangesResponse) MarshalVT 

func (m *ListFlowgraphChangesResponse) MarshalVT() (dAtA []byte, err error)

func (*ListFlowgraphChangesResponse) ProtoMessage 

func (*ListFlowgraphChangesResponse) ProtoMessage()

func (*ListFlowgraphChangesResponse) Reset 

func (x *ListFlowgraphChangesResponse) Reset()

func (*ListFlowgraphChangesResponse) SizeVT 

func (m *ListFlowgraphChangesResponse) SizeVT() (n int)

func (*ListFlowgraphChangesResponse) String 

func (x *ListFlowgraphChangesResponse) String() string

func (*ListFlowgraphChangesResponse) UnmarshalJSON 

func (x *ListFlowgraphChangesResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListFlowgraphChangesResponse from JSON.

func (*ListFlowgraphChangesResponse) UnmarshalProtoJSON 

func (x *ListFlowgraphChangesResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListFlowgraphChangesResponse message from JSON.

func (*ListFlowgraphChangesResponse) UnmarshalVT 

func (m *ListFlowgraphChangesResponse) UnmarshalVT(dAtA []byte) error

type LookupFlowgraphNodeType 

type LookupFlowgraphNodeType interface {
	// Directive indicates LookupFlowgraphNodeType is a directive.
	directive.Directive

	// LookupFlowgraphNodeTypeID returns the node type ID to look up.
	LookupFlowgraphNodeTypeID() string
}

LookupFlowgraphNodeType is a directive to look up a Flowgraph node type.

func NewLookupFlowgraphNodeType 

func NewLookupFlowgraphNodeType(typeID string) LookupFlowgraphNodeType

NewLookupFlowgraphNodeType constructs a new LookupFlowgraphNodeType directive.

type LookupFlowgraphNodeTypeValue 

type LookupFlowgraphNodeTypeValue = FlowgraphNodeType

LookupFlowgraphNodeTypeValue is the result type for LookupFlowgraphNodeType.

type PlacedFlowgraphConnection 

type PlacedFlowgraphConnection struct {
	// ID is the graph-local ID of the connection.
	ID string
	// Connection is the authored connection.
	Connection *FlowgraphConnection
	// RemoteDevicePeerID is the peer ID of the Device running the other end.
	RemoteDevicePeerID string
}

PlacedFlowgraphConnection is a connection that ends at a placed node.

type PlacedFlowgraphNode 

type PlacedFlowgraphNode struct {
	// FlowgraphKey is the object key of the Flowgraph holding the node.
	FlowgraphKey string
	// NodeID is the graph-local ID of the node.
	NodeID string
	// Node is the authored node.
	Node *FlowgraphNode
	// DevicePeerID is the peer ID of the Device running the node.
	DevicePeerID string
	// Connections contains the connections that end at the node.
	Connections []*PlacedFlowgraphConnection
}

PlacedFlowgraphNode is a node placed on a Device with the context its node type compiles from.

func (*PlacedFlowgraphNode) CapabilityID 

func (n *PlacedFlowgraphNode) CapabilityID() string

CapabilityID returns the ID of the Device capability that shows the node.

type SRPCFlowgraphResourceServiceClient 

type SRPCFlowgraphResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// GetFlowgraph reads the current body and placement edges.
	GetFlowgraph(ctx context.Context, in *GetFlowgraphRequest) (*GetFlowgraphResponse, error)
	// UpdateFlowgraph applies one authored change atomically.
	UpdateFlowgraph(ctx context.Context, in *UpdateFlowgraphRequest) (*UpdateFlowgraphResponse, error)
	// WatchFlowgraph streams committed body and placement changes.
	WatchFlowgraph(ctx context.Context, in *WatchFlowgraphRequest) (SRPCFlowgraphResourceService_WatchFlowgraphClient, error)
	// ListFlowgraphChanges reads the graph's revisions from the World changelog.
	ListFlowgraphChanges(ctx context.Context, in *ListFlowgraphChangesRequest) (*ListFlowgraphChangesResponse, error)
}

func NewSRPCFlowgraphResourceServiceClient 

func NewSRPCFlowgraphResourceServiceClient(cc srpc.Client) SRPCFlowgraphResourceServiceClient

func NewSRPCFlowgraphResourceServiceClientWithServiceID 

func NewSRPCFlowgraphResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCFlowgraphResourceServiceClient

type SRPCFlowgraphResourceServiceHandler 

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

func (SRPCFlowgraphResourceServiceHandler) GetMethodIDs 

func (SRPCFlowgraphResourceServiceHandler) GetMethodIDs() []string

func (*SRPCFlowgraphResourceServiceHandler) GetServiceID 

func (d *SRPCFlowgraphResourceServiceHandler) GetServiceID() string

func (*SRPCFlowgraphResourceServiceHandler) InvokeMethod 

func (d *SRPCFlowgraphResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCFlowgraphResourceServiceHandler) InvokeMethod_GetFlowgraph 

func (SRPCFlowgraphResourceServiceHandler) InvokeMethod_GetFlowgraph(impl SRPCFlowgraphResourceServiceServer, strm srpc.Stream) error

func (SRPCFlowgraphResourceServiceHandler) InvokeMethod_ListFlowgraphChanges 

func (SRPCFlowgraphResourceServiceHandler) InvokeMethod_ListFlowgraphChanges(impl SRPCFlowgraphResourceServiceServer, strm srpc.Stream) error

func (SRPCFlowgraphResourceServiceHandler) InvokeMethod_UpdateFlowgraph 

func (SRPCFlowgraphResourceServiceHandler) InvokeMethod_UpdateFlowgraph(impl SRPCFlowgraphResourceServiceServer, strm srpc.Stream) error

func (SRPCFlowgraphResourceServiceHandler) InvokeMethod_WatchFlowgraph 

func (SRPCFlowgraphResourceServiceHandler) InvokeMethod_WatchFlowgraph(impl SRPCFlowgraphResourceServiceServer, strm srpc.Stream) error

type SRPCFlowgraphResourceServiceServer 

type SRPCFlowgraphResourceServiceServer interface {
	// GetFlowgraph reads the current body and placement edges.
	GetFlowgraph(context.Context, *GetFlowgraphRequest) (*GetFlowgraphResponse, error)
	// UpdateFlowgraph applies one authored change atomically.
	UpdateFlowgraph(context.Context, *UpdateFlowgraphRequest) (*UpdateFlowgraphResponse, error)
	// WatchFlowgraph streams committed body and placement changes.
	WatchFlowgraph(*WatchFlowgraphRequest, SRPCFlowgraphResourceService_WatchFlowgraphStream) error
	// ListFlowgraphChanges reads the graph's revisions from the World changelog.
	ListFlowgraphChanges(context.Context, *ListFlowgraphChangesRequest) (*ListFlowgraphChangesResponse, error)
}

type SRPCFlowgraphResourceService_GetFlowgraphStream 

type SRPCFlowgraphResourceService_GetFlowgraphStream interface {
	srpc.Stream
}

type SRPCFlowgraphResourceService_ListFlowgraphChangesStream 

type SRPCFlowgraphResourceService_ListFlowgraphChangesStream interface {
	srpc.Stream
}

type SRPCFlowgraphResourceService_UpdateFlowgraphStream 

type SRPCFlowgraphResourceService_UpdateFlowgraphStream interface {
	srpc.Stream
}

type SRPCFlowgraphResourceService_WatchFlowgraphClient 

type SRPCFlowgraphResourceService_WatchFlowgraphClient interface {
	srpc.Stream
	Recv() (*WatchFlowgraphResponse, error)
	RecvTo(*WatchFlowgraphResponse) error
}

type SRPCFlowgraphResourceService_WatchFlowgraphStream 

type SRPCFlowgraphResourceService_WatchFlowgraphStream interface {
	srpc.Stream
	Send(*WatchFlowgraphResponse) error
	SendAndClose(*WatchFlowgraphResponse) error
}

type UpdateFlowgraphRequest 

type UpdateFlowgraphRequest struct {

	// Name replaces the display name when set.
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// SetNodes adds or replaces nodes by ID.
	SetNodes map[string]*FlowgraphNode `` /* 172-byte string literal not displayed */
	// RemoveNodeIds removes nodes, their placements, and their connections.
	RemoveNodeIds []string `protobuf:"bytes,3,rep,name=remove_node_ids,json=removeNodeIds,proto3" json:"removeNodeIds,omitempty"`
	// SetConnections adds or replaces connections by ID.
	SetConnections map[string]*FlowgraphConnection `` /* 190-byte string literal not displayed */
	// RemoveConnectionIds removes connections by ID.
	RemoveConnectionIds []string `protobuf:"bytes,5,rep,name=remove_connection_ids,json=removeConnectionIds,proto3" json:"removeConnectionIds,omitempty"`
	// SetPlacements adds or replaces placement edges by node ID.
	SetPlacements map[string]*FlowgraphPlacement `` /* 187-byte string literal not displayed */
	// RemovePlacementNodeIds removes placement edges without deleting the nodes.
	RemovePlacementNodeIds []string `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

UpdateFlowgraphRequest edits nodes, connections, and placement edges.

func (*UpdateFlowgraphRequest) CloneMessageVT 

func (m *UpdateFlowgraphRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*UpdateFlowgraphRequest) CloneVT 

func (m *UpdateFlowgraphRequest) CloneVT() *UpdateFlowgraphRequest

func (*UpdateFlowgraphRequest) EqualMessageVT 

func (this *UpdateFlowgraphRequest) EqualMessageVT(thatMsg any) bool

func (*UpdateFlowgraphRequest) EqualVT 

func (this *UpdateFlowgraphRequest) EqualVT(that *UpdateFlowgraphRequest) bool

func (*UpdateFlowgraphRequest) GetName 

func (x *UpdateFlowgraphRequest) GetName() string

func (*UpdateFlowgraphRequest) GetRemoveConnectionIds 

func (x *UpdateFlowgraphRequest) GetRemoveConnectionIds() []string

func (*UpdateFlowgraphRequest) GetRemoveNodeIds 

func (x *UpdateFlowgraphRequest) GetRemoveNodeIds() []string

func (*UpdateFlowgraphRequest) GetRemovePlacementNodeIds 

func (x *UpdateFlowgraphRequest) GetRemovePlacementNodeIds() []string

func (*UpdateFlowgraphRequest) GetSetConnections 

func (x *UpdateFlowgraphRequest) GetSetConnections() map[string]*FlowgraphConnection

func (*UpdateFlowgraphRequest) GetSetNodes 

func (x *UpdateFlowgraphRequest) GetSetNodes() map[string]*FlowgraphNode

func (*UpdateFlowgraphRequest) GetSetPlacements 

func (x *UpdateFlowgraphRequest) GetSetPlacements() map[string]*FlowgraphPlacement

func (*UpdateFlowgraphRequest) MarshalJSON 

func (x *UpdateFlowgraphRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the UpdateFlowgraphRequest to JSON.

func (*UpdateFlowgraphRequest) MarshalProtoJSON 

func (x *UpdateFlowgraphRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the UpdateFlowgraphRequest message to JSON.

func (*UpdateFlowgraphRequest) MarshalProtoText 

func (x *UpdateFlowgraphRequest) MarshalProtoText() string

func (*UpdateFlowgraphRequest) MarshalToSizedBufferVT 

func (m *UpdateFlowgraphRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateFlowgraphRequest) MarshalToVT 

func (m *UpdateFlowgraphRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateFlowgraphRequest) MarshalVT 

func (m *UpdateFlowgraphRequest) MarshalVT() (dAtA []byte, err error)

func (*UpdateFlowgraphRequest) ProtoMessage 

func (*UpdateFlowgraphRequest) ProtoMessage()

func (*UpdateFlowgraphRequest) Reset 

func (x *UpdateFlowgraphRequest) Reset()

func (*UpdateFlowgraphRequest) SizeVT 

func (m *UpdateFlowgraphRequest) SizeVT() (n int)

func (*UpdateFlowgraphRequest) String 

func (x *UpdateFlowgraphRequest) String() string

func (*UpdateFlowgraphRequest) UnmarshalJSON 

func (x *UpdateFlowgraphRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the UpdateFlowgraphRequest from JSON.

func (*UpdateFlowgraphRequest) UnmarshalProtoJSON 

func (x *UpdateFlowgraphRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the UpdateFlowgraphRequest message from JSON.

func (*UpdateFlowgraphRequest) UnmarshalVT 

func (m *UpdateFlowgraphRequest) UnmarshalVT(dAtA []byte) error

type UpdateFlowgraphRequest_SetConnectionsEntry 

type UpdateFlowgraphRequest_SetConnectionsEntry struct {
	Key   string               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *FlowgraphConnection `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateFlowgraphRequest_SetConnectionsEntry) GetKey 

func (x *UpdateFlowgraphRequest_SetConnectionsEntry) GetKey() string

func (*UpdateFlowgraphRequest_SetConnectionsEntry) GetValue 

func (x *UpdateFlowgraphRequest_SetConnectionsEntry) GetValue() *FlowgraphConnection

func (*UpdateFlowgraphRequest_SetConnectionsEntry) MarshalJSON 

func (x *UpdateFlowgraphRequest_SetConnectionsEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the UpdateFlowgraphRequest_SetConnectionsEntry to JSON.

func (*UpdateFlowgraphRequest_SetConnectionsEntry) MarshalProtoJSON 

func (x *UpdateFlowgraphRequest_SetConnectionsEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the UpdateFlowgraphRequest_SetConnectionsEntry message to JSON.

func (*UpdateFlowgraphRequest_SetConnectionsEntry) MarshalProtoText 

func (x *UpdateFlowgraphRequest_SetConnectionsEntry) MarshalProtoText() string

func (*UpdateFlowgraphRequest_SetConnectionsEntry) ProtoMessage 

func (*UpdateFlowgraphRequest_SetConnectionsEntry) ProtoMessage()

func (*UpdateFlowgraphRequest_SetConnectionsEntry) Reset 

func (x *UpdateFlowgraphRequest_SetConnectionsEntry) Reset()

func (*UpdateFlowgraphRequest_SetConnectionsEntry) String 

func (x *UpdateFlowgraphRequest_SetConnectionsEntry) String() string

func (*UpdateFlowgraphRequest_SetConnectionsEntry) UnmarshalJSON 

func (x *UpdateFlowgraphRequest_SetConnectionsEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the UpdateFlowgraphRequest_SetConnectionsEntry from JSON.

func (*UpdateFlowgraphRequest_SetConnectionsEntry) UnmarshalProtoJSON 

func (x *UpdateFlowgraphRequest_SetConnectionsEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the UpdateFlowgraphRequest_SetConnectionsEntry message from JSON.

type UpdateFlowgraphRequest_SetNodesEntry 

type UpdateFlowgraphRequest_SetNodesEntry struct {
	Key   string         `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *FlowgraphNode `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateFlowgraphRequest_SetNodesEntry) GetKey 

func (x *UpdateFlowgraphRequest_SetNodesEntry) GetKey() string

func (*UpdateFlowgraphRequest_SetNodesEntry) GetValue 

func (x *UpdateFlowgraphRequest_SetNodesEntry) GetValue() *FlowgraphNode

func (*UpdateFlowgraphRequest_SetNodesEntry) MarshalJSON 

func (x *UpdateFlowgraphRequest_SetNodesEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the UpdateFlowgraphRequest_SetNodesEntry to JSON.

func (*UpdateFlowgraphRequest_SetNodesEntry) MarshalProtoJSON 

func (x *UpdateFlowgraphRequest_SetNodesEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the UpdateFlowgraphRequest_SetNodesEntry message to JSON.

func (*UpdateFlowgraphRequest_SetNodesEntry) MarshalProtoText 

func (x *UpdateFlowgraphRequest_SetNodesEntry) MarshalProtoText() string

func (*UpdateFlowgraphRequest_SetNodesEntry) ProtoMessage 

func (*UpdateFlowgraphRequest_SetNodesEntry) ProtoMessage()

func (*UpdateFlowgraphRequest_SetNodesEntry) Reset 

func (x *UpdateFlowgraphRequest_SetNodesEntry) Reset()

func (*UpdateFlowgraphRequest_SetNodesEntry) String 

func (x *UpdateFlowgraphRequest_SetNodesEntry) String() string

func (*UpdateFlowgraphRequest_SetNodesEntry) UnmarshalJSON 

func (x *UpdateFlowgraphRequest_SetNodesEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the UpdateFlowgraphRequest_SetNodesEntry from JSON.

func (*UpdateFlowgraphRequest_SetNodesEntry) UnmarshalProtoJSON 

func (x *UpdateFlowgraphRequest_SetNodesEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the UpdateFlowgraphRequest_SetNodesEntry message from JSON.

type UpdateFlowgraphRequest_SetPlacementsEntry 

type UpdateFlowgraphRequest_SetPlacementsEntry struct {
	Key   string              `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *FlowgraphPlacement `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateFlowgraphRequest_SetPlacementsEntry) GetKey 

func (x *UpdateFlowgraphRequest_SetPlacementsEntry) GetKey() string

func (*UpdateFlowgraphRequest_SetPlacementsEntry) GetValue 

func (x *UpdateFlowgraphRequest_SetPlacementsEntry) GetValue() *FlowgraphPlacement

func (*UpdateFlowgraphRequest_SetPlacementsEntry) MarshalJSON 

func (x *UpdateFlowgraphRequest_SetPlacementsEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the UpdateFlowgraphRequest_SetPlacementsEntry to JSON.

func (*UpdateFlowgraphRequest_SetPlacementsEntry) MarshalProtoJSON 

func (x *UpdateFlowgraphRequest_SetPlacementsEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the UpdateFlowgraphRequest_SetPlacementsEntry message to JSON.

func (*UpdateFlowgraphRequest_SetPlacementsEntry) MarshalProtoText 

func (x *UpdateFlowgraphRequest_SetPlacementsEntry) MarshalProtoText() string

func (*UpdateFlowgraphRequest_SetPlacementsEntry) ProtoMessage 

func (*UpdateFlowgraphRequest_SetPlacementsEntry) ProtoMessage()

func (*UpdateFlowgraphRequest_SetPlacementsEntry) Reset 

func (x *UpdateFlowgraphRequest_SetPlacementsEntry) Reset()

func (*UpdateFlowgraphRequest_SetPlacementsEntry) String 

func (x *UpdateFlowgraphRequest_SetPlacementsEntry) String() string

func (*UpdateFlowgraphRequest_SetPlacementsEntry) UnmarshalJSON 

func (x *UpdateFlowgraphRequest_SetPlacementsEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the UpdateFlowgraphRequest_SetPlacementsEntry from JSON.

func (*UpdateFlowgraphRequest_SetPlacementsEntry) UnmarshalProtoJSON 

func (x *UpdateFlowgraphRequest_SetPlacementsEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the UpdateFlowgraphRequest_SetPlacementsEntry message from JSON.

type UpdateFlowgraphResponse 

type UpdateFlowgraphResponse struct {

	// Snapshot is the graph at this change's revision.
	Snapshot *FlowgraphSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

UpdateFlowgraphResponse contains the committed authored result.

func (*UpdateFlowgraphResponse) CloneMessageVT 

func (m *UpdateFlowgraphResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*UpdateFlowgraphResponse) CloneVT 

func (m *UpdateFlowgraphResponse) CloneVT() *UpdateFlowgraphResponse

func (*UpdateFlowgraphResponse) EqualMessageVT 

func (this *UpdateFlowgraphResponse) EqualMessageVT(thatMsg any) bool

func (*UpdateFlowgraphResponse) EqualVT 

func (this *UpdateFlowgraphResponse) EqualVT(that *UpdateFlowgraphResponse) bool

func (*UpdateFlowgraphResponse) GetSnapshot 

func (x *UpdateFlowgraphResponse) GetSnapshot() *FlowgraphSnapshot

func (*UpdateFlowgraphResponse) MarshalJSON 

func (x *UpdateFlowgraphResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the UpdateFlowgraphResponse to JSON.

func (*UpdateFlowgraphResponse) MarshalProtoJSON 

func (x *UpdateFlowgraphResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the UpdateFlowgraphResponse message to JSON.

func (*UpdateFlowgraphResponse) MarshalProtoText 

func (x *UpdateFlowgraphResponse) MarshalProtoText() string

func (*UpdateFlowgraphResponse) MarshalToSizedBufferVT 

func (m *UpdateFlowgraphResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UpdateFlowgraphResponse) MarshalToVT 

func (m *UpdateFlowgraphResponse) MarshalToVT(dAtA []byte) (int, error)

func (*UpdateFlowgraphResponse) MarshalVT 

func (m *UpdateFlowgraphResponse) MarshalVT() (dAtA []byte, err error)

func (*UpdateFlowgraphResponse) ProtoMessage 

func (*UpdateFlowgraphResponse) ProtoMessage()

func (*UpdateFlowgraphResponse) Reset 

func (x *UpdateFlowgraphResponse) Reset()

func (*UpdateFlowgraphResponse) SizeVT 

func (m *UpdateFlowgraphResponse) SizeVT() (n int)

func (*UpdateFlowgraphResponse) String 

func (x *UpdateFlowgraphResponse) String() string

func (*UpdateFlowgraphResponse) UnmarshalJSON 

func (x *UpdateFlowgraphResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the UpdateFlowgraphResponse from JSON.

func (*UpdateFlowgraphResponse) UnmarshalProtoJSON 

func (x *UpdateFlowgraphResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the UpdateFlowgraphResponse message from JSON.

func (*UpdateFlowgraphResponse) UnmarshalVT 

func (m *UpdateFlowgraphResponse) UnmarshalVT(dAtA []byte) error

type WatchFlowgraphRequest 

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

WatchFlowgraphRequest watches the mounted graph.

func (*WatchFlowgraphRequest) CloneMessageVT 

func (m *WatchFlowgraphRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WatchFlowgraphRequest) CloneVT 

func (m *WatchFlowgraphRequest) CloneVT() *WatchFlowgraphRequest

func (*WatchFlowgraphRequest) EqualMessageVT 

func (this *WatchFlowgraphRequest) EqualMessageVT(thatMsg any) bool

func (*WatchFlowgraphRequest) EqualVT 

func (this *WatchFlowgraphRequest) EqualVT(that *WatchFlowgraphRequest) bool

func (*WatchFlowgraphRequest) MarshalJSON 

func (x *WatchFlowgraphRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WatchFlowgraphRequest to JSON.

func (*WatchFlowgraphRequest) MarshalProtoJSON 

func (x *WatchFlowgraphRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WatchFlowgraphRequest message to JSON.

func (*WatchFlowgraphRequest) MarshalProtoText 

func (x *WatchFlowgraphRequest) MarshalProtoText() string

func (*WatchFlowgraphRequest) MarshalToSizedBufferVT 

func (m *WatchFlowgraphRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchFlowgraphRequest) MarshalToVT 

func (m *WatchFlowgraphRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WatchFlowgraphRequest) MarshalVT 

func (m *WatchFlowgraphRequest) MarshalVT() (dAtA []byte, err error)

func (*WatchFlowgraphRequest) ProtoMessage 

func (*WatchFlowgraphRequest) ProtoMessage()

func (*WatchFlowgraphRequest) Reset 

func (x *WatchFlowgraphRequest) Reset()

func (*WatchFlowgraphRequest) SizeVT 

func (m *WatchFlowgraphRequest) SizeVT() (n int)

func (*WatchFlowgraphRequest) String 

func (x *WatchFlowgraphRequest) String() string

func (*WatchFlowgraphRequest) UnmarshalJSON 

func (x *WatchFlowgraphRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WatchFlowgraphRequest from JSON.

func (*WatchFlowgraphRequest) UnmarshalProtoJSON 

func (x *WatchFlowgraphRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WatchFlowgraphRequest message from JSON.

func (*WatchFlowgraphRequest) UnmarshalVT 

func (m *WatchFlowgraphRequest) UnmarshalVT(dAtA []byte) error

type WatchFlowgraphResponse 

type WatchFlowgraphResponse struct {

	// Snapshot is the graph at the observed revision.
	Snapshot *FlowgraphSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

WatchFlowgraphResponse contains one committed graph snapshot.

func (*WatchFlowgraphResponse) CloneMessageVT 

func (m *WatchFlowgraphResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WatchFlowgraphResponse) CloneVT 

func (m *WatchFlowgraphResponse) CloneVT() *WatchFlowgraphResponse

func (*WatchFlowgraphResponse) EqualMessageVT 

func (this *WatchFlowgraphResponse) EqualMessageVT(thatMsg any) bool

func (*WatchFlowgraphResponse) EqualVT 

func (this *WatchFlowgraphResponse) EqualVT(that *WatchFlowgraphResponse) bool

func (*WatchFlowgraphResponse) GetSnapshot 

func (x *WatchFlowgraphResponse) GetSnapshot() *FlowgraphSnapshot

func (*WatchFlowgraphResponse) MarshalJSON 

func (x *WatchFlowgraphResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WatchFlowgraphResponse to JSON.

func (*WatchFlowgraphResponse) MarshalProtoJSON 

func (x *WatchFlowgraphResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WatchFlowgraphResponse message to JSON.

func (*WatchFlowgraphResponse) MarshalProtoText 

func (x *WatchFlowgraphResponse) MarshalProtoText() string

func (*WatchFlowgraphResponse) MarshalToSizedBufferVT 

func (m *WatchFlowgraphResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchFlowgraphResponse) MarshalToVT 

func (m *WatchFlowgraphResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WatchFlowgraphResponse) MarshalVT 

func (m *WatchFlowgraphResponse) MarshalVT() (dAtA []byte, err error)

func (*WatchFlowgraphResponse) ProtoMessage 

func (*WatchFlowgraphResponse) ProtoMessage()

func (*WatchFlowgraphResponse) Reset 

func (x *WatchFlowgraphResponse) Reset()

func (*WatchFlowgraphResponse) SizeVT 

func (m *WatchFlowgraphResponse) SizeVT() (n int)

func (*WatchFlowgraphResponse) String 

func (x *WatchFlowgraphResponse) String() string

func (*WatchFlowgraphResponse) UnmarshalJSON 

func (x *WatchFlowgraphResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WatchFlowgraphResponse from JSON.

func (*WatchFlowgraphResponse) UnmarshalProtoJSON 

func (x *WatchFlowgraphResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WatchFlowgraphResponse message from JSON.

func (*WatchFlowgraphResponse) UnmarshalVT 

func (m *WatchFlowgraphResponse) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Directories

Path Synopsis
Package flowgraph_registry carries plugin node declarations and compiler RPCs.
 Package flowgraph_registry carries plugin node declarations and compiler RPCs.
Package flowgraph_run drives the Steps of a Flowgraph run on a Forge Job.
 Package flowgraph_run drives the Steps of a Flowgraph run on a Forge Job.

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.