module

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2023 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	GraphChangeOp_name = map[int32]string{
		0: "UPDATE",
		1: "DELETE",
	}
	GraphChangeOp_value = map[string]int32{
		"UPDATE": 0,
		"DELETE": 1,
	}
)

Enum value maps for GraphChangeOp.

View Source 
var File_cmp_proto protoreflect.FileDescriptor
View Source 
var File_graph_proto protoreflect.FileDescriptor
View Source 
var File_instance_proto protoreflect.FileDescriptor
View Source 
var File_mapport_proto protoreflect.FileDescriptor
View Source 
var File_message_proto protoreflect.FileDescriptor
View Source 
var File_module_version_proto protoreflect.FileDescriptor
View Source 
var File_node_proto protoreflect.FileDescriptor
View Source 
var File_platform_messages_proto protoreflect.FileDescriptor
View Source 
var File_port_config_proto protoreflect.FileDescriptor
View Source 
var File_runner_config_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BuildPushOptions 

type BuildPushOptions struct {
	Username string `protobuf:"bytes,1,opt,name=Username,proto3" json:"Username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=Password,proto3" json:"Password,omitempty"`
	Repo     string `protobuf:"bytes,3,opt,name=Repo,proto3" json:"Repo,omitempty"`
	Tag      string `protobuf:"bytes,4,opt,name=Tag,proto3" json:"Tag,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildPushOptions) Descriptor deprecated 

func (*BuildPushOptions) Descriptor() ([]byte, []int)

Deprecated: Use BuildPushOptions.ProtoReflect.Descriptor instead.

func (*BuildPushOptions) GetPassword 

func (x *BuildPushOptions) GetPassword() string

func (*BuildPushOptions) GetRepo 

func (x *BuildPushOptions) GetRepo() string

func (*BuildPushOptions) GetTag 

func (x *BuildPushOptions) GetTag() string

func (*BuildPushOptions) GetUsername 

func (x *BuildPushOptions) GetUsername() string

func (*BuildPushOptions) ProtoMessage 

func (*BuildPushOptions) ProtoMessage()

func (*BuildPushOptions) ProtoReflect 

func (x *BuildPushOptions) ProtoReflect() protoreflect.Message

func (*BuildPushOptions) Reset 

func (x *BuildPushOptions) Reset()

func (*BuildPushOptions) String 

func (x *BuildPushOptions) String() string

type Component 

type Component struct {
	Name        string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Description string   `protobuf:"bytes,3,opt,name=Description,proto3" json:"Description,omitempty"`
	Info        string   `protobuf:"bytes,4,opt,name=Info,proto3" json:"Info,omitempty"`
	Tags        []string `protobuf:"bytes,5,rep,name=Tags,proto3" json:"Tags,omitempty"`
	// contains filtered or unexported fields
}

func (*Component) Descriptor deprecated 

func (*Component) Descriptor() ([]byte, []int)

Deprecated: Use Component.ProtoReflect.Descriptor instead.

func (*Component) GetDescription 

func (x *Component) GetDescription() string

func (*Component) GetInfo 

func (x *Component) GetInfo() string

func (*Component) GetName 

func (x *Component) GetName() string

func (*Component) GetTags 

func (x *Component) GetTags() []string

func (*Component) ProtoMessage 

func (*Component) ProtoMessage()

func (*Component) ProtoReflect 

func (x *Component) ProtoReflect() protoreflect.Message

func (*Component) Reset 

func (x *Component) Reset()

func (*Component) String 

func (x *Component) String() string

type ConfigureInstanceRequest 

type ConfigureInstanceRequest struct {
	FlowID      string `protobuf:"bytes,1,opt,name=FlowID,proto3" json:"FlowID,omitempty"`
	ComponentID string `protobuf:"bytes,2,opt,name=ComponentID,proto3" json:"ComponentID,omitempty"`
	//string InstanceName = 3;
	InstanceID   string     `protobuf:"bytes,4,opt,name=InstanceID,proto3" json:"InstanceID,omitempty"` // list of port mapping with nats subjects
	Destinations []*MapPort `protobuf:"bytes,6,rep,name=Destinations,proto3" json:"Destinations,omitempty"`
	Revision     int64      `protobuf:"varint,7,opt,name=Revision,proto3" json:"Revision,omitempty"`
	//string InstanceLabel = 8;
	PortConfigs []*PortConfig    `protobuf:"bytes,9,rep,name=PortConfigs,proto3" json:"PortConfigs,omitempty"`
	Run         bool             `protobuf:"varint,10,opt,name=Run,proto3" json:"Run,omitempty"`
	Data        *structpb.Struct `protobuf:"bytes,11,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureInstanceRequest) Descriptor deprecated 

func (*ConfigureInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureInstanceRequest.ProtoReflect.Descriptor instead.

func (*ConfigureInstanceRequest) GetComponentID 

func (x *ConfigureInstanceRequest) GetComponentID() string

func (*ConfigureInstanceRequest) GetData 

func (x *ConfigureInstanceRequest) GetData() *structpb.Struct

func (*ConfigureInstanceRequest) GetDestinations 

func (x *ConfigureInstanceRequest) GetDestinations() []*MapPort

func (*ConfigureInstanceRequest) GetFlowID 

func (x *ConfigureInstanceRequest) GetFlowID() string

func (*ConfigureInstanceRequest) GetInstanceID 

func (x *ConfigureInstanceRequest) GetInstanceID() string

func (*ConfigureInstanceRequest) GetPortConfigs 

func (x *ConfigureInstanceRequest) GetPortConfigs() []*PortConfig

func (*ConfigureInstanceRequest) GetRevision 

func (x *ConfigureInstanceRequest) GetRevision() int64

func (*ConfigureInstanceRequest) GetRun 

func (x *ConfigureInstanceRequest) GetRun() bool

func (*ConfigureInstanceRequest) ProtoMessage 

func (*ConfigureInstanceRequest) ProtoMessage()

func (*ConfigureInstanceRequest) ProtoReflect 

func (x *ConfigureInstanceRequest) ProtoReflect() protoreflect.Message

func (*ConfigureInstanceRequest) Reset 

func (x *ConfigureInstanceRequest) Reset()

func (*ConfigureInstanceRequest) String 

func (x *ConfigureInstanceRequest) String() string

type ConfigureInstanceResponse 

type ConfigureInstanceResponse struct {
	IsRunning bool           `protobuf:"varint,2,opt,name=IsRunning,proto3" json:"IsRunning,omitempty"`
	HasError  bool           `protobuf:"varint,3,opt,name=HasError,proto3" json:"HasError,omitempty"`
	Error     string         `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	Changes   []*GraphChange `protobuf:"bytes,5,rep,name=Changes,proto3" json:"Changes,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureInstanceResponse) Descriptor deprecated 

func (*ConfigureInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureInstanceResponse.ProtoReflect.Descriptor instead.

func (*ConfigureInstanceResponse) GetChanges 

func (x *ConfigureInstanceResponse) GetChanges() []*GraphChange

func (*ConfigureInstanceResponse) GetError 

func (x *ConfigureInstanceResponse) GetError() string

func (*ConfigureInstanceResponse) GetHasError 

func (x *ConfigureInstanceResponse) GetHasError() bool

func (*ConfigureInstanceResponse) GetIsRunning 

func (x *ConfigureInstanceResponse) GetIsRunning() bool

func (*ConfigureInstanceResponse) ProtoMessage 

func (*ConfigureInstanceResponse) ProtoMessage()

func (*ConfigureInstanceResponse) ProtoReflect 

func (x *ConfigureInstanceResponse) ProtoReflect() protoreflect.Message

func (*ConfigureInstanceResponse) Reset 

func (x *ConfigureInstanceResponse) Reset()

func (*ConfigureInstanceResponse) String 

func (x *ConfigureInstanceResponse) String() string

type Edge 

type Edge struct {
	Source       string `protobuf:"bytes,1,opt,name=Source,proto3" json:"Source,omitempty"`
	Target       string `protobuf:"bytes,2,opt,name=Target,proto3" json:"Target,omitempty"`
	SourceHandle string `protobuf:"bytes,3,opt,name=SourceHandle,proto3" json:"SourceHandle,omitempty"`
	TargetHandle string `protobuf:"bytes,4,opt,name=TargetHandle,proto3" json:"TargetHandle,omitempty"`
	// contains filtered or unexported fields
}

func (*Edge) Descriptor deprecated 

func (*Edge) Descriptor() ([]byte, []int)

Deprecated: Use Edge.ProtoReflect.Descriptor instead.

func (*Edge) GetSource 

func (x *Edge) GetSource() string

func (*Edge) GetSourceHandle 

func (x *Edge) GetSourceHandle() string

func (*Edge) GetTarget 

func (x *Edge) GetTarget() string

func (*Edge) GetTargetHandle 

func (x *Edge) GetTargetHandle() string

func (*Edge) ProtoMessage 

func (*Edge) ProtoMessage()

func (*Edge) ProtoReflect 

func (x *Edge) ProtoReflect() protoreflect.Message

func (*Edge) Reset 

func (x *Edge) Reset()

func (*Edge) String 

func (x *Edge) String() string

type GetManifestRequest 

type GetManifestRequest struct {
	ServerKey       string `protobuf:"bytes,1,opt,name=ServerKey,proto3" json:"ServerKey,omitempty"`       // from ags
	DevMode         bool   `protobuf:"varint,2,opt,name=DevMode,proto3" json:"DevMode,omitempty"`          // not sure about it
	DeveloperKey    string `protobuf:"bytes,3,opt,name=DeveloperKey,proto3" json:"DeveloperKey,omitempty"` //if dev mode is on, developer_key is required, maybe if no modVerID
	Version         string `protobuf:"bytes,6,opt,name=Version,proto3" json:"Version,omitempty"`
	ModuleVersionID string `protobuf:"bytes,7,opt,name=ModuleVersionID,proto3" json:"ModuleVersionID,omitempty"` // from ldflags if any
	// contains filtered or unexported fields
}

func (*GetManifestRequest) Descriptor deprecated 

func (*GetManifestRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetManifestRequest.ProtoReflect.Descriptor instead.

func (*GetManifestRequest) GetDevMode 

func (x *GetManifestRequest) GetDevMode() bool

func (*GetManifestRequest) GetDeveloperKey 

func (x *GetManifestRequest) GetDeveloperKey() string

func (*GetManifestRequest) GetModuleVersionID 

func (x *GetManifestRequest) GetModuleVersionID() string

func (*GetManifestRequest) GetServerKey 

func (x *GetManifestRequest) GetServerKey() string

func (*GetManifestRequest) GetVersion 

func (x *GetManifestRequest) GetVersion() string

func (*GetManifestRequest) ProtoMessage 

func (*GetManifestRequest) ProtoMessage()

func (*GetManifestRequest) ProtoReflect 

func (x *GetManifestRequest) ProtoReflect() protoreflect.Message

func (*GetManifestRequest) Reset 

func (x *GetManifestRequest) Reset()

func (*GetManifestRequest) String 

func (x *GetManifestRequest) String() string

type GetManifestResponse 

type GetManifestResponse struct {
	RunnerConfig *RunnerConfig               `protobuf:"bytes,1,opt,name=RunnerConfig,proto3" json:"RunnerConfig,omitempty"`
	Modules      []*ModuleVersion            `protobuf:"bytes,2,rep,name=Modules,proto3" json:"Modules,omitempty"`     // empty if dev mode is on
	Instances    []*ConfigureInstanceRequest `protobuf:"bytes,3,rep,name=Instances,proto3" json:"Instances,omitempty"` // instances to bootstrap
	Error        string                      `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

@todo - nats auth keys?

func (*GetManifestResponse) Descriptor deprecated 

func (*GetManifestResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetManifestResponse.ProtoReflect.Descriptor instead.

func (*GetManifestResponse) GetError added in v0.0.3 

func (x *GetManifestResponse) GetError() string

func (*GetManifestResponse) GetInstances 

func (x *GetManifestResponse) GetInstances() []*ConfigureInstanceRequest

func (*GetManifestResponse) GetModules 

func (x *GetManifestResponse) GetModules() []*ModuleVersion

func (*GetManifestResponse) GetRunnerConfig 

func (x *GetManifestResponse) GetRunnerConfig() *RunnerConfig

func (*GetManifestResponse) ProtoMessage 

func (*GetManifestResponse) ProtoMessage()

func (*GetManifestResponse) ProtoReflect 

func (x *GetManifestResponse) ProtoReflect() protoreflect.Message

func (*GetManifestResponse) Reset 

func (x *GetManifestResponse) Reset()

func (*GetManifestResponse) String 

func (x *GetManifestResponse) String() string

type GraphChange 

type GraphChange struct {
	Elements []*GraphElement    `protobuf:"bytes,1,rep,name=Elements,proto3" json:"Elements,omitempty"`
	Op       GraphChangeOp      `protobuf:"varint,2,opt,name=Op,proto3,enum=server.GraphChangeOp" json:"Op,omitempty"`
	Server   *GraphChangeServer `protobuf:"bytes,3,opt,name=Server,proto3" json:"Server,omitempty"`
	Module   *GraphChangeModule `protobuf:"bytes,4,opt,name=Module,proto3" json:"Module,omitempty"`
	// contains filtered or unexported fields
}

func (*GraphChange) Descriptor deprecated 

func (*GraphChange) Descriptor() ([]byte, []int)

Deprecated: Use GraphChange.ProtoReflect.Descriptor instead.

func (*GraphChange) GetElements 

func (x *GraphChange) GetElements() []*GraphElement

func (*GraphChange) GetModule 

func (x *GraphChange) GetModule() *GraphChangeModule

func (*GraphChange) GetOp 

func (x *GraphChange) GetOp() GraphChangeOp

func (*GraphChange) GetServer 

func (x *GraphChange) GetServer() *GraphChangeServer

func (*GraphChange) ProtoMessage 

func (*GraphChange) ProtoMessage()

func (*GraphChange) ProtoReflect 

func (x *GraphChange) ProtoReflect() protoreflect.Message

func (*GraphChange) Reset 

func (x *GraphChange) Reset()

func (*GraphChange) String 

func (x *GraphChange) String() string

type GraphChangeModule 

type GraphChangeModule struct {
	Name      string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Version   string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	VersionID string `protobuf:"bytes,3,opt,name=VersionID,proto3" json:"VersionID,omitempty"`
	// contains filtered or unexported fields
}

func (*GraphChangeModule) Descriptor deprecated 

func (*GraphChangeModule) Descriptor() ([]byte, []int)

Deprecated: Use GraphChangeModule.ProtoReflect.Descriptor instead.

func (*GraphChangeModule) GetName 

func (x *GraphChangeModule) GetName() string

func (*GraphChangeModule) GetVersion 

func (x *GraphChangeModule) GetVersion() string

func (*GraphChangeModule) GetVersionID 

func (x *GraphChangeModule) GetVersionID() string

func (*GraphChangeModule) ProtoMessage 

func (*GraphChangeModule) ProtoMessage()

func (*GraphChangeModule) ProtoReflect 

func (x *GraphChangeModule) ProtoReflect() protoreflect.Message

func (*GraphChangeModule) Reset 

func (x *GraphChangeModule) Reset()

func (*GraphChangeModule) String 

func (x *GraphChangeModule) String() string

type GraphChangeOp 

type GraphChangeOp int32
const (
	GraphChangeOp_UPDATE GraphChangeOp = 0
	GraphChangeOp_DELETE GraphChangeOp = 1
)

func (GraphChangeOp) Descriptor 

func (GraphChangeOp) Descriptor() protoreflect.EnumDescriptor

func (GraphChangeOp) Enum 

func (x GraphChangeOp) Enum() *GraphChangeOp

func (GraphChangeOp) EnumDescriptor deprecated 

func (GraphChangeOp) EnumDescriptor() ([]byte, []int)

Deprecated: Use GraphChangeOp.Descriptor instead.

func (GraphChangeOp) Number 

func (x GraphChangeOp) Number() protoreflect.EnumNumber

func (GraphChangeOp) String 

func (x GraphChangeOp) String() string

func (GraphChangeOp) Type 

func (GraphChangeOp) Type() protoreflect.EnumType

type GraphChangeServer 

type GraphChangeServer struct {
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*GraphChangeServer) Descriptor deprecated 

func (*GraphChangeServer) Descriptor() ([]byte, []int)

Deprecated: Use GraphChangeServer.ProtoReflect.Descriptor instead.

func (*GraphChangeServer) GetID 

func (x *GraphChangeServer) GetID() string

func (*GraphChangeServer) ProtoMessage 

func (*GraphChangeServer) ProtoMessage()

func (*GraphChangeServer) ProtoReflect 

func (x *GraphChangeServer) ProtoReflect() protoreflect.Message

func (*GraphChangeServer) Reset 

func (x *GraphChangeServer) Reset()

func (*GraphChangeServer) String 

func (x *GraphChangeServer) String() string

type GraphElement 

type GraphElement struct {
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	//string FlowID = 2;
	Node     *Node `protobuf:"bytes,3,opt,name=Node,proto3" json:"Node,omitempty"`
	Edge     *Edge `protobuf:"bytes,4,opt,name=Edge,proto3" json:"Edge,omitempty"`
	Revision int64 `protobuf:"varint,5,opt,name=Revision,proto3" json:"Revision,omitempty"`
	// contains filtered or unexported fields
}

any element of an element of the graph (using for storage)

func (*GraphElement) Descriptor deprecated 

func (*GraphElement) Descriptor() ([]byte, []int)

Deprecated: Use GraphElement.ProtoReflect.Descriptor instead.

func (*GraphElement) GetEdge 

func (x *GraphElement) GetEdge() *Edge

func (*GraphElement) GetID 

func (x *GraphElement) GetID() string

func (*GraphElement) GetNode 

func (x *GraphElement) GetNode() *Node

func (*GraphElement) GetRevision 

func (x *GraphElement) GetRevision() int64

func (*GraphElement) ProtoMessage 

func (*GraphElement) ProtoMessage()

func (*GraphElement) ProtoReflect 

func (x *GraphElement) ProtoReflect() protoreflect.Message

func (*GraphElement) Reset 

func (x *GraphElement) Reset()

func (*GraphElement) String 

func (x *GraphElement) String() string

type MapPort 

type MapPort struct {
	From   string `protobuf:"bytes,1,opt,name=From,proto3" json:"From,omitempty"` // full port name name
	To     string `protobuf:"bytes,2,opt,name=To,proto3" json:"To,omitempty"`
	EdgeID string `protobuf:"bytes,3,opt,name=EdgeID,proto3" json:"EdgeID,omitempty"`
	// contains filtered or unexported fields
}

func (*MapPort) Descriptor deprecated 

func (*MapPort) Descriptor() ([]byte, []int)

Deprecated: Use MapPort.ProtoReflect.Descriptor instead.

func (*MapPort) GetEdgeID 

func (x *MapPort) GetEdgeID() string

func (*MapPort) GetFrom 

func (x *MapPort) GetFrom() string

func (*MapPort) GetTo 

func (x *MapPort) GetTo() string

func (*MapPort) ProtoMessage 

func (*MapPort) ProtoMessage()

func (*MapPort) ProtoReflect 

func (x *MapPort) ProtoReflect() protoreflect.Message

func (*MapPort) Reset 

func (x *MapPort) Reset()

func (*MapPort) String 

func (x *MapPort) String() string

type MessageRequest 

type MessageRequest struct {
	ID       string            `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	From     string            `protobuf:"bytes,2,opt,name=From,proto3" json:"From,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	Payload  []byte            `protobuf:"bytes,5,opt,name=Payload,proto3" json:"Payload,omitempty"`
	EdgeID   string            `protobuf:"bytes,6,opt,name=EdgeID,proto3" json:"EdgeID,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageRequest) Descriptor deprecated 

func (*MessageRequest) Descriptor() ([]byte, []int)

Deprecated: Use MessageRequest.ProtoReflect.Descriptor instead.

func (*MessageRequest) GetEdgeID 

func (x *MessageRequest) GetEdgeID() string

func (*MessageRequest) GetFrom 

func (x *MessageRequest) GetFrom() string

func (*MessageRequest) GetID 

func (x *MessageRequest) GetID() string

func (*MessageRequest) GetMetadata 

func (x *MessageRequest) GetMetadata() map[string]string

func (*MessageRequest) GetPayload 

func (x *MessageRequest) GetPayload() []byte

func (*MessageRequest) ProtoMessage 

func (*MessageRequest) ProtoMessage()

func (*MessageRequest) ProtoReflect 

func (x *MessageRequest) ProtoReflect() protoreflect.Message

func (*MessageRequest) Reset 

func (x *MessageRequest) Reset()

func (*MessageRequest) String 

func (x *MessageRequest) String() string

type MessageResponse 

type MessageResponse struct {
	Data     []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	HasError bool   `protobuf:"varint,3,opt,name=HasError,proto3" json:"HasError,omitempty"`
	Error    string `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageResponse) Descriptor deprecated 

func (*MessageResponse) Descriptor() ([]byte, []int)

Deprecated: Use MessageResponse.ProtoReflect.Descriptor instead.

func (*MessageResponse) GetData 

func (x *MessageResponse) GetData() []byte

func (*MessageResponse) GetError 

func (x *MessageResponse) GetError() string

func (*MessageResponse) GetHasError 

func (x *MessageResponse) GetHasError() bool

func (*MessageResponse) ProtoMessage 

func (*MessageResponse) ProtoMessage()

func (*MessageResponse) ProtoReflect 

func (x *MessageResponse) ProtoReflect() protoreflect.Message

func (*MessageResponse) Reset 

func (x *MessageResponse) Reset()

func (*MessageResponse) String 

func (x *MessageResponse) String() string

type ModuleVersion 

type ModuleVersion struct {
	ID         string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ModuleName string `protobuf:"bytes,2,opt,name=ModuleName,proto3" json:"ModuleName,omitempty"`
	Version    string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleVersion) Descriptor deprecated 

func (*ModuleVersion) Descriptor() ([]byte, []int)

Deprecated: Use ModuleVersion.ProtoReflect.Descriptor instead.

func (*ModuleVersion) GetID 

func (x *ModuleVersion) GetID() string

func (*ModuleVersion) GetModuleName 

func (x *ModuleVersion) GetModuleName() string

func (*ModuleVersion) GetVersion 

func (x *ModuleVersion) GetVersion() string

func (*ModuleVersion) ProtoMessage 

func (*ModuleVersion) ProtoMessage()

func (*ModuleVersion) ProtoReflect 

func (x *ModuleVersion) ProtoReflect() protoreflect.Message

func (*ModuleVersion) Reset 

func (x *ModuleVersion) Reset()

func (*ModuleVersion) String 

func (x *ModuleVersion) String() string

type Node 

type Node struct {

	//string Label = 1;
	// if implements runnable interface
	Runnable    bool        `protobuf:"varint,2,opt,name=Runnable,proto3" json:"Runnable,omitempty"`
	ComponentID string      `protobuf:"bytes,5,opt,name=ComponentID,proto3" json:"ComponentID,omitempty"`
	Position    *Position   `protobuf:"bytes,6,opt,name=Position,proto3" json:"Position,omitempty"`
	Ports       []*NodePort `protobuf:"bytes,7,rep,name=Ports,proto3" json:"Ports,omitempty"`
	// if we want to see its running
	Run          bool          `protobuf:"varint,8,opt,name=Run,proto3" json:"Run,omitempty"` // connection between other nodes
	Destinations []*MapPort    `protobuf:"bytes,9,rep,name=Destinations,proto3" json:"Destinations,omitempty"`
	PortConfigs  []*PortConfig `protobuf:"bytes,13,rep,name=PortConfigs,proto3" json:"PortConfigs,omitempty"`
	//string Name = 10;
	Data *structpb.Struct `protobuf:"bytes,11,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

func (*Node) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetComponentID 

func (x *Node) GetComponentID() string

func (*Node) GetData 

func (x *Node) GetData() *structpb.Struct

func (*Node) GetDestinations 

func (x *Node) GetDestinations() []*MapPort

func (*Node) GetPortConfigs 

func (x *Node) GetPortConfigs() []*PortConfig

func (*Node) GetPorts 

func (x *Node) GetPorts() []*NodePort

func (*Node) GetPosition 

func (x *Node) GetPosition() *Position

func (*Node) GetRun 

func (x *Node) GetRun() bool

func (*Node) GetRunnable 

func (x *Node) GetRunnable() bool

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodePort 

type NodePort struct {
	Source     bool   `protobuf:"varint,1,opt,name=Source,proto3" json:"Source,omitempty"`
	Position   int32  `protobuf:"varint,2,opt,name=Position,proto3" json:"Position,omitempty"`
	PortName   string `protobuf:"bytes,3,opt,name=PortName,proto3" json:"PortName,omitempty"`
	Label      string `protobuf:"bytes,4,opt,name=Label,proto3" json:"Label,omitempty"`
	IsSettings bool   `protobuf:"varint,5,opt,name=IsSettings,proto3" json:"IsSettings,omitempty"`
	// schema generated from DTO
	SchemaDefault []byte `protobuf:"bytes,6,opt,name=SchemaDefault,proto3" json:"SchemaDefault,omitempty"`
	// schema with adjustments using schema editor
	Status bool `protobuf:"varint,7,opt,name=Status,proto3" json:"Status,omitempty"`
	// default setup of the port/handle
	//bytes Configuration = 8;
	ConfigurationDefault []byte `protobuf:"bytes,9,opt,name=ConfigurationDefault,proto3" json:"ConfigurationDefault,omitempty"`
	// contains filtered or unexported fields
}

func (*NodePort) Descriptor deprecated 

func (*NodePort) Descriptor() ([]byte, []int)

Deprecated: Use NodePort.ProtoReflect.Descriptor instead.

func (*NodePort) GetConfigurationDefault 

func (x *NodePort) GetConfigurationDefault() []byte

func (*NodePort) GetIsSettings 

func (x *NodePort) GetIsSettings() bool

func (*NodePort) GetLabel 

func (x *NodePort) GetLabel() string

func (*NodePort) GetPortName 

func (x *NodePort) GetPortName() string

func (*NodePort) GetPosition 

func (x *NodePort) GetPosition() int32

func (*NodePort) GetSchemaDefault 

func (x *NodePort) GetSchemaDefault() []byte

func (*NodePort) GetSource 

func (x *NodePort) GetSource() bool

func (*NodePort) GetStatus 

func (x *NodePort) GetStatus() bool

func (*NodePort) ProtoMessage 

func (*NodePort) ProtoMessage()

func (*NodePort) ProtoReflect 

func (x *NodePort) ProtoReflect() protoreflect.Message

func (*NodePort) Reset 

func (x *NodePort) Reset()

func (*NodePort) String 

func (x *NodePort) String() string

type PortConfig 

type PortConfig struct {
	From                 string `protobuf:"bytes,1,opt,name=From,proto3" json:"From,omitempty"`                                 // full port name, may be empty for a node's own config
	PortName             string `protobuf:"bytes,2,opt,name=PortName,proto3" json:"PortName,omitempty"`                         // port name of a node being configured
	Configuration        []byte `protobuf:"bytes,3,opt,name=Configuration,proto3" json:"Configuration,omitempty"`               // json encoded data, not necessarily an object
	Schema               []byte `protobuf:"bytes,5,opt,name=Schema,proto3" json:"Schema,omitempty"`                             // port schema which might be customized
	SchemaDefault        []byte `protobuf:"bytes,6,opt,name=SchemaDefault,proto3" json:"SchemaDefault,omitempty"`               // default json schema of the port (for the reset)
	ConfigurationDefault []byte `protobuf:"bytes,7,opt,name=ConfigurationDefault,proto3" json:"ConfigurationDefault,omitempty"` // default configuration of the port (for the reset)
	// contains filtered or unexported fields
}

func (*PortConfig) Descriptor deprecated 

func (*PortConfig) Descriptor() ([]byte, []int)

Deprecated: Use PortConfig.ProtoReflect.Descriptor instead.

func (*PortConfig) GetConfiguration 

func (x *PortConfig) GetConfiguration() []byte

func (*PortConfig) GetConfigurationDefault 

func (x *PortConfig) GetConfigurationDefault() []byte

func (*PortConfig) GetFrom 

func (x *PortConfig) GetFrom() string

func (*PortConfig) GetPortName 

func (x *PortConfig) GetPortName() string

func (*PortConfig) GetSchema 

func (x *PortConfig) GetSchema() []byte

func (*PortConfig) GetSchemaDefault 

func (x *PortConfig) GetSchemaDefault() []byte

func (*PortConfig) ProtoMessage 

func (*PortConfig) ProtoMessage()

func (*PortConfig) ProtoReflect 

func (x *PortConfig) ProtoReflect() protoreflect.Message

func (*PortConfig) Reset 

func (x *PortConfig) Reset()

func (*PortConfig) String 

func (x *PortConfig) String() string

type Position 

type Position struct {
	X    int32 `protobuf:"varint,1,opt,name=X,proto3" json:"X,omitempty"`
	Y    int32 `protobuf:"varint,2,opt,name=Y,proto3" json:"Y,omitempty"`
	Spin int32 `protobuf:"varint,3,opt,name=Spin,proto3" json:"Spin,omitempty"`
	// contains filtered or unexported fields
}

func (*Position) Descriptor deprecated 

func (*Position) Descriptor() ([]byte, []int)

Deprecated: Use Position.ProtoReflect.Descriptor instead.

func (*Position) GetSpin 

func (x *Position) GetSpin() int32

func (*Position) GetX 

func (x *Position) GetX() int32

func (*Position) GetY 

func (x *Position) GetY() int32

func (*Position) ProtoMessage 

func (*Position) ProtoMessage()

func (*Position) ProtoReflect 

func (x *Position) ProtoReflect() protoreflect.Message

func (*Position) Reset 

func (x *Position) Reset()

func (*Position) String 

func (x *Position) String() string

type PublishModuleRequest 

type PublishModuleRequest struct {
	Name         string       `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`                 // by publisher from module info
	Description  string       `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`   // by publisher from module info
	Info         string       `protobuf:"bytes,3,opt,name=Info,proto3" json:"Info,omitempty"`                 // from readme.md
	DeveloperKey string       `protobuf:"bytes,4,opt,name=DeveloperKey,proto3" json:"DeveloperKey,omitempty"` // from CI
	Version      string       `protobuf:"bytes,8,opt,name=Version,proto3" json:"Version,omitempty"`           // by publisher
	Components   []*Component `protobuf:"bytes,13,rep,name=Components,proto3" json:"Components,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishModuleRequest) Descriptor deprecated 

func (*PublishModuleRequest) Descriptor() ([]byte, []int)

Deprecated: Use PublishModuleRequest.ProtoReflect.Descriptor instead.

func (*PublishModuleRequest) GetComponents 

func (x *PublishModuleRequest) GetComponents() []*Component

func (*PublishModuleRequest) GetDescription 

func (x *PublishModuleRequest) GetDescription() string

func (*PublishModuleRequest) GetDeveloperKey 

func (x *PublishModuleRequest) GetDeveloperKey() string

func (*PublishModuleRequest) GetInfo 

func (x *PublishModuleRequest) GetInfo() string

func (*PublishModuleRequest) GetName 

func (x *PublishModuleRequest) GetName() string

func (*PublishModuleRequest) GetVersion 

func (x *PublishModuleRequest) GetVersion() string

func (*PublishModuleRequest) ProtoMessage 

func (*PublishModuleRequest) ProtoMessage()

func (*PublishModuleRequest) ProtoReflect 

func (x *PublishModuleRequest) ProtoReflect() protoreflect.Message

func (*PublishModuleRequest) Reset 

func (x *PublishModuleRequest) Reset()

func (*PublishModuleRequest) String 

func (x *PublishModuleRequest) String() string

type PublishModuleResponse 

type PublishModuleResponse struct {
	Module  *ModuleVersion    `protobuf:"bytes,1,opt,name=Module,proto3" json:"Module,omitempty"`
	Options *BuildPushOptions `protobuf:"bytes,2,opt,name=Options,proto3" json:"Options,omitempty"`
	Error   string            `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishModuleResponse) Descriptor deprecated 

func (*PublishModuleResponse) Descriptor() ([]byte, []int)

Deprecated: Use PublishModuleResponse.ProtoReflect.Descriptor instead.

func (*PublishModuleResponse) GetError added in v0.0.3 

func (x *PublishModuleResponse) GetError() string

func (*PublishModuleResponse) GetModule 

func (x *PublishModuleResponse) GetModule() *ModuleVersion

func (*PublishModuleResponse) GetOptions 

func (x *PublishModuleResponse) GetOptions() *BuildPushOptions

func (*PublishModuleResponse) ProtoMessage 

func (*PublishModuleResponse) ProtoMessage()

func (*PublishModuleResponse) ProtoReflect 

func (x *PublishModuleResponse) ProtoReflect() protoreflect.Message

func (*PublishModuleResponse) Reset 

func (x *PublishModuleResponse) Reset()

func (*PublishModuleResponse) String 

func (x *PublishModuleResponse) String() string

type RunnerConfig 

type RunnerConfig struct {
	ServerID    string `protobuf:"bytes,1,opt,name=ServerID,proto3" json:"ServerID,omitempty"`
	DevMode     bool   `protobuf:"varint,2,opt,name=DevMode,proto3" json:"DevMode,omitempty"`
	WorkspaceID string `protobuf:"bytes,4,opt,name=WorkspaceID,proto3" json:"WorkspaceID,omitempty"`
	// contains filtered or unexported fields
}

func (*RunnerConfig) Descriptor deprecated 

func (*RunnerConfig) Descriptor() ([]byte, []int)

Deprecated: Use RunnerConfig.ProtoReflect.Descriptor instead.

func (*RunnerConfig) GetDevMode 

func (x *RunnerConfig) GetDevMode() bool

func (*RunnerConfig) GetServerID 

func (x *RunnerConfig) GetServerID() string

func (*RunnerConfig) GetWorkspaceID 

func (x *RunnerConfig) GetWorkspaceID() string

func (*RunnerConfig) ProtoMessage 

func (*RunnerConfig) ProtoMessage()

func (*RunnerConfig) ProtoReflect 

func (x *RunnerConfig) ProtoReflect() protoreflect.Message

func (*RunnerConfig) Reset 

func (x *RunnerConfig) Reset()

func (*RunnerConfig) String 

func (x *RunnerConfig) String() string

type UpdateModuleVersionRequest 

type UpdateModuleVersionRequest struct {
	ID   string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Repo string `protobuf:"bytes,2,opt,name=Repo,proto3" json:"Repo,omitempty"`
	Tag  string `protobuf:"bytes,3,opt,name=Tag,proto3" json:"Tag,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateModuleVersionRequest) Descriptor deprecated 

func (*UpdateModuleVersionRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateModuleVersionRequest.ProtoReflect.Descriptor instead.

func (*UpdateModuleVersionRequest) GetID 

func (x *UpdateModuleVersionRequest) GetID() string

func (*UpdateModuleVersionRequest) GetRepo 

func (x *UpdateModuleVersionRequest) GetRepo() string

func (*UpdateModuleVersionRequest) GetTag 

func (x *UpdateModuleVersionRequest) GetTag() string

func (*UpdateModuleVersionRequest) ProtoMessage 

func (*UpdateModuleVersionRequest) ProtoMessage()

func (*UpdateModuleVersionRequest) ProtoReflect 

func (x *UpdateModuleVersionRequest) ProtoReflect() protoreflect.Message

func (*UpdateModuleVersionRequest) Reset 

func (x *UpdateModuleVersionRequest) Reset()

func (*UpdateModuleVersionRequest) String 

func (x *UpdateModuleVersionRequest) String() string

type UpdateModuleVersionResponse 

type UpdateModuleVersionResponse struct {
	Error string `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateModuleVersionResponse) Descriptor deprecated 

func (*UpdateModuleVersionResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateModuleVersionResponse.ProtoReflect.Descriptor instead.

func (*UpdateModuleVersionResponse) GetError added in v0.0.3 

func (x *UpdateModuleVersionResponse) GetError() string

func (*UpdateModuleVersionResponse) ProtoMessage 

func (*UpdateModuleVersionResponse) ProtoMessage()

func (*UpdateModuleVersionResponse) ProtoReflect 

func (x *UpdateModuleVersionResponse) ProtoReflect() protoreflect.Message

func (*UpdateModuleVersionResponse) Reset 

func (x *UpdateModuleVersionResponse) Reset()

func (*UpdateModuleVersionResponse) String 

func (x *UpdateModuleVersionResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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