Versions in this module Expand all Collapse all v0 v0.0.8 Jun 9, 2023 v0.0.7 Jun 9, 2023 v0.0.6 May 30, 2023 v0.0.5 May 13, 2023 v0.0.4 May 10, 2023 Changes in this version + var File_srv_proto protoreflect.FileDescriptor + type DiscoveryNode struct + Component *Component + FlowID string + Graph *structpb.Struct + ID string + Module *ModuleVersion + PortLastState []*PortState + ServerID string + Stats *structpb.Struct + WorkspaceID string + func (*DiscoveryNode) Descriptor() ([]byte, []int) + func (*DiscoveryNode) ProtoMessage() + func (x *DiscoveryNode) GetComponent() *Component + func (x *DiscoveryNode) GetFlowID() string + func (x *DiscoveryNode) GetGraph() *structpb.Struct + func (x *DiscoveryNode) GetID() string + func (x *DiscoveryNode) GetModule() *ModuleVersion + func (x *DiscoveryNode) GetPortLastState() []*PortState + func (x *DiscoveryNode) GetServerID() string + func (x *DiscoveryNode) GetStats() *structpb.Struct + func (x *DiscoveryNode) GetWorkspaceID() string + func (x *DiscoveryNode) ProtoReflect() protoreflect.Message + func (x *DiscoveryNode) Reset() + func (x *DiscoveryNode) String() string + type PortState struct + Data []byte + Date *timestamppb.Timestamp + NodeID string + PortName string + func (*PortState) Descriptor() ([]byte, []int) + func (*PortState) ProtoMessage() + func (x *PortState) GetData() []byte + func (x *PortState) GetDate() *timestamppb.Timestamp + func (x *PortState) GetNodeID() string + func (x *PortState) GetPortName() string + func (x *PortState) ProtoReflect() protoreflect.Message + func (x *PortState) Reset() + func (x *PortState) String() string + type Srv struct + ID string + func (*Srv) Descriptor() ([]byte, []int) + func (*Srv) ProtoMessage() + func (x *Srv) GetID() string + func (x *Srv) ProtoReflect() protoreflect.Message + func (x *Srv) Reset() + func (x *Srv) String() string v0.0.3 Apr 30, 2023 Changes in this version type GetManifestResponse + Error string + func (x *GetManifestResponse) GetError() string type PublishModuleResponse + Error string + func (x *PublishModuleResponse) GetError() string type UpdateModuleVersionResponse + Error string + func (x *UpdateModuleVersionResponse) GetError() string v0.0.1 Apr 27, 2023 Changes in this version + var File_cmp_proto protoreflect.FileDescriptor + var File_graph_proto protoreflect.FileDescriptor + var File_instance_proto protoreflect.FileDescriptor + var File_mapport_proto protoreflect.FileDescriptor + var File_message_proto protoreflect.FileDescriptor + var File_module_version_proto protoreflect.FileDescriptor + var File_node_proto protoreflect.FileDescriptor + var File_platform_messages_proto protoreflect.FileDescriptor + var File_platform_service_proto protoreflect.FileDescriptor + var File_port_config_proto protoreflect.FileDescriptor + var File_runner_config_proto protoreflect.FileDescriptor + var GraphChangeOp_name = map[int32]string + var GraphChangeOp_value = map[string]int32 + var PlatformService_ServiceDesc = grpc.ServiceDesc + func RegisterPlatformServiceServer(s grpc.ServiceRegistrar, srv PlatformServiceServer) + type BuildPushOptions struct + Password string + Repo string + Tag string + Username string + func (*BuildPushOptions) Descriptor() ([]byte, []int) + func (*BuildPushOptions) ProtoMessage() + func (x *BuildPushOptions) GetPassword() string + func (x *BuildPushOptions) GetRepo() string + func (x *BuildPushOptions) GetTag() string + func (x *BuildPushOptions) GetUsername() string + func (x *BuildPushOptions) ProtoReflect() protoreflect.Message + func (x *BuildPushOptions) Reset() + func (x *BuildPushOptions) String() string + type Component struct + Description string + Info string + Name string + Tags []string + func (*Component) Descriptor() ([]byte, []int) + func (*Component) ProtoMessage() + func (x *Component) GetDescription() string + func (x *Component) GetInfo() string + func (x *Component) GetName() string + func (x *Component) GetTags() []string + func (x *Component) ProtoReflect() protoreflect.Message + func (x *Component) Reset() + func (x *Component) String() string + type ConfigureInstanceRequest struct + ComponentID string + Data *structpb.Struct + Destinations []*MapPort + FlowID string + InstanceID string + PortConfigs []*PortConfig + Revision int64 + Run bool + func (*ConfigureInstanceRequest) Descriptor() ([]byte, []int) + func (*ConfigureInstanceRequest) ProtoMessage() + func (x *ConfigureInstanceRequest) GetComponentID() string + func (x *ConfigureInstanceRequest) GetData() *structpb.Struct + func (x *ConfigureInstanceRequest) GetDestinations() []*MapPort + func (x *ConfigureInstanceRequest) GetFlowID() string + func (x *ConfigureInstanceRequest) GetInstanceID() string + func (x *ConfigureInstanceRequest) GetPortConfigs() []*PortConfig + func (x *ConfigureInstanceRequest) GetRevision() int64 + func (x *ConfigureInstanceRequest) GetRun() bool + func (x *ConfigureInstanceRequest) ProtoReflect() protoreflect.Message + func (x *ConfigureInstanceRequest) Reset() + func (x *ConfigureInstanceRequest) String() string + type ConfigureInstanceResponse struct + Changes []*GraphChange + Error string + HasError bool + IsRunning bool + func (*ConfigureInstanceResponse) Descriptor() ([]byte, []int) + func (*ConfigureInstanceResponse) ProtoMessage() + func (x *ConfigureInstanceResponse) GetChanges() []*GraphChange + func (x *ConfigureInstanceResponse) GetError() string + func (x *ConfigureInstanceResponse) GetHasError() bool + func (x *ConfigureInstanceResponse) GetIsRunning() bool + func (x *ConfigureInstanceResponse) ProtoReflect() protoreflect.Message + func (x *ConfigureInstanceResponse) Reset() + func (x *ConfigureInstanceResponse) String() string + type Edge struct + Source string + SourceHandle string + Target string + TargetHandle string + func (*Edge) Descriptor() ([]byte, []int) + func (*Edge) ProtoMessage() + func (x *Edge) GetSource() string + func (x *Edge) GetSourceHandle() string + func (x *Edge) GetTarget() string + func (x *Edge) GetTargetHandle() string + func (x *Edge) ProtoReflect() protoreflect.Message + func (x *Edge) Reset() + func (x *Edge) String() string + type GetManifestRequest struct + DevMode bool + DeveloperKey string + ModuleVersionID string + ServerKey string + Version string + func (*GetManifestRequest) Descriptor() ([]byte, []int) + func (*GetManifestRequest) ProtoMessage() + func (x *GetManifestRequest) GetDevMode() bool + func (x *GetManifestRequest) GetDeveloperKey() string + func (x *GetManifestRequest) GetModuleVersionID() string + func (x *GetManifestRequest) GetServerKey() string + func (x *GetManifestRequest) GetVersion() string + func (x *GetManifestRequest) ProtoReflect() protoreflect.Message + func (x *GetManifestRequest) Reset() + func (x *GetManifestRequest) String() string + type GetManifestResponse struct + Instances []*ConfigureInstanceRequest + Modules []*ModuleVersion + RunnerConfig *RunnerConfig + func (*GetManifestResponse) Descriptor() ([]byte, []int) + func (*GetManifestResponse) ProtoMessage() + func (x *GetManifestResponse) GetInstances() []*ConfigureInstanceRequest + func (x *GetManifestResponse) GetModules() []*ModuleVersion + func (x *GetManifestResponse) GetRunnerConfig() *RunnerConfig + func (x *GetManifestResponse) ProtoReflect() protoreflect.Message + func (x *GetManifestResponse) Reset() + func (x *GetManifestResponse) String() string + type GraphChange struct + Elements []*GraphElement + Module *GraphChangeModule + Op GraphChangeOp + Server *GraphChangeServer + func (*GraphChange) Descriptor() ([]byte, []int) + func (*GraphChange) ProtoMessage() + func (x *GraphChange) GetElements() []*GraphElement + func (x *GraphChange) GetModule() *GraphChangeModule + func (x *GraphChange) GetOp() GraphChangeOp + func (x *GraphChange) GetServer() *GraphChangeServer + func (x *GraphChange) ProtoReflect() protoreflect.Message + func (x *GraphChange) Reset() + func (x *GraphChange) String() string + type GraphChangeModule struct + Name string + Version string + VersionID string + func (*GraphChangeModule) Descriptor() ([]byte, []int) + func (*GraphChangeModule) ProtoMessage() + func (x *GraphChangeModule) GetName() string + func (x *GraphChangeModule) GetVersion() string + func (x *GraphChangeModule) GetVersionID() string + func (x *GraphChangeModule) ProtoReflect() protoreflect.Message + func (x *GraphChangeModule) Reset() + func (x *GraphChangeModule) String() string + type GraphChangeOp int32 + const GraphChangeOp_DELETE + const GraphChangeOp_UPDATE + func (GraphChangeOp) Descriptor() protoreflect.EnumDescriptor + func (GraphChangeOp) EnumDescriptor() ([]byte, []int) + func (GraphChangeOp) Type() protoreflect.EnumType + func (x GraphChangeOp) Enum() *GraphChangeOp + func (x GraphChangeOp) Number() protoreflect.EnumNumber + func (x GraphChangeOp) String() string + type GraphChangeServer struct + ID string + func (*GraphChangeServer) Descriptor() ([]byte, []int) + func (*GraphChangeServer) ProtoMessage() + func (x *GraphChangeServer) GetID() string + func (x *GraphChangeServer) ProtoReflect() protoreflect.Message + func (x *GraphChangeServer) Reset() + func (x *GraphChangeServer) String() string + type GraphElement struct + Edge *Edge + ID string + Node *Node + Revision int64 + func (*GraphElement) Descriptor() ([]byte, []int) + func (*GraphElement) ProtoMessage() + func (x *GraphElement) GetEdge() *Edge + func (x *GraphElement) GetID() string + func (x *GraphElement) GetNode() *Node + func (x *GraphElement) GetRevision() int64 + func (x *GraphElement) ProtoReflect() protoreflect.Message + func (x *GraphElement) Reset() + func (x *GraphElement) String() string + type MapPort struct + EdgeID string + From string + To string + func (*MapPort) Descriptor() ([]byte, []int) + func (*MapPort) ProtoMessage() + func (x *MapPort) GetEdgeID() string + func (x *MapPort) GetFrom() string + func (x *MapPort) GetTo() string + func (x *MapPort) ProtoReflect() protoreflect.Message + func (x *MapPort) Reset() + func (x *MapPort) String() string + type MessageRequest struct + EdgeID string + From string + ID string + Metadata map[string]string + Payload []byte + func (*MessageRequest) Descriptor() ([]byte, []int) + func (*MessageRequest) ProtoMessage() + func (x *MessageRequest) GetEdgeID() string + func (x *MessageRequest) GetFrom() string + func (x *MessageRequest) GetID() string + func (x *MessageRequest) GetMetadata() map[string]string + func (x *MessageRequest) GetPayload() []byte + func (x *MessageRequest) ProtoReflect() protoreflect.Message + func (x *MessageRequest) Reset() + func (x *MessageRequest) String() string + type MessageResponse struct + Data []byte + Error string + HasError bool + func (*MessageResponse) Descriptor() ([]byte, []int) + func (*MessageResponse) ProtoMessage() + func (x *MessageResponse) GetData() []byte + func (x *MessageResponse) GetError() string + func (x *MessageResponse) GetHasError() bool + func (x *MessageResponse) ProtoReflect() protoreflect.Message + func (x *MessageResponse) Reset() + func (x *MessageResponse) String() string + type ModuleVersion struct + ID string + ModuleName string + Version string + func (*ModuleVersion) Descriptor() ([]byte, []int) + func (*ModuleVersion) ProtoMessage() + func (x *ModuleVersion) GetID() string + func (x *ModuleVersion) GetModuleName() string + func (x *ModuleVersion) GetVersion() string + func (x *ModuleVersion) ProtoReflect() protoreflect.Message + func (x *ModuleVersion) Reset() + func (x *ModuleVersion) String() string + type Node struct + ComponentID string + Data *structpb.Struct + Destinations []*MapPort + PortConfigs []*PortConfig + Ports []*NodePort + Position *Position + Run bool + Runnable bool + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (x *Node) GetComponentID() string + func (x *Node) GetData() *structpb.Struct + func (x *Node) GetDestinations() []*MapPort + func (x *Node) GetPortConfigs() []*PortConfig + func (x *Node) GetPorts() []*NodePort + func (x *Node) GetPosition() *Position + func (x *Node) GetRun() bool + func (x *Node) GetRunnable() bool + func (x *Node) ProtoReflect() protoreflect.Message + func (x *Node) Reset() + func (x *Node) String() string + type NodePort struct + ConfigurationDefault []byte + IsSettings bool + Label string + PortName string + Position int32 + SchemaDefault []byte + Source bool + Status bool + func (*NodePort) Descriptor() ([]byte, []int) + func (*NodePort) ProtoMessage() + func (x *NodePort) GetConfigurationDefault() []byte + func (x *NodePort) GetIsSettings() bool + func (x *NodePort) GetLabel() string + func (x *NodePort) GetPortName() string + func (x *NodePort) GetPosition() int32 + func (x *NodePort) GetSchemaDefault() []byte + func (x *NodePort) GetSource() bool + func (x *NodePort) GetStatus() bool + func (x *NodePort) ProtoReflect() protoreflect.Message + func (x *NodePort) Reset() + func (x *NodePort) String() string + type PlatformServiceClient interface + GetManifest func(ctx context.Context, in *GetManifestRequest, opts ...grpc.CallOption) (*GetManifestResponse, error) + PublishModule func(ctx context.Context, in *PublishModuleRequest, opts ...grpc.CallOption) (*PublishModuleResponse, error) + UpdateModuleVersion func(ctx context.Context, in *UpdateModuleVersionRequest, opts ...grpc.CallOption) (*UpdateModuleVersionResponse, error) + func NewPlatformServiceClient(cc grpc.ClientConnInterface) PlatformServiceClient + type PlatformServiceServer interface + GetManifest func(context.Context, *GetManifestRequest) (*GetManifestResponse, error) + PublishModule func(context.Context, *PublishModuleRequest) (*PublishModuleResponse, error) + UpdateModuleVersion func(context.Context, *UpdateModuleVersionRequest) (*UpdateModuleVersionResponse, error) + type PortConfig struct + Configuration []byte + ConfigurationDefault []byte + From string + PortName string + Schema []byte + SchemaDefault []byte + func (*PortConfig) Descriptor() ([]byte, []int) + func (*PortConfig) ProtoMessage() + func (x *PortConfig) GetConfiguration() []byte + func (x *PortConfig) GetConfigurationDefault() []byte + func (x *PortConfig) GetFrom() string + func (x *PortConfig) GetPortName() string + func (x *PortConfig) GetSchema() []byte + func (x *PortConfig) GetSchemaDefault() []byte + func (x *PortConfig) ProtoReflect() protoreflect.Message + func (x *PortConfig) Reset() + func (x *PortConfig) String() string + type Position struct + Spin int32 + X int32 + Y int32 + func (*Position) Descriptor() ([]byte, []int) + func (*Position) ProtoMessage() + func (x *Position) GetSpin() int32 + func (x *Position) GetX() int32 + func (x *Position) GetY() int32 + func (x *Position) ProtoReflect() protoreflect.Message + func (x *Position) Reset() + func (x *Position) String() string + type PublishModuleRequest struct + Components []*Component + Description string + DeveloperKey string + Info string + Name string + Version string + func (*PublishModuleRequest) Descriptor() ([]byte, []int) + func (*PublishModuleRequest) ProtoMessage() + func (x *PublishModuleRequest) GetComponents() []*Component + func (x *PublishModuleRequest) GetDescription() string + func (x *PublishModuleRequest) GetDeveloperKey() string + func (x *PublishModuleRequest) GetInfo() string + func (x *PublishModuleRequest) GetName() string + func (x *PublishModuleRequest) GetVersion() string + func (x *PublishModuleRequest) ProtoReflect() protoreflect.Message + func (x *PublishModuleRequest) Reset() + func (x *PublishModuleRequest) String() string + type PublishModuleResponse struct + Module *ModuleVersion + Options *BuildPushOptions + func (*PublishModuleResponse) Descriptor() ([]byte, []int) + func (*PublishModuleResponse) ProtoMessage() + func (x *PublishModuleResponse) GetModule() *ModuleVersion + func (x *PublishModuleResponse) GetOptions() *BuildPushOptions + func (x *PublishModuleResponse) ProtoReflect() protoreflect.Message + func (x *PublishModuleResponse) Reset() + func (x *PublishModuleResponse) String() string + type RunnerConfig struct + DevMode bool + ServerID string + WorkspaceID string + func (*RunnerConfig) Descriptor() ([]byte, []int) + func (*RunnerConfig) ProtoMessage() + func (x *RunnerConfig) GetDevMode() bool + func (x *RunnerConfig) GetServerID() string + func (x *RunnerConfig) GetWorkspaceID() string + func (x *RunnerConfig) ProtoReflect() protoreflect.Message + func (x *RunnerConfig) Reset() + func (x *RunnerConfig) String() string + type UnimplementedPlatformServiceServer struct + func (UnimplementedPlatformServiceServer) GetManifest(context.Context, *GetManifestRequest) (*GetManifestResponse, error) + func (UnimplementedPlatformServiceServer) PublishModule(context.Context, *PublishModuleRequest) (*PublishModuleResponse, error) + func (UnimplementedPlatformServiceServer) UpdateModuleVersion(context.Context, *UpdateModuleVersionRequest) (*UpdateModuleVersionResponse, error) + type UnsafePlatformServiceServer interface + type UpdateModuleVersionRequest struct + ID string + Repo string + Tag string + func (*UpdateModuleVersionRequest) Descriptor() ([]byte, []int) + func (*UpdateModuleVersionRequest) ProtoMessage() + func (x *UpdateModuleVersionRequest) GetID() string + func (x *UpdateModuleVersionRequest) GetRepo() string + func (x *UpdateModuleVersionRequest) GetTag() string + func (x *UpdateModuleVersionRequest) ProtoReflect() protoreflect.Message + func (x *UpdateModuleVersionRequest) Reset() + func (x *UpdateModuleVersionRequest) String() string + type UpdateModuleVersionResponse struct + func (*UpdateModuleVersionResponse) Descriptor() ([]byte, []int) + func (*UpdateModuleVersionResponse) ProtoMessage() + func (x *UpdateModuleVersionResponse) ProtoReflect() protoreflect.Message + func (x *UpdateModuleVersionResponse) Reset() + func (x *UpdateModuleVersionResponse) String() string
Go to main page