Documentation ¶
Index ¶
- Variables
- func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)
- func RegisterPingServiceServer(s grpc.ServiceRegistrar, srv PingServiceServer)
- type AddNodeRequest
- func (*AddNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddNodeRequest) GetChainConfigs() map[string]string
- func (x *AddNodeRequest) GetExecPath() string
- func (x *AddNodeRequest) GetName() string
- func (x *AddNodeRequest) GetNodeConfig() string
- func (x *AddNodeRequest) GetUpgradeConfigs() map[string]string
- func (*AddNodeRequest) ProtoMessage()
- func (x *AddNodeRequest) ProtoReflect() protoreflect.Message
- func (x *AddNodeRequest) Reset()
- func (x *AddNodeRequest) String() string
- type AddNodeResponse
- type AttachPeerRequest
- type AttachPeerResponse
- func (*AttachPeerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AttachPeerResponse) GetAttachedPeerInfo() *AttachedPeerInfo
- func (x *AttachPeerResponse) GetClusterInfo() *ClusterInfo
- func (*AttachPeerResponse) ProtoMessage()
- func (x *AttachPeerResponse) ProtoReflect() protoreflect.Message
- func (x *AttachPeerResponse) Reset()
- func (x *AttachPeerResponse) String() string
- type AttachedPeerInfo
- type BlockchainSpec
- func (*BlockchainSpec) Descriptor() ([]byte, []int)deprecated
- func (x *BlockchainSpec) GetChainConfig() string
- func (x *BlockchainSpec) GetGenesis() string
- func (x *BlockchainSpec) GetNetworkUpgrade() string
- func (x *BlockchainSpec) GetSubnetId() string
- func (x *BlockchainSpec) GetVmName() string
- func (*BlockchainSpec) ProtoMessage()
- func (x *BlockchainSpec) ProtoReflect() protoreflect.Message
- func (x *BlockchainSpec) Reset()
- func (x *BlockchainSpec) String() string
- type ClusterInfo
- func (*ClusterInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterInfo) GetAttachedPeerInfos() map[string]*ListOfAttachedPeerInfo
- func (x *ClusterInfo) GetCustomChains() map[string]*CustomChainInfo
- func (x *ClusterInfo) GetCustomChainsHealthy() bool
- func (x *ClusterInfo) GetHealthy() bool
- func (x *ClusterInfo) GetNodeInfos() map[string]*NodeInfo
- func (x *ClusterInfo) GetNodeNames() []string
- func (x *ClusterInfo) GetPid() int32
- func (x *ClusterInfo) GetRootDataDir() string
- func (x *ClusterInfo) GetSubnets() []string
- func (*ClusterInfo) ProtoMessage()
- func (x *ClusterInfo) ProtoReflect() protoreflect.Message
- func (x *ClusterInfo) Reset()
- func (x *ClusterInfo) String() string
- type ControlServiceClient
- type ControlServiceServer
- type ControlService_StreamStatusClient
- type ControlService_StreamStatusServer
- type CreateBlockchainsRequest
- func (*CreateBlockchainsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateBlockchainsRequest) GetBlockchainSpecs() []*BlockchainSpec
- func (*CreateBlockchainsRequest) ProtoMessage()
- func (x *CreateBlockchainsRequest) ProtoReflect() protoreflect.Message
- func (x *CreateBlockchainsRequest) Reset()
- func (x *CreateBlockchainsRequest) String() string
- type CreateBlockchainsResponse
- func (*CreateBlockchainsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateBlockchainsResponse) GetClusterInfo() *ClusterInfo
- func (*CreateBlockchainsResponse) ProtoMessage()
- func (x *CreateBlockchainsResponse) ProtoReflect() protoreflect.Message
- func (x *CreateBlockchainsResponse) Reset()
- func (x *CreateBlockchainsResponse) String() string
- type CreateSubnetsRequest
- func (*CreateSubnetsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSubnetsRequest) GetNumSubnets() uint32
- func (*CreateSubnetsRequest) ProtoMessage()
- func (x *CreateSubnetsRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSubnetsRequest) Reset()
- func (x *CreateSubnetsRequest) String() string
- type CreateSubnetsResponse
- func (*CreateSubnetsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSubnetsResponse) GetClusterInfo() *ClusterInfo
- func (*CreateSubnetsResponse) ProtoMessage()
- func (x *CreateSubnetsResponse) ProtoReflect() protoreflect.Message
- func (x *CreateSubnetsResponse) Reset()
- func (x *CreateSubnetsResponse) String() string
- type CustomChainInfo
- func (*CustomChainInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CustomChainInfo) GetChainId() string
- func (x *CustomChainInfo) GetChainName() string
- func (x *CustomChainInfo) GetSubnetId() string
- func (x *CustomChainInfo) GetVmId() string
- func (*CustomChainInfo) ProtoMessage()
- func (x *CustomChainInfo) ProtoReflect() protoreflect.Message
- func (x *CustomChainInfo) Reset()
- func (x *CustomChainInfo) String() string
- type GetSnapshotNamesRequest
- type GetSnapshotNamesResponse
- func (*GetSnapshotNamesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSnapshotNamesResponse) GetSnapshotNames() []string
- func (*GetSnapshotNamesResponse) ProtoMessage()
- func (x *GetSnapshotNamesResponse) ProtoReflect() protoreflect.Message
- func (x *GetSnapshotNamesResponse) Reset()
- func (x *GetSnapshotNamesResponse) String() string
- type HealthRequest
- type HealthResponse
- type ListOfAttachedPeerInfo
- func (*ListOfAttachedPeerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ListOfAttachedPeerInfo) GetPeers() []*AttachedPeerInfo
- func (*ListOfAttachedPeerInfo) ProtoMessage()
- func (x *ListOfAttachedPeerInfo) ProtoReflect() protoreflect.Message
- func (x *ListOfAttachedPeerInfo) Reset()
- func (x *ListOfAttachedPeerInfo) String() string
- type LoadSnapshotRequest
- func (*LoadSnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LoadSnapshotRequest) GetChainConfigs() map[string]string
- func (x *LoadSnapshotRequest) GetExecPath() string
- func (x *LoadSnapshotRequest) GetGlobalNodeConfig() string
- func (x *LoadSnapshotRequest) GetPluginDir() string
- func (x *LoadSnapshotRequest) GetReassignPortsIfUsed() bool
- func (x *LoadSnapshotRequest) GetRootDataDir() string
- func (x *LoadSnapshotRequest) GetSnapshotName() string
- func (x *LoadSnapshotRequest) GetUpgradeConfigs() map[string]string
- func (*LoadSnapshotRequest) ProtoMessage()
- func (x *LoadSnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *LoadSnapshotRequest) Reset()
- func (x *LoadSnapshotRequest) String() string
- type LoadSnapshotResponse
- func (*LoadSnapshotResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LoadSnapshotResponse) GetClusterInfo() *ClusterInfo
- func (*LoadSnapshotResponse) ProtoMessage()
- func (x *LoadSnapshotResponse) ProtoReflect() protoreflect.Message
- func (x *LoadSnapshotResponse) Reset()
- func (x *LoadSnapshotResponse) String() string
- type NodeInfo
- func (*NodeInfo) Descriptor() ([]byte, []int)deprecated
- func (x *NodeInfo) GetConfig() []byte
- func (x *NodeInfo) GetDbDir() string
- func (x *NodeInfo) GetExecPath() string
- func (x *NodeInfo) GetId() string
- func (x *NodeInfo) GetLogDir() string
- func (x *NodeInfo) GetName() string
- func (x *NodeInfo) GetPluginDir() string
- func (x *NodeInfo) GetUri() string
- func (x *NodeInfo) GetWhitelistedSubnets() string
- func (*NodeInfo) ProtoMessage()
- func (x *NodeInfo) ProtoReflect() protoreflect.Message
- func (x *NodeInfo) Reset()
- func (x *NodeInfo) String() string
- type PingRequest
- type PingResponse
- type PingServiceClient
- type PingServiceServer
- type RemoveNodeRequest
- type RemoveNodeResponse
- func (*RemoveNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveNodeResponse) GetClusterInfo() *ClusterInfo
- func (*RemoveNodeResponse) ProtoMessage()
- func (x *RemoveNodeResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveNodeResponse) Reset()
- func (x *RemoveNodeResponse) String() string
- type RemoveSnapshotRequest
- func (*RemoveSnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveSnapshotRequest) GetSnapshotName() string
- func (*RemoveSnapshotRequest) ProtoMessage()
- func (x *RemoveSnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveSnapshotRequest) Reset()
- func (x *RemoveSnapshotRequest) String() string
- type RemoveSnapshotResponse
- type RestartNodeRequest
- func (*RestartNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RestartNodeRequest) GetChainConfigs() map[string]string
- func (x *RestartNodeRequest) GetExecPath() string
- func (x *RestartNodeRequest) GetName() string
- func (x *RestartNodeRequest) GetUpgradeConfigs() map[string]string
- func (x *RestartNodeRequest) GetWhitelistedSubnets() string
- func (*RestartNodeRequest) ProtoMessage()
- func (x *RestartNodeRequest) ProtoReflect() protoreflect.Message
- func (x *RestartNodeRequest) Reset()
- func (x *RestartNodeRequest) String() string
- type RestartNodeResponse
- func (*RestartNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RestartNodeResponse) GetClusterInfo() *ClusterInfo
- func (*RestartNodeResponse) ProtoMessage()
- func (x *RestartNodeResponse) ProtoReflect() protoreflect.Message
- func (x *RestartNodeResponse) Reset()
- func (x *RestartNodeResponse) String() string
- type SaveSnapshotRequest
- func (*SaveSnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SaveSnapshotRequest) GetSnapshotName() string
- func (*SaveSnapshotRequest) ProtoMessage()
- func (x *SaveSnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *SaveSnapshotRequest) Reset()
- func (x *SaveSnapshotRequest) String() string
- type SaveSnapshotResponse
- func (*SaveSnapshotResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SaveSnapshotResponse) GetSnapshotPath() string
- func (*SaveSnapshotResponse) ProtoMessage()
- func (x *SaveSnapshotResponse) ProtoReflect() protoreflect.Message
- func (x *SaveSnapshotResponse) Reset()
- func (x *SaveSnapshotResponse) String() string
- type SendOutboundMessageRequest
- func (*SendOutboundMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendOutboundMessageRequest) GetBytes() []byte
- func (x *SendOutboundMessageRequest) GetNodeName() string
- func (x *SendOutboundMessageRequest) GetOp() uint32
- func (x *SendOutboundMessageRequest) GetPeerId() string
- func (*SendOutboundMessageRequest) ProtoMessage()
- func (x *SendOutboundMessageRequest) ProtoReflect() protoreflect.Message
- func (x *SendOutboundMessageRequest) Reset()
- func (x *SendOutboundMessageRequest) String() string
- type SendOutboundMessageResponse
- func (*SendOutboundMessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SendOutboundMessageResponse) GetSent() bool
- func (*SendOutboundMessageResponse) ProtoMessage()
- func (x *SendOutboundMessageResponse) ProtoReflect() protoreflect.Message
- func (x *SendOutboundMessageResponse) Reset()
- func (x *SendOutboundMessageResponse) String() string
- type StartRequest
- func (*StartRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartRequest) GetBlockchainSpecs() []*BlockchainSpec
- func (x *StartRequest) GetChainConfigs() map[string]string
- func (x *StartRequest) GetCustomNodeConfigs() map[string]string
- func (x *StartRequest) GetDynamicPorts() bool
- func (x *StartRequest) GetExecPath() string
- func (x *StartRequest) GetGlobalNodeConfig() string
- func (x *StartRequest) GetNumNodes() uint32
- func (x *StartRequest) GetPluginDir() string
- func (x *StartRequest) GetReassignPortsIfUsed() bool
- func (x *StartRequest) GetRootDataDir() string
- func (x *StartRequest) GetUpgradeConfigs() map[string]string
- func (x *StartRequest) GetWhitelistedSubnets() string
- func (*StartRequest) ProtoMessage()
- func (x *StartRequest) ProtoReflect() protoreflect.Message
- func (x *StartRequest) Reset()
- func (x *StartRequest) String() string
- type StartResponse
- type StatusRequest
- type StatusResponse
- type StopRequest
- type StopResponse
- type StreamStatusRequest
- func (*StreamStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamStatusRequest) GetPushInterval() int64
- func (*StreamStatusRequest) ProtoMessage()
- func (x *StreamStatusRequest) ProtoReflect() protoreflect.Message
- func (x *StreamStatusRequest) Reset()
- func (x *StreamStatusRequest) String() string
- type StreamStatusResponse
- func (*StreamStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamStatusResponse) GetClusterInfo() *ClusterInfo
- func (*StreamStatusResponse) ProtoMessage()
- func (x *StreamStatusResponse) ProtoReflect() protoreflect.Message
- func (x *StreamStatusResponse) Reset()
- func (x *StreamStatusResponse) String() string
- type URIsRequest
- type URIsResponse
- type UnimplementedControlServiceServer
- func (UnimplementedControlServiceServer) AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)
- func (UnimplementedControlServiceServer) AttachPeer(context.Context, *AttachPeerRequest) (*AttachPeerResponse, error)
- func (UnimplementedControlServiceServer) CreateBlockchains(context.Context, *CreateBlockchainsRequest) (*CreateBlockchainsResponse, error)
- func (UnimplementedControlServiceServer) CreateSubnets(context.Context, *CreateSubnetsRequest) (*CreateSubnetsResponse, error)
- func (UnimplementedControlServiceServer) GetSnapshotNames(context.Context, *GetSnapshotNamesRequest) (*GetSnapshotNamesResponse, error)
- func (UnimplementedControlServiceServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)
- func (UnimplementedControlServiceServer) LoadSnapshot(context.Context, *LoadSnapshotRequest) (*LoadSnapshotResponse, error)
- func (UnimplementedControlServiceServer) RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
- func (UnimplementedControlServiceServer) RemoveSnapshot(context.Context, *RemoveSnapshotRequest) (*RemoveSnapshotResponse, error)
- func (UnimplementedControlServiceServer) RestartNode(context.Context, *RestartNodeRequest) (*RestartNodeResponse, error)
- func (UnimplementedControlServiceServer) SaveSnapshot(context.Context, *SaveSnapshotRequest) (*SaveSnapshotResponse, error)
- func (UnimplementedControlServiceServer) SendOutboundMessage(context.Context, *SendOutboundMessageRequest) (*SendOutboundMessageResponse, error)
- func (UnimplementedControlServiceServer) Start(context.Context, *StartRequest) (*StartResponse, error)
- func (UnimplementedControlServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
- func (UnimplementedControlServiceServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
- func (UnimplementedControlServiceServer) StreamStatus(*StreamStatusRequest, ControlService_StreamStatusServer) error
- func (UnimplementedControlServiceServer) URIs(context.Context, *URIsRequest) (*URIsResponse, error)
- type UnimplementedPingServiceServer
- type UnsafeControlServiceServer
- type UnsafePingServiceServer
Constants ¶
This section is empty.
Variables ¶
var ControlService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "rpcpb.ControlService", HandlerType: (*ControlServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Start", Handler: _ControlService_Start_Handler, }, { MethodName: "CreateBlockchains", Handler: _ControlService_CreateBlockchains_Handler, }, { MethodName: "CreateSubnets", Handler: _ControlService_CreateSubnets_Handler, }, { MethodName: "Health", Handler: _ControlService_Health_Handler, }, { MethodName: "URIs", Handler: _ControlService_URIs_Handler, }, { MethodName: "Status", Handler: _ControlService_Status_Handler, }, { MethodName: "RemoveNode", Handler: _ControlService_RemoveNode_Handler, }, { MethodName: "AddNode", Handler: _ControlService_AddNode_Handler, }, { MethodName: "RestartNode", Handler: _ControlService_RestartNode_Handler, }, { MethodName: "Stop", Handler: _ControlService_Stop_Handler, }, { MethodName: "AttachPeer", Handler: _ControlService_AttachPeer_Handler, }, { MethodName: "SendOutboundMessage", Handler: _ControlService_SendOutboundMessage_Handler, }, { MethodName: "SaveSnapshot", Handler: _ControlService_SaveSnapshot_Handler, }, { MethodName: "LoadSnapshot", Handler: _ControlService_LoadSnapshot_Handler, }, { MethodName: "RemoveSnapshot", Handler: _ControlService_RemoveSnapshot_Handler, }, { MethodName: "GetSnapshotNames", Handler: _ControlService_GetSnapshotNames_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamStatus", Handler: _ControlService_StreamStatus_Handler, ServerStreams: true, }, }, Metadata: "rpcpb/rpc.proto", }
ControlService_ServiceDesc is the grpc.ServiceDesc for ControlService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_rpcpb_rpc_proto protoreflect.FileDescriptor
var PingService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "rpcpb.PingService", HandlerType: (*PingServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _PingService_Ping_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "rpcpb/rpc.proto", }
PingService_ServiceDesc is the grpc.ServiceDesc for PingService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterControlServiceServer ¶
func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)
func RegisterPingServiceServer ¶
func RegisterPingServiceServer(s grpc.ServiceRegistrar, srv PingServiceServer)
Types ¶
type AddNodeRequest ¶
type AddNodeRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ExecPath string `protobuf:"bytes,2,opt,name=exec_path,json=execPath,proto3" json:"exec_path,omitempty"` NodeConfig *string `protobuf:"bytes,3,opt,name=node_config,json=nodeConfig,proto3,oneof" json:"node_config,omitempty"` // Map of chain name to config file contents. // If specified, will create a file "chainname/config.json" with // the contents provided here. ChainConfigs map[string]string `` /* 185-byte string literal not displayed */ // Map of chain name to config file contents. // If specified, will create a file "chainname/upgrade.json" with // the contents provided here. UpgradeConfigs map[string]string `` /* 191-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AddNodeRequest) Descriptor
deprecated
func (*AddNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddNodeRequest.ProtoReflect.Descriptor instead.
func (*AddNodeRequest) GetChainConfigs ¶ added in v0.2.0
func (x *AddNodeRequest) GetChainConfigs() map[string]string
func (*AddNodeRequest) GetExecPath ¶ added in v0.2.0
func (x *AddNodeRequest) GetExecPath() string
func (*AddNodeRequest) GetName ¶
func (x *AddNodeRequest) GetName() string
func (*AddNodeRequest) GetNodeConfig ¶ added in v0.2.0
func (x *AddNodeRequest) GetNodeConfig() string
func (*AddNodeRequest) GetUpgradeConfigs ¶ added in v0.2.0
func (x *AddNodeRequest) GetUpgradeConfigs() map[string]string
func (*AddNodeRequest) ProtoMessage ¶
func (*AddNodeRequest) ProtoMessage()
func (*AddNodeRequest) ProtoReflect ¶
func (x *AddNodeRequest) ProtoReflect() protoreflect.Message
func (*AddNodeRequest) Reset ¶
func (x *AddNodeRequest) Reset()
func (*AddNodeRequest) String ¶
func (x *AddNodeRequest) String() string
type AddNodeResponse ¶
type AddNodeResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*AddNodeResponse) Descriptor
deprecated
func (*AddNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddNodeResponse.ProtoReflect.Descriptor instead.
func (*AddNodeResponse) GetClusterInfo ¶
func (x *AddNodeResponse) GetClusterInfo() *ClusterInfo
func (*AddNodeResponse) ProtoMessage ¶
func (*AddNodeResponse) ProtoMessage()
func (*AddNodeResponse) ProtoReflect ¶
func (x *AddNodeResponse) ProtoReflect() protoreflect.Message
func (*AddNodeResponse) Reset ¶
func (x *AddNodeResponse) Reset()
func (*AddNodeResponse) String ¶
func (x *AddNodeResponse) String() string
type AttachPeerRequest ¶
type AttachPeerRequest struct { NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` // contains filtered or unexported fields }
func (*AttachPeerRequest) Descriptor
deprecated
func (*AttachPeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use AttachPeerRequest.ProtoReflect.Descriptor instead.
func (*AttachPeerRequest) GetNodeName ¶
func (x *AttachPeerRequest) GetNodeName() string
func (*AttachPeerRequest) ProtoMessage ¶
func (*AttachPeerRequest) ProtoMessage()
func (*AttachPeerRequest) ProtoReflect ¶
func (x *AttachPeerRequest) ProtoReflect() protoreflect.Message
func (*AttachPeerRequest) Reset ¶
func (x *AttachPeerRequest) Reset()
func (*AttachPeerRequest) String ¶
func (x *AttachPeerRequest) String() string
type AttachPeerResponse ¶
type AttachPeerResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` AttachedPeerInfo *AttachedPeerInfo `protobuf:"bytes,2,opt,name=attached_peer_info,json=attachedPeerInfo,proto3" json:"attached_peer_info,omitempty"` // contains filtered or unexported fields }
func (*AttachPeerResponse) Descriptor
deprecated
func (*AttachPeerResponse) Descriptor() ([]byte, []int)
Deprecated: Use AttachPeerResponse.ProtoReflect.Descriptor instead.
func (*AttachPeerResponse) GetAttachedPeerInfo ¶
func (x *AttachPeerResponse) GetAttachedPeerInfo() *AttachedPeerInfo
func (*AttachPeerResponse) GetClusterInfo ¶
func (x *AttachPeerResponse) GetClusterInfo() *ClusterInfo
func (*AttachPeerResponse) ProtoMessage ¶
func (*AttachPeerResponse) ProtoMessage()
func (*AttachPeerResponse) ProtoReflect ¶
func (x *AttachPeerResponse) ProtoReflect() protoreflect.Message
func (*AttachPeerResponse) Reset ¶
func (x *AttachPeerResponse) Reset()
func (*AttachPeerResponse) String ¶
func (x *AttachPeerResponse) String() string
type AttachedPeerInfo ¶
type AttachedPeerInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*AttachedPeerInfo) Descriptor
deprecated
func (*AttachedPeerInfo) Descriptor() ([]byte, []int)
Deprecated: Use AttachedPeerInfo.ProtoReflect.Descriptor instead.
func (*AttachedPeerInfo) GetId ¶
func (x *AttachedPeerInfo) GetId() string
func (*AttachedPeerInfo) ProtoMessage ¶
func (*AttachedPeerInfo) ProtoMessage()
func (*AttachedPeerInfo) ProtoReflect ¶
func (x *AttachedPeerInfo) ProtoReflect() protoreflect.Message
func (*AttachedPeerInfo) Reset ¶
func (x *AttachedPeerInfo) Reset()
func (*AttachedPeerInfo) String ¶
func (x *AttachedPeerInfo) String() string
type BlockchainSpec ¶ added in v0.2.0
type BlockchainSpec struct { VmName string `protobuf:"bytes,1,opt,name=vm_name,json=vmName,proto3" json:"vm_name,omitempty"` Genesis string `protobuf:"bytes,2,opt,name=genesis,proto3" json:"genesis,omitempty"` SubnetId *string `protobuf:"bytes,3,opt,name=subnet_id,json=subnetId,proto3,oneof" json:"subnet_id,omitempty"` ChainConfig string `protobuf:"bytes,4,opt,name=chain_config,json=chainConfig,proto3" json:"chain_config,omitempty"` NetworkUpgrade string `protobuf:"bytes,5,opt,name=network_upgrade,json=networkUpgrade,proto3" json:"network_upgrade,omitempty"` // contains filtered or unexported fields }
func (*BlockchainSpec) Descriptor
deprecated
added in
v0.2.0
func (*BlockchainSpec) Descriptor() ([]byte, []int)
Deprecated: Use BlockchainSpec.ProtoReflect.Descriptor instead.
func (*BlockchainSpec) GetChainConfig ¶ added in v0.3.0
func (x *BlockchainSpec) GetChainConfig() string
func (*BlockchainSpec) GetGenesis ¶ added in v0.2.0
func (x *BlockchainSpec) GetGenesis() string
func (*BlockchainSpec) GetNetworkUpgrade ¶ added in v0.3.0
func (x *BlockchainSpec) GetNetworkUpgrade() string
func (*BlockchainSpec) GetSubnetId ¶ added in v0.2.0
func (x *BlockchainSpec) GetSubnetId() string
func (*BlockchainSpec) GetVmName ¶ added in v0.2.0
func (x *BlockchainSpec) GetVmName() string
func (*BlockchainSpec) ProtoMessage ¶ added in v0.2.0
func (*BlockchainSpec) ProtoMessage()
func (*BlockchainSpec) ProtoReflect ¶ added in v0.2.0
func (x *BlockchainSpec) ProtoReflect() protoreflect.Message
func (*BlockchainSpec) Reset ¶ added in v0.2.0
func (x *BlockchainSpec) Reset()
func (*BlockchainSpec) String ¶ added in v0.2.0
func (x *BlockchainSpec) String() string
type ClusterInfo ¶
type ClusterInfo struct { NodeNames []string `protobuf:"bytes,1,rep,name=node_names,json=nodeNames,proto3" json:"node_names,omitempty"` NodeInfos map[string]*NodeInfo `` /* 176-byte string literal not displayed */ Pid int32 `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"` RootDataDir string `protobuf:"bytes,4,opt,name=root_data_dir,json=rootDataDir,proto3" json:"root_data_dir,omitempty"` Healthy bool `protobuf:"varint,5,opt,name=healthy,proto3" json:"healthy,omitempty"` // Maps from the node ID to its attached peer infos. AttachedPeerInfos map[string]*ListOfAttachedPeerInfo `` /* 202-byte string literal not displayed */ // Set to "true" once custom blockchains are ready. CustomChainsHealthy bool `protobuf:"varint,7,opt,name=custom_chains_healthy,json=customChainsHealthy,proto3" json:"custom_chains_healthy,omitempty"` // The map of blockchain IDs in "ids.ID" format to its blockchain information. CustomChains map[string]*CustomChainInfo `` /* 185-byte string literal not displayed */ Subnets []string `protobuf:"bytes,9,rep,name=subnets,proto3" json:"subnets,omitempty"` // contains filtered or unexported fields }
func (*ClusterInfo) Descriptor
deprecated
func (*ClusterInfo) Descriptor() ([]byte, []int)
Deprecated: Use ClusterInfo.ProtoReflect.Descriptor instead.
func (*ClusterInfo) GetAttachedPeerInfos ¶
func (x *ClusterInfo) GetAttachedPeerInfos() map[string]*ListOfAttachedPeerInfo
func (*ClusterInfo) GetCustomChains ¶ added in v0.2.0
func (x *ClusterInfo) GetCustomChains() map[string]*CustomChainInfo
func (*ClusterInfo) GetCustomChainsHealthy ¶ added in v0.2.0
func (x *ClusterInfo) GetCustomChainsHealthy() bool
func (*ClusterInfo) GetHealthy ¶
func (x *ClusterInfo) GetHealthy() bool
func (*ClusterInfo) GetNodeInfos ¶
func (x *ClusterInfo) GetNodeInfos() map[string]*NodeInfo
func (*ClusterInfo) GetNodeNames ¶
func (x *ClusterInfo) GetNodeNames() []string
func (*ClusterInfo) GetPid ¶
func (x *ClusterInfo) GetPid() int32
func (*ClusterInfo) GetRootDataDir ¶
func (x *ClusterInfo) GetRootDataDir() string
func (*ClusterInfo) GetSubnets ¶ added in v0.2.0
func (x *ClusterInfo) GetSubnets() []string
func (*ClusterInfo) ProtoMessage ¶
func (*ClusterInfo) ProtoMessage()
func (*ClusterInfo) ProtoReflect ¶
func (x *ClusterInfo) ProtoReflect() protoreflect.Message
func (*ClusterInfo) Reset ¶
func (x *ClusterInfo) Reset()
func (*ClusterInfo) String ¶
func (x *ClusterInfo) String() string
type ControlServiceClient ¶
type ControlServiceClient interface { Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) CreateBlockchains(ctx context.Context, in *CreateBlockchainsRequest, opts ...grpc.CallOption) (*CreateBlockchainsResponse, error) CreateSubnets(ctx context.Context, in *CreateSubnetsRequest, opts ...grpc.CallOption) (*CreateSubnetsResponse, error) Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error) URIs(ctx context.Context, in *URIsRequest, opts ...grpc.CallOption) (*URIsResponse, error) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) StreamStatus(ctx context.Context, in *StreamStatusRequest, opts ...grpc.CallOption) (ControlService_StreamStatusClient, error) RemoveNode(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error) AddNode(ctx context.Context, in *AddNodeRequest, opts ...grpc.CallOption) (*AddNodeResponse, error) RestartNode(ctx context.Context, in *RestartNodeRequest, opts ...grpc.CallOption) (*RestartNodeResponse, error) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error) AttachPeer(ctx context.Context, in *AttachPeerRequest, opts ...grpc.CallOption) (*AttachPeerResponse, error) SendOutboundMessage(ctx context.Context, in *SendOutboundMessageRequest, opts ...grpc.CallOption) (*SendOutboundMessageResponse, error) SaveSnapshot(ctx context.Context, in *SaveSnapshotRequest, opts ...grpc.CallOption) (*SaveSnapshotResponse, error) LoadSnapshot(ctx context.Context, in *LoadSnapshotRequest, opts ...grpc.CallOption) (*LoadSnapshotResponse, error) RemoveSnapshot(ctx context.Context, in *RemoveSnapshotRequest, opts ...grpc.CallOption) (*RemoveSnapshotResponse, error) GetSnapshotNames(ctx context.Context, in *GetSnapshotNamesRequest, opts ...grpc.CallOption) (*GetSnapshotNamesResponse, error) }
ControlServiceClient is the client API for ControlService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewControlServiceClient ¶
func NewControlServiceClient(cc grpc.ClientConnInterface) ControlServiceClient
type ControlServiceServer ¶
type ControlServiceServer interface { Start(context.Context, *StartRequest) (*StartResponse, error) CreateBlockchains(context.Context, *CreateBlockchainsRequest) (*CreateBlockchainsResponse, error) CreateSubnets(context.Context, *CreateSubnetsRequest) (*CreateSubnetsResponse, error) Health(context.Context, *HealthRequest) (*HealthResponse, error) URIs(context.Context, *URIsRequest) (*URIsResponse, error) Status(context.Context, *StatusRequest) (*StatusResponse, error) StreamStatus(*StreamStatusRequest, ControlService_StreamStatusServer) error RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error) AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error) RestartNode(context.Context, *RestartNodeRequest) (*RestartNodeResponse, error) Stop(context.Context, *StopRequest) (*StopResponse, error) AttachPeer(context.Context, *AttachPeerRequest) (*AttachPeerResponse, error) SendOutboundMessage(context.Context, *SendOutboundMessageRequest) (*SendOutboundMessageResponse, error) SaveSnapshot(context.Context, *SaveSnapshotRequest) (*SaveSnapshotResponse, error) LoadSnapshot(context.Context, *LoadSnapshotRequest) (*LoadSnapshotResponse, error) RemoveSnapshot(context.Context, *RemoveSnapshotRequest) (*RemoveSnapshotResponse, error) GetSnapshotNames(context.Context, *GetSnapshotNamesRequest) (*GetSnapshotNamesResponse, error) // contains filtered or unexported methods }
ControlServiceServer is the server API for ControlService service. All implementations must embed UnimplementedControlServiceServer for forward compatibility
type ControlService_StreamStatusClient ¶
type ControlService_StreamStatusClient interface { Recv() (*StreamStatusResponse, error) grpc.ClientStream }
type ControlService_StreamStatusServer ¶
type ControlService_StreamStatusServer interface { Send(*StreamStatusResponse) error grpc.ServerStream }
type CreateBlockchainsRequest ¶ added in v0.2.0
type CreateBlockchainsRequest struct { // The list of: // - custom chain's VM name // - genesis file path // - (optional) subnet id to use. // - chain config file path // - network upgrade file path // // The matching file with the name in "ids.ID" format must exist. // e.g., ids.ToID(hashing.ComputeHash256("subnetevm")).String() // e.g., subnet-cli create VMID subnetevm // // If this field is set to none (by default), the node/network-runner // will return error BlockchainSpecs []*BlockchainSpec `protobuf:"bytes,1,rep,name=blockchain_specs,json=blockchainSpecs,proto3" json:"blockchain_specs,omitempty"` // contains filtered or unexported fields }
func (*CreateBlockchainsRequest) Descriptor
deprecated
added in
v0.2.0
func (*CreateBlockchainsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateBlockchainsRequest.ProtoReflect.Descriptor instead.
func (*CreateBlockchainsRequest) GetBlockchainSpecs ¶ added in v0.2.0
func (x *CreateBlockchainsRequest) GetBlockchainSpecs() []*BlockchainSpec
func (*CreateBlockchainsRequest) ProtoMessage ¶ added in v0.2.0
func (*CreateBlockchainsRequest) ProtoMessage()
func (*CreateBlockchainsRequest) ProtoReflect ¶ added in v0.2.0
func (x *CreateBlockchainsRequest) ProtoReflect() protoreflect.Message
func (*CreateBlockchainsRequest) Reset ¶ added in v0.2.0
func (x *CreateBlockchainsRequest) Reset()
func (*CreateBlockchainsRequest) String ¶ added in v0.2.0
func (x *CreateBlockchainsRequest) String() string
type CreateBlockchainsResponse ¶ added in v0.2.0
type CreateBlockchainsResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*CreateBlockchainsResponse) Descriptor
deprecated
added in
v0.2.0
func (*CreateBlockchainsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateBlockchainsResponse.ProtoReflect.Descriptor instead.
func (*CreateBlockchainsResponse) GetClusterInfo ¶ added in v0.2.0
func (x *CreateBlockchainsResponse) GetClusterInfo() *ClusterInfo
func (*CreateBlockchainsResponse) ProtoMessage ¶ added in v0.2.0
func (*CreateBlockchainsResponse) ProtoMessage()
func (*CreateBlockchainsResponse) ProtoReflect ¶ added in v0.2.0
func (x *CreateBlockchainsResponse) ProtoReflect() protoreflect.Message
func (*CreateBlockchainsResponse) Reset ¶ added in v0.2.0
func (x *CreateBlockchainsResponse) Reset()
func (*CreateBlockchainsResponse) String ¶ added in v0.2.0
func (x *CreateBlockchainsResponse) String() string
type CreateSubnetsRequest ¶ added in v0.2.0
type CreateSubnetsRequest struct { NumSubnets *uint32 `protobuf:"varint,1,opt,name=num_subnets,json=numSubnets,proto3,oneof" json:"num_subnets,omitempty"` // contains filtered or unexported fields }
func (*CreateSubnetsRequest) Descriptor
deprecated
added in
v0.2.0
func (*CreateSubnetsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSubnetsRequest.ProtoReflect.Descriptor instead.
func (*CreateSubnetsRequest) GetNumSubnets ¶ added in v0.2.0
func (x *CreateSubnetsRequest) GetNumSubnets() uint32
func (*CreateSubnetsRequest) ProtoMessage ¶ added in v0.2.0
func (*CreateSubnetsRequest) ProtoMessage()
func (*CreateSubnetsRequest) ProtoReflect ¶ added in v0.2.0
func (x *CreateSubnetsRequest) ProtoReflect() protoreflect.Message
func (*CreateSubnetsRequest) Reset ¶ added in v0.2.0
func (x *CreateSubnetsRequest) Reset()
func (*CreateSubnetsRequest) String ¶ added in v0.2.0
func (x *CreateSubnetsRequest) String() string
type CreateSubnetsResponse ¶ added in v0.2.0
type CreateSubnetsResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*CreateSubnetsResponse) Descriptor
deprecated
added in
v0.2.0
func (*CreateSubnetsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateSubnetsResponse.ProtoReflect.Descriptor instead.
func (*CreateSubnetsResponse) GetClusterInfo ¶ added in v0.2.0
func (x *CreateSubnetsResponse) GetClusterInfo() *ClusterInfo
func (*CreateSubnetsResponse) ProtoMessage ¶ added in v0.2.0
func (*CreateSubnetsResponse) ProtoMessage()
func (*CreateSubnetsResponse) ProtoReflect ¶ added in v0.2.0
func (x *CreateSubnetsResponse) ProtoReflect() protoreflect.Message
func (*CreateSubnetsResponse) Reset ¶ added in v0.2.0
func (x *CreateSubnetsResponse) Reset()
func (*CreateSubnetsResponse) String ¶ added in v0.2.0
func (x *CreateSubnetsResponse) String() string
type CustomChainInfo ¶ added in v0.2.0
type CustomChainInfo struct { // Blockchain name given to the create blockchain TX // Currently used to keep a record of the VM name, // which is not saved anywhere and can't be recovered from VM ID ChainName string `protobuf:"bytes,1,opt,name=chain_name,json=chainName,proto3" json:"chain_name,omitempty"` // VM ID in "ids.ID" format. VmId string `protobuf:"bytes,2,opt,name=vm_id,json=vmId,proto3" json:"vm_id,omitempty"` // Create subnet transaction ID -- subnet ID. // The subnet ID must be whitelisted by the avalanche node. SubnetId string `protobuf:"bytes,3,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"` // Create blockchain transaction ID -- blockchain ID> // The blockchain ID is used for RPC endpoints. ChainId string `protobuf:"bytes,4,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // contains filtered or unexported fields }
func (*CustomChainInfo) Descriptor
deprecated
added in
v0.2.0
func (*CustomChainInfo) Descriptor() ([]byte, []int)
Deprecated: Use CustomChainInfo.ProtoReflect.Descriptor instead.
func (*CustomChainInfo) GetChainId ¶ added in v0.2.0
func (x *CustomChainInfo) GetChainId() string
func (*CustomChainInfo) GetChainName ¶ added in v0.2.0
func (x *CustomChainInfo) GetChainName() string
func (*CustomChainInfo) GetSubnetId ¶ added in v0.2.0
func (x *CustomChainInfo) GetSubnetId() string
func (*CustomChainInfo) GetVmId ¶ added in v0.2.0
func (x *CustomChainInfo) GetVmId() string
func (*CustomChainInfo) ProtoMessage ¶ added in v0.2.0
func (*CustomChainInfo) ProtoMessage()
func (*CustomChainInfo) ProtoReflect ¶ added in v0.2.0
func (x *CustomChainInfo) ProtoReflect() protoreflect.Message
func (*CustomChainInfo) Reset ¶ added in v0.2.0
func (x *CustomChainInfo) Reset()
func (*CustomChainInfo) String ¶ added in v0.2.0
func (x *CustomChainInfo) String() string
type GetSnapshotNamesRequest ¶ added in v0.1.0
type GetSnapshotNamesRequest struct {
// contains filtered or unexported fields
}
func (*GetSnapshotNamesRequest) Descriptor
deprecated
added in
v0.1.0
func (*GetSnapshotNamesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSnapshotNamesRequest.ProtoReflect.Descriptor instead.
func (*GetSnapshotNamesRequest) ProtoMessage ¶ added in v0.1.0
func (*GetSnapshotNamesRequest) ProtoMessage()
func (*GetSnapshotNamesRequest) ProtoReflect ¶ added in v0.1.0
func (x *GetSnapshotNamesRequest) ProtoReflect() protoreflect.Message
func (*GetSnapshotNamesRequest) Reset ¶ added in v0.1.0
func (x *GetSnapshotNamesRequest) Reset()
func (*GetSnapshotNamesRequest) String ¶ added in v0.1.0
func (x *GetSnapshotNamesRequest) String() string
type GetSnapshotNamesResponse ¶ added in v0.1.0
type GetSnapshotNamesResponse struct { SnapshotNames []string `protobuf:"bytes,1,rep,name=snapshot_names,json=snapshotNames,proto3" json:"snapshot_names,omitempty"` // contains filtered or unexported fields }
func (*GetSnapshotNamesResponse) Descriptor
deprecated
added in
v0.1.0
func (*GetSnapshotNamesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSnapshotNamesResponse.ProtoReflect.Descriptor instead.
func (*GetSnapshotNamesResponse) GetSnapshotNames ¶ added in v0.1.0
func (x *GetSnapshotNamesResponse) GetSnapshotNames() []string
func (*GetSnapshotNamesResponse) ProtoMessage ¶ added in v0.1.0
func (*GetSnapshotNamesResponse) ProtoMessage()
func (*GetSnapshotNamesResponse) ProtoReflect ¶ added in v0.1.0
func (x *GetSnapshotNamesResponse) ProtoReflect() protoreflect.Message
func (*GetSnapshotNamesResponse) Reset ¶ added in v0.1.0
func (x *GetSnapshotNamesResponse) Reset()
func (*GetSnapshotNamesResponse) String ¶ added in v0.1.0
func (x *GetSnapshotNamesResponse) String() string
type HealthRequest ¶
type HealthRequest struct {
// contains filtered or unexported fields
}
func (*HealthRequest) Descriptor
deprecated
func (*HealthRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthRequest.ProtoReflect.Descriptor instead.
func (*HealthRequest) ProtoMessage ¶
func (*HealthRequest) ProtoMessage()
func (*HealthRequest) ProtoReflect ¶
func (x *HealthRequest) ProtoReflect() protoreflect.Message
func (*HealthRequest) Reset ¶
func (x *HealthRequest) Reset()
func (*HealthRequest) String ¶
func (x *HealthRequest) String() string
type HealthResponse ¶
type HealthResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*HealthResponse) Descriptor
deprecated
func (*HealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.
func (*HealthResponse) GetClusterInfo ¶
func (x *HealthResponse) GetClusterInfo() *ClusterInfo
func (*HealthResponse) ProtoMessage ¶
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) ProtoReflect ¶
func (x *HealthResponse) ProtoReflect() protoreflect.Message
func (*HealthResponse) Reset ¶
func (x *HealthResponse) Reset()
func (*HealthResponse) String ¶
func (x *HealthResponse) String() string
type ListOfAttachedPeerInfo ¶
type ListOfAttachedPeerInfo struct { Peers []*AttachedPeerInfo `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"` // contains filtered or unexported fields }
func (*ListOfAttachedPeerInfo) Descriptor
deprecated
func (*ListOfAttachedPeerInfo) Descriptor() ([]byte, []int)
Deprecated: Use ListOfAttachedPeerInfo.ProtoReflect.Descriptor instead.
func (*ListOfAttachedPeerInfo) GetPeers ¶
func (x *ListOfAttachedPeerInfo) GetPeers() []*AttachedPeerInfo
func (*ListOfAttachedPeerInfo) ProtoMessage ¶
func (*ListOfAttachedPeerInfo) ProtoMessage()
func (*ListOfAttachedPeerInfo) ProtoReflect ¶
func (x *ListOfAttachedPeerInfo) ProtoReflect() protoreflect.Message
func (*ListOfAttachedPeerInfo) Reset ¶
func (x *ListOfAttachedPeerInfo) Reset()
func (*ListOfAttachedPeerInfo) String ¶
func (x *ListOfAttachedPeerInfo) String() string
type LoadSnapshotRequest ¶ added in v0.1.0
type LoadSnapshotRequest struct { SnapshotName string `protobuf:"bytes,1,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"` ExecPath *string `protobuf:"bytes,2,opt,name=exec_path,json=execPath,proto3,oneof" json:"exec_path,omitempty"` PluginDir *string `protobuf:"bytes,3,opt,name=plugin_dir,json=pluginDir,proto3,oneof" json:"plugin_dir,omitempty"` RootDataDir *string `protobuf:"bytes,4,opt,name=root_data_dir,json=rootDataDir,proto3,oneof" json:"root_data_dir,omitempty"` ChainConfigs map[string]string `` /* 185-byte string literal not displayed */ UpgradeConfigs map[string]string `` /* 191-byte string literal not displayed */ GlobalNodeConfig *string `protobuf:"bytes,7,opt,name=global_node_config,json=globalNodeConfig,proto3,oneof" json:"global_node_config,omitempty"` ReassignPortsIfUsed *bool `` /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
func (*LoadSnapshotRequest) Descriptor
deprecated
added in
v0.1.0
func (*LoadSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadSnapshotRequest.ProtoReflect.Descriptor instead.
func (*LoadSnapshotRequest) GetChainConfigs ¶ added in v0.2.0
func (x *LoadSnapshotRequest) GetChainConfigs() map[string]string
func (*LoadSnapshotRequest) GetExecPath ¶ added in v0.2.0
func (x *LoadSnapshotRequest) GetExecPath() string
func (*LoadSnapshotRequest) GetGlobalNodeConfig ¶ added in v0.2.0
func (x *LoadSnapshotRequest) GetGlobalNodeConfig() string
func (*LoadSnapshotRequest) GetPluginDir ¶ added in v0.2.0
func (x *LoadSnapshotRequest) GetPluginDir() string
func (*LoadSnapshotRequest) GetReassignPortsIfUsed ¶ added in v0.3.0
func (x *LoadSnapshotRequest) GetReassignPortsIfUsed() bool
func (*LoadSnapshotRequest) GetRootDataDir ¶ added in v0.2.0
func (x *LoadSnapshotRequest) GetRootDataDir() string
func (*LoadSnapshotRequest) GetSnapshotName ¶ added in v0.1.0
func (x *LoadSnapshotRequest) GetSnapshotName() string
func (*LoadSnapshotRequest) GetUpgradeConfigs ¶ added in v0.2.0
func (x *LoadSnapshotRequest) GetUpgradeConfigs() map[string]string
func (*LoadSnapshotRequest) ProtoMessage ¶ added in v0.1.0
func (*LoadSnapshotRequest) ProtoMessage()
func (*LoadSnapshotRequest) ProtoReflect ¶ added in v0.1.0
func (x *LoadSnapshotRequest) ProtoReflect() protoreflect.Message
func (*LoadSnapshotRequest) Reset ¶ added in v0.1.0
func (x *LoadSnapshotRequest) Reset()
func (*LoadSnapshotRequest) String ¶ added in v0.1.0
func (x *LoadSnapshotRequest) String() string
type LoadSnapshotResponse ¶ added in v0.1.0
type LoadSnapshotResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*LoadSnapshotResponse) Descriptor
deprecated
added in
v0.1.0
func (*LoadSnapshotResponse) Descriptor() ([]byte, []int)
Deprecated: Use LoadSnapshotResponse.ProtoReflect.Descriptor instead.
func (*LoadSnapshotResponse) GetClusterInfo ¶ added in v0.1.0
func (x *LoadSnapshotResponse) GetClusterInfo() *ClusterInfo
func (*LoadSnapshotResponse) ProtoMessage ¶ added in v0.1.0
func (*LoadSnapshotResponse) ProtoMessage()
func (*LoadSnapshotResponse) ProtoReflect ¶ added in v0.1.0
func (x *LoadSnapshotResponse) ProtoReflect() protoreflect.Message
func (*LoadSnapshotResponse) Reset ¶ added in v0.1.0
func (x *LoadSnapshotResponse) Reset()
func (*LoadSnapshotResponse) String ¶ added in v0.1.0
func (x *LoadSnapshotResponse) String() string
type NodeInfo ¶
type NodeInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ExecPath string `protobuf:"bytes,2,opt,name=exec_path,json=execPath,proto3" json:"exec_path,omitempty"` Uri string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"` Id string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"` LogDir string `protobuf:"bytes,5,opt,name=log_dir,json=logDir,proto3" json:"log_dir,omitempty"` DbDir string `protobuf:"bytes,6,opt,name=db_dir,json=dbDir,proto3" json:"db_dir,omitempty"` PluginDir string `protobuf:"bytes,7,opt,name=plugin_dir,json=pluginDir,proto3" json:"plugin_dir,omitempty"` WhitelistedSubnets string `protobuf:"bytes,8,opt,name=whitelisted_subnets,json=whitelistedSubnets,proto3" json:"whitelisted_subnets,omitempty"` Config []byte `protobuf:"bytes,9,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*NodeInfo) Descriptor
deprecated
func (*NodeInfo) GetExecPath ¶
func (*NodeInfo) GetPluginDir ¶
func (*NodeInfo) GetWhitelistedSubnets ¶
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) ProtoReflect ¶
func (x *NodeInfo) ProtoReflect() protoreflect.Message
type PingRequest ¶
type PingRequest struct {
// contains filtered or unexported fields
}
func (*PingRequest) Descriptor
deprecated
func (*PingRequest) Descriptor() ([]byte, []int)
Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) ProtoReflect ¶
func (x *PingRequest) ProtoReflect() protoreflect.Message
func (*PingRequest) Reset ¶
func (x *PingRequest) Reset()
func (*PingRequest) String ¶
func (x *PingRequest) String() string
type PingResponse ¶
type PingResponse struct { Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` // contains filtered or unexported fields }
func (*PingResponse) Descriptor
deprecated
func (*PingResponse) Descriptor() ([]byte, []int)
Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.
func (*PingResponse) GetPid ¶
func (x *PingResponse) GetPid() int32
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) ProtoReflect ¶
func (x *PingResponse) ProtoReflect() protoreflect.Message
func (*PingResponse) Reset ¶
func (x *PingResponse) Reset()
func (*PingResponse) String ¶
func (x *PingResponse) String() string
type PingServiceClient ¶
type PingServiceClient interface {
Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}
PingServiceClient is the client API for PingService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewPingServiceClient ¶
func NewPingServiceClient(cc grpc.ClientConnInterface) PingServiceClient
type PingServiceServer ¶
type PingServiceServer interface { Ping(context.Context, *PingRequest) (*PingResponse, error) // contains filtered or unexported methods }
PingServiceServer is the server API for PingService service. All implementations must embed UnimplementedPingServiceServer for forward compatibility
type RemoveNodeRequest ¶
type RemoveNodeRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*RemoveNodeRequest) Descriptor
deprecated
func (*RemoveNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveNodeRequest.ProtoReflect.Descriptor instead.
func (*RemoveNodeRequest) GetName ¶
func (x *RemoveNodeRequest) GetName() string
func (*RemoveNodeRequest) ProtoMessage ¶
func (*RemoveNodeRequest) ProtoMessage()
func (*RemoveNodeRequest) ProtoReflect ¶
func (x *RemoveNodeRequest) ProtoReflect() protoreflect.Message
func (*RemoveNodeRequest) Reset ¶
func (x *RemoveNodeRequest) Reset()
func (*RemoveNodeRequest) String ¶
func (x *RemoveNodeRequest) String() string
type RemoveNodeResponse ¶
type RemoveNodeResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*RemoveNodeResponse) Descriptor
deprecated
func (*RemoveNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveNodeResponse.ProtoReflect.Descriptor instead.
func (*RemoveNodeResponse) GetClusterInfo ¶
func (x *RemoveNodeResponse) GetClusterInfo() *ClusterInfo
func (*RemoveNodeResponse) ProtoMessage ¶
func (*RemoveNodeResponse) ProtoMessage()
func (*RemoveNodeResponse) ProtoReflect ¶
func (x *RemoveNodeResponse) ProtoReflect() protoreflect.Message
func (*RemoveNodeResponse) Reset ¶
func (x *RemoveNodeResponse) Reset()
func (*RemoveNodeResponse) String ¶
func (x *RemoveNodeResponse) String() string
type RemoveSnapshotRequest ¶ added in v0.1.0
type RemoveSnapshotRequest struct { SnapshotName string `protobuf:"bytes,1,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"` // contains filtered or unexported fields }
func (*RemoveSnapshotRequest) Descriptor
deprecated
added in
v0.1.0
func (*RemoveSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveSnapshotRequest.ProtoReflect.Descriptor instead.
func (*RemoveSnapshotRequest) GetSnapshotName ¶ added in v0.1.0
func (x *RemoveSnapshotRequest) GetSnapshotName() string
func (*RemoveSnapshotRequest) ProtoMessage ¶ added in v0.1.0
func (*RemoveSnapshotRequest) ProtoMessage()
func (*RemoveSnapshotRequest) ProtoReflect ¶ added in v0.1.0
func (x *RemoveSnapshotRequest) ProtoReflect() protoreflect.Message
func (*RemoveSnapshotRequest) Reset ¶ added in v0.1.0
func (x *RemoveSnapshotRequest) Reset()
func (*RemoveSnapshotRequest) String ¶ added in v0.1.0
func (x *RemoveSnapshotRequest) String() string
type RemoveSnapshotResponse ¶ added in v0.1.0
type RemoveSnapshotResponse struct {
// contains filtered or unexported fields
}
func (*RemoveSnapshotResponse) Descriptor
deprecated
added in
v0.1.0
func (*RemoveSnapshotResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveSnapshotResponse.ProtoReflect.Descriptor instead.
func (*RemoveSnapshotResponse) ProtoMessage ¶ added in v0.1.0
func (*RemoveSnapshotResponse) ProtoMessage()
func (*RemoveSnapshotResponse) ProtoReflect ¶ added in v0.1.0
func (x *RemoveSnapshotResponse) ProtoReflect() protoreflect.Message
func (*RemoveSnapshotResponse) Reset ¶ added in v0.1.0
func (x *RemoveSnapshotResponse) Reset()
func (*RemoveSnapshotResponse) String ¶ added in v0.1.0
func (x *RemoveSnapshotResponse) String() string
type RestartNodeRequest ¶
type RestartNodeRequest struct { // Must be a valid node name. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Optional fields are set to the previous values if empty. ExecPath *string `protobuf:"bytes,2,opt,name=exec_path,json=execPath,proto3,oneof" json:"exec_path,omitempty"` WhitelistedSubnets *string `protobuf:"bytes,3,opt,name=whitelisted_subnets,json=whitelistedSubnets,proto3,oneof" json:"whitelisted_subnets,omitempty"` // Map of chain name to config file contents. // If specified, will create a file "chainname/config.json" with // the contents provided here. ChainConfigs map[string]string `` /* 185-byte string literal not displayed */ // Map of chain name to config file contents. // If specified, will create a file "chainname/upgrade.json" with // the contents provided here. UpgradeConfigs map[string]string `` /* 191-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RestartNodeRequest) Descriptor
deprecated
func (*RestartNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestartNodeRequest.ProtoReflect.Descriptor instead.
func (*RestartNodeRequest) GetChainConfigs ¶ added in v0.2.0
func (x *RestartNodeRequest) GetChainConfigs() map[string]string
func (*RestartNodeRequest) GetExecPath ¶
func (x *RestartNodeRequest) GetExecPath() string
func (*RestartNodeRequest) GetName ¶
func (x *RestartNodeRequest) GetName() string
func (*RestartNodeRequest) GetUpgradeConfigs ¶ added in v0.2.0
func (x *RestartNodeRequest) GetUpgradeConfigs() map[string]string
func (*RestartNodeRequest) GetWhitelistedSubnets ¶
func (x *RestartNodeRequest) GetWhitelistedSubnets() string
func (*RestartNodeRequest) ProtoMessage ¶
func (*RestartNodeRequest) ProtoMessage()
func (*RestartNodeRequest) ProtoReflect ¶
func (x *RestartNodeRequest) ProtoReflect() protoreflect.Message
func (*RestartNodeRequest) Reset ¶
func (x *RestartNodeRequest) Reset()
func (*RestartNodeRequest) String ¶
func (x *RestartNodeRequest) String() string
type RestartNodeResponse ¶
type RestartNodeResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*RestartNodeResponse) Descriptor
deprecated
func (*RestartNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use RestartNodeResponse.ProtoReflect.Descriptor instead.
func (*RestartNodeResponse) GetClusterInfo ¶
func (x *RestartNodeResponse) GetClusterInfo() *ClusterInfo
func (*RestartNodeResponse) ProtoMessage ¶
func (*RestartNodeResponse) ProtoMessage()
func (*RestartNodeResponse) ProtoReflect ¶
func (x *RestartNodeResponse) ProtoReflect() protoreflect.Message
func (*RestartNodeResponse) Reset ¶
func (x *RestartNodeResponse) Reset()
func (*RestartNodeResponse) String ¶
func (x *RestartNodeResponse) String() string
type SaveSnapshotRequest ¶ added in v0.1.0
type SaveSnapshotRequest struct { SnapshotName string `protobuf:"bytes,1,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"` // contains filtered or unexported fields }
func (*SaveSnapshotRequest) Descriptor
deprecated
added in
v0.1.0
func (*SaveSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use SaveSnapshotRequest.ProtoReflect.Descriptor instead.
func (*SaveSnapshotRequest) GetSnapshotName ¶ added in v0.1.0
func (x *SaveSnapshotRequest) GetSnapshotName() string
func (*SaveSnapshotRequest) ProtoMessage ¶ added in v0.1.0
func (*SaveSnapshotRequest) ProtoMessage()
func (*SaveSnapshotRequest) ProtoReflect ¶ added in v0.1.0
func (x *SaveSnapshotRequest) ProtoReflect() protoreflect.Message
func (*SaveSnapshotRequest) Reset ¶ added in v0.1.0
func (x *SaveSnapshotRequest) Reset()
func (*SaveSnapshotRequest) String ¶ added in v0.1.0
func (x *SaveSnapshotRequest) String() string
type SaveSnapshotResponse ¶ added in v0.1.0
type SaveSnapshotResponse struct { SnapshotPath string `protobuf:"bytes,1,opt,name=snapshot_path,json=snapshotPath,proto3" json:"snapshot_path,omitempty"` // contains filtered or unexported fields }
func (*SaveSnapshotResponse) Descriptor
deprecated
added in
v0.1.0
func (*SaveSnapshotResponse) Descriptor() ([]byte, []int)
Deprecated: Use SaveSnapshotResponse.ProtoReflect.Descriptor instead.
func (*SaveSnapshotResponse) GetSnapshotPath ¶ added in v0.1.0
func (x *SaveSnapshotResponse) GetSnapshotPath() string
func (*SaveSnapshotResponse) ProtoMessage ¶ added in v0.1.0
func (*SaveSnapshotResponse) ProtoMessage()
func (*SaveSnapshotResponse) ProtoReflect ¶ added in v0.1.0
func (x *SaveSnapshotResponse) ProtoReflect() protoreflect.Message
func (*SaveSnapshotResponse) Reset ¶ added in v0.1.0
func (x *SaveSnapshotResponse) Reset()
func (*SaveSnapshotResponse) String ¶ added in v0.1.0
func (x *SaveSnapshotResponse) String() string
type SendOutboundMessageRequest ¶
type SendOutboundMessageRequest struct { NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` PeerId string `protobuf:"bytes,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"` Op uint32 `protobuf:"varint,3,opt,name=op,proto3" json:"op,omitempty"` Bytes []byte `protobuf:"bytes,4,opt,name=bytes,proto3" json:"bytes,omitempty"` // contains filtered or unexported fields }
func (*SendOutboundMessageRequest) Descriptor
deprecated
func (*SendOutboundMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendOutboundMessageRequest.ProtoReflect.Descriptor instead.
func (*SendOutboundMessageRequest) GetBytes ¶
func (x *SendOutboundMessageRequest) GetBytes() []byte
func (*SendOutboundMessageRequest) GetNodeName ¶
func (x *SendOutboundMessageRequest) GetNodeName() string
func (*SendOutboundMessageRequest) GetOp ¶
func (x *SendOutboundMessageRequest) GetOp() uint32
func (*SendOutboundMessageRequest) GetPeerId ¶
func (x *SendOutboundMessageRequest) GetPeerId() string
func (*SendOutboundMessageRequest) ProtoMessage ¶
func (*SendOutboundMessageRequest) ProtoMessage()
func (*SendOutboundMessageRequest) ProtoReflect ¶
func (x *SendOutboundMessageRequest) ProtoReflect() protoreflect.Message
func (*SendOutboundMessageRequest) Reset ¶
func (x *SendOutboundMessageRequest) Reset()
func (*SendOutboundMessageRequest) String ¶
func (x *SendOutboundMessageRequest) String() string
type SendOutboundMessageResponse ¶
type SendOutboundMessageResponse struct { Sent bool `protobuf:"varint,1,opt,name=sent,proto3" json:"sent,omitempty"` // contains filtered or unexported fields }
func (*SendOutboundMessageResponse) Descriptor
deprecated
func (*SendOutboundMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use SendOutboundMessageResponse.ProtoReflect.Descriptor instead.
func (*SendOutboundMessageResponse) GetSent ¶
func (x *SendOutboundMessageResponse) GetSent() bool
func (*SendOutboundMessageResponse) ProtoMessage ¶
func (*SendOutboundMessageResponse) ProtoMessage()
func (*SendOutboundMessageResponse) ProtoReflect ¶
func (x *SendOutboundMessageResponse) ProtoReflect() protoreflect.Message
func (*SendOutboundMessageResponse) Reset ¶
func (x *SendOutboundMessageResponse) Reset()
func (*SendOutboundMessageResponse) String ¶
func (x *SendOutboundMessageResponse) String() string
type StartRequest ¶
type StartRequest struct { ExecPath string `protobuf:"bytes,1,opt,name=exec_path,json=execPath,proto3" json:"exec_path,omitempty"` NumNodes *uint32 `protobuf:"varint,2,opt,name=num_nodes,json=numNodes,proto3,oneof" json:"num_nodes,omitempty"` WhitelistedSubnets *string `protobuf:"bytes,3,opt,name=whitelisted_subnets,json=whitelistedSubnets,proto3,oneof" json:"whitelisted_subnets,omitempty"` GlobalNodeConfig *string `protobuf:"bytes,4,opt,name=global_node_config,json=globalNodeConfig,proto3,oneof" json:"global_node_config,omitempty"` // Used for both database and log files. RootDataDir *string `protobuf:"bytes,5,opt,name=root_data_dir,json=rootDataDir,proto3,oneof" json:"root_data_dir,omitempty"` // Build directory that contains the subdir 'plugins' from which to load all custom VM executables. // If not specified, will be derived from the exec_path (its basedir) PluginDir *string `protobuf:"bytes,6,opt,name=plugin_dir,json=pluginDir,proto3,oneof" json:"plugin_dir,omitempty"` // The list of: // - custom chain's VM name // - genesis file path // - (optional) subnet id to use. // - chain config file path // - network upgrade file path // // subnet id must be always nil when using StartRequest, as the network is empty and has no preloaded // subnet ids available. // // The matching file with the name in "ids.ID" format must exist. // e.g., ids.ToID(hashing.ComputeHash256("subnetevm")).String() // e.g., subnet-cli create VMID subnetevm // // If this field is set to none (by default), the node/network-runner // does not install the custom chain and does not create the subnet, // even if the VM binary exists on the local plugins directory. BlockchainSpecs []*BlockchainSpec `protobuf:"bytes,7,rep,name=blockchain_specs,json=blockchainSpecs,proto3" json:"blockchain_specs,omitempty"` CustomNodeConfigs map[string]string `` /* 202-byte string literal not displayed */ // Map of chain name to config file contents. // If specified, will create a file "chainname/config.json" with // the contents provided here. ChainConfigs map[string]string `` /* 185-byte string literal not displayed */ // Map of chain name to upgrade file contents. // If specified, will create a file "chainname/upgrade.json" with // the contents provided here. UpgradeConfigs map[string]string `` /* 192-byte string literal not displayed */ // reassign default/custom ports if they are already taken ReassignPortsIfUsed *bool `` /* 130-byte string literal not displayed */ // use dynamic ports instead of default ones DynamicPorts *bool `protobuf:"varint,12,opt,name=dynamic_ports,json=dynamicPorts,proto3,oneof" json:"dynamic_ports,omitempty"` // contains filtered or unexported fields }
func (*StartRequest) Descriptor
deprecated
func (*StartRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
func (*StartRequest) GetBlockchainSpecs ¶ added in v0.2.0
func (x *StartRequest) GetBlockchainSpecs() []*BlockchainSpec
func (*StartRequest) GetChainConfigs ¶ added in v0.2.0
func (x *StartRequest) GetChainConfigs() map[string]string
func (*StartRequest) GetCustomNodeConfigs ¶
func (x *StartRequest) GetCustomNodeConfigs() map[string]string
func (*StartRequest) GetDynamicPorts ¶ added in v0.3.0
func (x *StartRequest) GetDynamicPorts() bool
func (*StartRequest) GetExecPath ¶
func (x *StartRequest) GetExecPath() string
func (*StartRequest) GetGlobalNodeConfig ¶
func (x *StartRequest) GetGlobalNodeConfig() string
func (*StartRequest) GetNumNodes ¶
func (x *StartRequest) GetNumNodes() uint32
func (*StartRequest) GetPluginDir ¶
func (x *StartRequest) GetPluginDir() string
func (*StartRequest) GetReassignPortsIfUsed ¶ added in v0.3.0
func (x *StartRequest) GetReassignPortsIfUsed() bool
func (*StartRequest) GetRootDataDir ¶
func (x *StartRequest) GetRootDataDir() string
func (*StartRequest) GetUpgradeConfigs ¶ added in v0.2.0
func (x *StartRequest) GetUpgradeConfigs() map[string]string
func (*StartRequest) GetWhitelistedSubnets ¶
func (x *StartRequest) GetWhitelistedSubnets() string
func (*StartRequest) ProtoMessage ¶
func (*StartRequest) ProtoMessage()
func (*StartRequest) ProtoReflect ¶
func (x *StartRequest) ProtoReflect() protoreflect.Message
func (*StartRequest) Reset ¶
func (x *StartRequest) Reset()
func (*StartRequest) String ¶
func (x *StartRequest) String() string
type StartResponse ¶
type StartResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*StartResponse) Descriptor
deprecated
func (*StartResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.
func (*StartResponse) GetClusterInfo ¶
func (x *StartResponse) GetClusterInfo() *ClusterInfo
func (*StartResponse) ProtoMessage ¶
func (*StartResponse) ProtoMessage()
func (*StartResponse) ProtoReflect ¶
func (x *StartResponse) ProtoReflect() protoreflect.Message
func (*StartResponse) Reset ¶
func (x *StartResponse) Reset()
func (*StartResponse) String ¶
func (x *StartResponse) String() string
type StatusRequest ¶
type StatusRequest struct {
// contains filtered or unexported fields
}
func (*StatusRequest) Descriptor
deprecated
func (*StatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) ProtoReflect ¶
func (x *StatusRequest) ProtoReflect() protoreflect.Message
func (*StatusRequest) Reset ¶
func (x *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (x *StatusRequest) String() string
type StatusResponse ¶
type StatusResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*StatusResponse) Descriptor
deprecated
func (*StatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.
func (*StatusResponse) GetClusterInfo ¶
func (x *StatusResponse) GetClusterInfo() *ClusterInfo
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) ProtoReflect ¶
func (x *StatusResponse) ProtoReflect() protoreflect.Message
func (*StatusResponse) Reset ¶
func (x *StatusResponse) Reset()
func (*StatusResponse) String ¶
func (x *StatusResponse) String() string
type StopRequest ¶
type StopRequest struct {
// contains filtered or unexported fields
}
func (*StopRequest) Descriptor
deprecated
func (*StopRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.
func (*StopRequest) ProtoMessage ¶
func (*StopRequest) ProtoMessage()
func (*StopRequest) ProtoReflect ¶
func (x *StopRequest) ProtoReflect() protoreflect.Message
func (*StopRequest) Reset ¶
func (x *StopRequest) Reset()
func (*StopRequest) String ¶
func (x *StopRequest) String() string
type StopResponse ¶
type StopResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*StopResponse) Descriptor
deprecated
func (*StopResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.
func (*StopResponse) GetClusterInfo ¶
func (x *StopResponse) GetClusterInfo() *ClusterInfo
func (*StopResponse) ProtoMessage ¶
func (*StopResponse) ProtoMessage()
func (*StopResponse) ProtoReflect ¶
func (x *StopResponse) ProtoReflect() protoreflect.Message
func (*StopResponse) Reset ¶
func (x *StopResponse) Reset()
func (*StopResponse) String ¶
func (x *StopResponse) String() string
type StreamStatusRequest ¶
type StreamStatusRequest struct { PushInterval int64 `protobuf:"varint,1,opt,name=push_interval,json=pushInterval,proto3" json:"push_interval,omitempty"` // contains filtered or unexported fields }
func (*StreamStatusRequest) Descriptor
deprecated
func (*StreamStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamStatusRequest.ProtoReflect.Descriptor instead.
func (*StreamStatusRequest) GetPushInterval ¶
func (x *StreamStatusRequest) GetPushInterval() int64
func (*StreamStatusRequest) ProtoMessage ¶
func (*StreamStatusRequest) ProtoMessage()
func (*StreamStatusRequest) ProtoReflect ¶
func (x *StreamStatusRequest) ProtoReflect() protoreflect.Message
func (*StreamStatusRequest) Reset ¶
func (x *StreamStatusRequest) Reset()
func (*StreamStatusRequest) String ¶
func (x *StreamStatusRequest) String() string
type StreamStatusResponse ¶
type StreamStatusResponse struct { ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"` // contains filtered or unexported fields }
func (*StreamStatusResponse) Descriptor
deprecated
func (*StreamStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamStatusResponse.ProtoReflect.Descriptor instead.
func (*StreamStatusResponse) GetClusterInfo ¶
func (x *StreamStatusResponse) GetClusterInfo() *ClusterInfo
func (*StreamStatusResponse) ProtoMessage ¶
func (*StreamStatusResponse) ProtoMessage()
func (*StreamStatusResponse) ProtoReflect ¶
func (x *StreamStatusResponse) ProtoReflect() protoreflect.Message
func (*StreamStatusResponse) Reset ¶
func (x *StreamStatusResponse) Reset()
func (*StreamStatusResponse) String ¶
func (x *StreamStatusResponse) String() string
type URIsRequest ¶
type URIsRequest struct {
// contains filtered or unexported fields
}
func (*URIsRequest) Descriptor
deprecated
func (*URIsRequest) Descriptor() ([]byte, []int)
Deprecated: Use URIsRequest.ProtoReflect.Descriptor instead.
func (*URIsRequest) ProtoMessage ¶
func (*URIsRequest) ProtoMessage()
func (*URIsRequest) ProtoReflect ¶
func (x *URIsRequest) ProtoReflect() protoreflect.Message
func (*URIsRequest) Reset ¶
func (x *URIsRequest) Reset()
func (*URIsRequest) String ¶
func (x *URIsRequest) String() string
type URIsResponse ¶
type URIsResponse struct { Uris []string `protobuf:"bytes,1,rep,name=uris,proto3" json:"uris,omitempty"` // contains filtered or unexported fields }
func (*URIsResponse) Descriptor
deprecated
func (*URIsResponse) Descriptor() ([]byte, []int)
Deprecated: Use URIsResponse.ProtoReflect.Descriptor instead.
func (*URIsResponse) GetUris ¶
func (x *URIsResponse) GetUris() []string
func (*URIsResponse) ProtoMessage ¶
func (*URIsResponse) ProtoMessage()
func (*URIsResponse) ProtoReflect ¶
func (x *URIsResponse) ProtoReflect() protoreflect.Message
func (*URIsResponse) Reset ¶
func (x *URIsResponse) Reset()
func (*URIsResponse) String ¶
func (x *URIsResponse) String() string
type UnimplementedControlServiceServer ¶
type UnimplementedControlServiceServer struct { }
UnimplementedControlServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedControlServiceServer) AddNode ¶
func (UnimplementedControlServiceServer) AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)
func (UnimplementedControlServiceServer) AttachPeer ¶
func (UnimplementedControlServiceServer) AttachPeer(context.Context, *AttachPeerRequest) (*AttachPeerResponse, error)
func (UnimplementedControlServiceServer) CreateBlockchains ¶ added in v0.2.0
func (UnimplementedControlServiceServer) CreateBlockchains(context.Context, *CreateBlockchainsRequest) (*CreateBlockchainsResponse, error)
func (UnimplementedControlServiceServer) CreateSubnets ¶ added in v0.2.0
func (UnimplementedControlServiceServer) CreateSubnets(context.Context, *CreateSubnetsRequest) (*CreateSubnetsResponse, error)
func (UnimplementedControlServiceServer) GetSnapshotNames ¶ added in v0.1.0
func (UnimplementedControlServiceServer) GetSnapshotNames(context.Context, *GetSnapshotNamesRequest) (*GetSnapshotNamesResponse, error)
func (UnimplementedControlServiceServer) Health ¶
func (UnimplementedControlServiceServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)
func (UnimplementedControlServiceServer) LoadSnapshot ¶ added in v0.1.0
func (UnimplementedControlServiceServer) LoadSnapshot(context.Context, *LoadSnapshotRequest) (*LoadSnapshotResponse, error)
func (UnimplementedControlServiceServer) RemoveNode ¶
func (UnimplementedControlServiceServer) RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
func (UnimplementedControlServiceServer) RemoveSnapshot ¶ added in v0.1.0
func (UnimplementedControlServiceServer) RemoveSnapshot(context.Context, *RemoveSnapshotRequest) (*RemoveSnapshotResponse, error)
func (UnimplementedControlServiceServer) RestartNode ¶
func (UnimplementedControlServiceServer) RestartNode(context.Context, *RestartNodeRequest) (*RestartNodeResponse, error)
func (UnimplementedControlServiceServer) SaveSnapshot ¶ added in v0.1.0
func (UnimplementedControlServiceServer) SaveSnapshot(context.Context, *SaveSnapshotRequest) (*SaveSnapshotResponse, error)
func (UnimplementedControlServiceServer) SendOutboundMessage ¶
func (UnimplementedControlServiceServer) SendOutboundMessage(context.Context, *SendOutboundMessageRequest) (*SendOutboundMessageResponse, error)
func (UnimplementedControlServiceServer) Start ¶
func (UnimplementedControlServiceServer) Start(context.Context, *StartRequest) (*StartResponse, error)
func (UnimplementedControlServiceServer) Status ¶
func (UnimplementedControlServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
func (UnimplementedControlServiceServer) Stop ¶
func (UnimplementedControlServiceServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
func (UnimplementedControlServiceServer) StreamStatus ¶
func (UnimplementedControlServiceServer) StreamStatus(*StreamStatusRequest, ControlService_StreamStatusServer) error
func (UnimplementedControlServiceServer) URIs ¶
func (UnimplementedControlServiceServer) URIs(context.Context, *URIsRequest) (*URIsResponse, error)
type UnimplementedPingServiceServer ¶
type UnimplementedPingServiceServer struct { }
UnimplementedPingServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedPingServiceServer) Ping ¶
func (UnimplementedPingServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
type UnsafeControlServiceServer ¶
type UnsafeControlServiceServer interface {
// contains filtered or unexported methods
}
UnsafeControlServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServiceServer will result in compilation errors.
type UnsafePingServiceServer ¶
type UnsafePingServiceServer interface {
// contains filtered or unexported methods
}
UnsafePingServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PingServiceServer will result in compilation errors.