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

s4wave_flowgraph

package
v0.57.28 Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2026 License: Apache-2.0 Imports: 27 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"
)
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 CreateFlowgraphOpID = "flowgraph/create"

CreateFlowgraphOpID identifies the World operation that creates a Flowgraph.

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 (
	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.

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 LookupCreateFlowgraphOp 

func LookupCreateFlowgraphOp(_ context.Context, id string) (world.Operation, error)

LookupCreateFlowgraphOp resolves the Flowgraph creation operation.

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 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 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) ApplyWorldObjectOp 

func (o *CreateFlowgraphOp) ApplyWorldObjectOp(context.Context, *logrus.Entry, world.ObjectState, peer.ID) (bool, error)

ApplyWorldObjectOp rejects an operation that requires the enclosing World.

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) GetOperationTypeId 

func (o *CreateFlowgraphOp) GetOperationTypeId() string

GetOperationTypeId returns the operation's wire identifier.

func (*CreateFlowgraphOp) MarshalBlock 

func (o *CreateFlowgraphOp) MarshalBlock() ([]byte, error)

MarshalBlock encodes the creation request.

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) UnmarshalBlock 

func (o *CreateFlowgraphOp) UnmarshalBlock(data []byte) error

UnmarshalBlock decodes the creation request.

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) MarshalBlock 

func (g *Flowgraph) MarshalBlock() ([]byte, error)

MarshalBlock encodes the authored body.

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) UnmarshalBlock 

func (g *Flowgraph) UnmarshalBlock(data []byte) error

UnmarshalBlock decodes the authored body.

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.

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"`
	// 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) GetInputs 

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

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"`
	// TaskKey is the Task whose output arrived, or empty for a run's start.
	TaskKey string `protobuf:"bytes,3,opt,name=task_key,json=taskKey,proto3" json:"taskKey,omitempty"`
	// OutputName is the arriving output of that Task.
	OutputName string `protobuf:"bytes,4,opt,name=output_name,json=outputName,proto3" json:"outputName,omitempty"`
	// contains filtered or unexported fields
}

FlowgraphArrival is an output 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) GetNodeId 

func (x *FlowgraphArrival) GetNodeId() string

func (*FlowgraphArrival) GetOutputName 

func (x *FlowgraphArrival) GetOutputName() string

func (*FlowgraphArrival) GetPort 

func (x *FlowgraphArrival) GetPort() string

func (*FlowgraphArrival) GetTaskKey 

func (x *FlowgraphArrival) GetTaskKey() string

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 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 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"`
	// 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) 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, key string) *FlowgraphResource

NewFlowgraphResource constructs a graph Resource without retaining object handles.

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.

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"`
	// 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) 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) GetState 

func (x *FlowgraphRun) GetState() FlowgraphRunState

func (*FlowgraphRun) GetVisits 

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

func (*FlowgraphRun) MarshalBlock 

func (r *FlowgraphRun) MarshalBlock() ([]byte, error)

MarshalBlock encodes the run state.

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) UnmarshalBlock 

func (r *FlowgraphRun) UnmarshalBlock(data []byte) error

UnmarshalBlock decodes the run state.

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_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"`
	// 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 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.

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) 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_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"`
	// 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) 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 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.