Versions in this module Expand all Collapse all v1 v1.0.0 Nov 21, 2024 Changes in this version + var ControlService_ServiceDesc = grpc.ServiceDesc + var File_rpcpb_rpc_proto protoreflect.FileDescriptor + var PingService_ServiceDesc = grpc.ServiceDesc + func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer) + func RegisterPingServiceServer(s grpc.ServiceRegistrar, srv PingServiceServer) + type AddNodeRequest struct + ChainConfigs map[string]string + ExecPath string + Name string + NodeConfig *string + UpgradeConfigs map[string]string + func (*AddNodeRequest) Descriptor() ([]byte, []int) + func (*AddNodeRequest) ProtoMessage() + 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 (x *AddNodeRequest) ProtoReflect() protoreflect.Message + func (x *AddNodeRequest) Reset() + func (x *AddNodeRequest) String() string + type AddNodeResponse struct + ClusterInfo *ClusterInfo + func (*AddNodeResponse) Descriptor() ([]byte, []int) + func (*AddNodeResponse) ProtoMessage() + func (x *AddNodeResponse) GetClusterInfo() *ClusterInfo + func (x *AddNodeResponse) ProtoReflect() protoreflect.Message + func (x *AddNodeResponse) Reset() + func (x *AddNodeResponse) String() string + type AttachPeerRequest struct + NodeName string + func (*AttachPeerRequest) Descriptor() ([]byte, []int) + func (*AttachPeerRequest) ProtoMessage() + func (x *AttachPeerRequest) GetNodeName() string + func (x *AttachPeerRequest) ProtoReflect() protoreflect.Message + func (x *AttachPeerRequest) Reset() + func (x *AttachPeerRequest) String() string + type AttachPeerResponse struct + AttachedPeerInfo *AttachedPeerInfo + ClusterInfo *ClusterInfo + func (*AttachPeerResponse) Descriptor() ([]byte, []int) + func (*AttachPeerResponse) ProtoMessage() + func (x *AttachPeerResponse) GetAttachedPeerInfo() *AttachedPeerInfo + func (x *AttachPeerResponse) GetClusterInfo() *ClusterInfo + func (x *AttachPeerResponse) ProtoReflect() protoreflect.Message + func (x *AttachPeerResponse) Reset() + func (x *AttachPeerResponse) String() string + type AttachedPeerInfo struct + Id string + func (*AttachedPeerInfo) Descriptor() ([]byte, []int) + func (*AttachedPeerInfo) ProtoMessage() + func (x *AttachedPeerInfo) GetId() string + func (x *AttachedPeerInfo) ProtoReflect() protoreflect.Message + func (x *AttachedPeerInfo) Reset() + func (x *AttachedPeerInfo) String() string + type BlockchainSpec struct + ChainConfig string + Genesis string + NetworkUpgrade string + SubnetId *string + VmName string + func (*BlockchainSpec) Descriptor() ([]byte, []int) + func (*BlockchainSpec) ProtoMessage() + 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 (x *BlockchainSpec) ProtoReflect() protoreflect.Message + func (x *BlockchainSpec) Reset() + func (x *BlockchainSpec) String() string + type ClusterInfo struct + AttachedPeerInfos map[string]*ListOfAttachedPeerInfo + CustomChains map[string]*CustomChainInfo + CustomChainsHealthy bool + Healthy bool + NodeInfos map[string]*NodeInfo + NodeNames []string + Pid int32 + RootDataDir string + Subnets []string + func (*ClusterInfo) Descriptor() ([]byte, []int) + func (*ClusterInfo) ProtoMessage() + 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 (x *ClusterInfo) ProtoReflect() protoreflect.Message + func (x *ClusterInfo) Reset() + func (x *ClusterInfo) String() string + type ControlServiceClient interface + AddNode func(ctx context.Context, in *AddNodeRequest, opts ...grpc.CallOption) (*AddNodeResponse, error) + AttachPeer func(ctx context.Context, in *AttachPeerRequest, opts ...grpc.CallOption) (*AttachPeerResponse, error) + CreateBlockchains func(ctx context.Context, in *CreateBlockchainsRequest, opts ...grpc.CallOption) (*CreateBlockchainsResponse, error) + CreateSubnets func(ctx context.Context, in *CreateSubnetsRequest, opts ...grpc.CallOption) (*CreateSubnetsResponse, error) + GetSnapshotNames func(ctx context.Context, in *GetSnapshotNamesRequest, opts ...grpc.CallOption) (*GetSnapshotNamesResponse, error) + Health func(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error) + LoadSnapshot func(ctx context.Context, in *LoadSnapshotRequest, opts ...grpc.CallOption) (*LoadSnapshotResponse, error) + RemoveNode func(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error) + RemoveSnapshot func(ctx context.Context, in *RemoveSnapshotRequest, opts ...grpc.CallOption) (*RemoveSnapshotResponse, error) + RestartNode func(ctx context.Context, in *RestartNodeRequest, opts ...grpc.CallOption) (*RestartNodeResponse, error) + SaveSnapshot func(ctx context.Context, in *SaveSnapshotRequest, opts ...grpc.CallOption) (*SaveSnapshotResponse, error) + SendOutboundMessage func(ctx context.Context, in *SendOutboundMessageRequest, opts ...grpc.CallOption) (*SendOutboundMessageResponse, error) + Start func(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) + Status func(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) + Stop func(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error) + StreamStatus func(ctx context.Context, in *StreamStatusRequest, opts ...grpc.CallOption) (ControlService_StreamStatusClient, error) + URIs func(ctx context.Context, in *URIsRequest, opts ...grpc.CallOption) (*URIsResponse, error) + func NewControlServiceClient(cc grpc.ClientConnInterface) ControlServiceClient + type ControlServiceServer interface + AddNode func(context.Context, *AddNodeRequest) (*AddNodeResponse, error) + AttachPeer func(context.Context, *AttachPeerRequest) (*AttachPeerResponse, error) + CreateBlockchains func(context.Context, *CreateBlockchainsRequest) (*CreateBlockchainsResponse, error) + CreateSubnets func(context.Context, *CreateSubnetsRequest) (*CreateSubnetsResponse, error) + GetSnapshotNames func(context.Context, *GetSnapshotNamesRequest) (*GetSnapshotNamesResponse, error) + Health func(context.Context, *HealthRequest) (*HealthResponse, error) + LoadSnapshot func(context.Context, *LoadSnapshotRequest) (*LoadSnapshotResponse, error) + RemoveNode func(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error) + RemoveSnapshot func(context.Context, *RemoveSnapshotRequest) (*RemoveSnapshotResponse, error) + RestartNode func(context.Context, *RestartNodeRequest) (*RestartNodeResponse, error) + SaveSnapshot func(context.Context, *SaveSnapshotRequest) (*SaveSnapshotResponse, error) + SendOutboundMessage func(context.Context, *SendOutboundMessageRequest) (*SendOutboundMessageResponse, error) + Start func(context.Context, *StartRequest) (*StartResponse, error) + Status func(context.Context, *StatusRequest) (*StatusResponse, error) + Stop func(context.Context, *StopRequest) (*StopResponse, error) + StreamStatus func(*StreamStatusRequest, ControlService_StreamStatusServer) error + URIs func(context.Context, *URIsRequest) (*URIsResponse, error) + type ControlService_StreamStatusClient interface + Recv func() (*StreamStatusResponse, error) + type ControlService_StreamStatusServer interface + Send func(*StreamStatusResponse) error + type CreateBlockchainsRequest struct + BlockchainSpecs []*BlockchainSpec + func (*CreateBlockchainsRequest) Descriptor() ([]byte, []int) + func (*CreateBlockchainsRequest) ProtoMessage() + func (x *CreateBlockchainsRequest) GetBlockchainSpecs() []*BlockchainSpec + func (x *CreateBlockchainsRequest) ProtoReflect() protoreflect.Message + func (x *CreateBlockchainsRequest) Reset() + func (x *CreateBlockchainsRequest) String() string + type CreateBlockchainsResponse struct + ClusterInfo *ClusterInfo + func (*CreateBlockchainsResponse) Descriptor() ([]byte, []int) + func (*CreateBlockchainsResponse) ProtoMessage() + func (x *CreateBlockchainsResponse) GetClusterInfo() *ClusterInfo + func (x *CreateBlockchainsResponse) ProtoReflect() protoreflect.Message + func (x *CreateBlockchainsResponse) Reset() + func (x *CreateBlockchainsResponse) String() string + type CreateSubnetsRequest struct + NumSubnets *uint32 + func (*CreateSubnetsRequest) Descriptor() ([]byte, []int) + func (*CreateSubnetsRequest) ProtoMessage() + func (x *CreateSubnetsRequest) GetNumSubnets() uint32 + func (x *CreateSubnetsRequest) ProtoReflect() protoreflect.Message + func (x *CreateSubnetsRequest) Reset() + func (x *CreateSubnetsRequest) String() string + type CreateSubnetsResponse struct + ClusterInfo *ClusterInfo + func (*CreateSubnetsResponse) Descriptor() ([]byte, []int) + func (*CreateSubnetsResponse) ProtoMessage() + func (x *CreateSubnetsResponse) GetClusterInfo() *ClusterInfo + func (x *CreateSubnetsResponse) ProtoReflect() protoreflect.Message + func (x *CreateSubnetsResponse) Reset() + func (x *CreateSubnetsResponse) String() string + type CustomChainInfo struct + ChainId string + ChainName string + SubnetId string + VmId string + func (*CustomChainInfo) Descriptor() ([]byte, []int) + func (*CustomChainInfo) ProtoMessage() + func (x *CustomChainInfo) GetChainId() string + func (x *CustomChainInfo) GetChainName() string + func (x *CustomChainInfo) GetSubnetId() string + func (x *CustomChainInfo) GetVmId() string + func (x *CustomChainInfo) ProtoReflect() protoreflect.Message + func (x *CustomChainInfo) Reset() + func (x *CustomChainInfo) String() string + type GetSnapshotNamesRequest struct + func (*GetSnapshotNamesRequest) Descriptor() ([]byte, []int) + func (*GetSnapshotNamesRequest) ProtoMessage() + func (x *GetSnapshotNamesRequest) ProtoReflect() protoreflect.Message + func (x *GetSnapshotNamesRequest) Reset() + func (x *GetSnapshotNamesRequest) String() string + type GetSnapshotNamesResponse struct + SnapshotNames []string + func (*GetSnapshotNamesResponse) Descriptor() ([]byte, []int) + func (*GetSnapshotNamesResponse) ProtoMessage() + func (x *GetSnapshotNamesResponse) GetSnapshotNames() []string + func (x *GetSnapshotNamesResponse) ProtoReflect() protoreflect.Message + func (x *GetSnapshotNamesResponse) Reset() + func (x *GetSnapshotNamesResponse) String() string + type HealthRequest struct + func (*HealthRequest) Descriptor() ([]byte, []int) + func (*HealthRequest) ProtoMessage() + func (x *HealthRequest) ProtoReflect() protoreflect.Message + func (x *HealthRequest) Reset() + func (x *HealthRequest) String() string + type HealthResponse struct + ClusterInfo *ClusterInfo + func (*HealthResponse) Descriptor() ([]byte, []int) + func (*HealthResponse) ProtoMessage() + func (x *HealthResponse) GetClusterInfo() *ClusterInfo + func (x *HealthResponse) ProtoReflect() protoreflect.Message + func (x *HealthResponse) Reset() + func (x *HealthResponse) String() string + type ListOfAttachedPeerInfo struct + Peers []*AttachedPeerInfo + func (*ListOfAttachedPeerInfo) Descriptor() ([]byte, []int) + func (*ListOfAttachedPeerInfo) ProtoMessage() + func (x *ListOfAttachedPeerInfo) GetPeers() []*AttachedPeerInfo + func (x *ListOfAttachedPeerInfo) ProtoReflect() protoreflect.Message + func (x *ListOfAttachedPeerInfo) Reset() + func (x *ListOfAttachedPeerInfo) String() string + type LoadSnapshotRequest struct + ChainConfigs map[string]string + ExecPath *string + GlobalNodeConfig *string + PluginDir *string + ReassignPortsIfUsed *bool + RootDataDir *string + SnapshotName string + UpgradeConfigs map[string]string + func (*LoadSnapshotRequest) Descriptor() ([]byte, []int) + func (*LoadSnapshotRequest) ProtoMessage() + 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 (x *LoadSnapshotRequest) ProtoReflect() protoreflect.Message + func (x *LoadSnapshotRequest) Reset() + func (x *LoadSnapshotRequest) String() string + type LoadSnapshotResponse struct + ClusterInfo *ClusterInfo + func (*LoadSnapshotResponse) Descriptor() ([]byte, []int) + func (*LoadSnapshotResponse) ProtoMessage() + func (x *LoadSnapshotResponse) GetClusterInfo() *ClusterInfo + func (x *LoadSnapshotResponse) ProtoReflect() protoreflect.Message + func (x *LoadSnapshotResponse) Reset() + func (x *LoadSnapshotResponse) String() string + type NodeInfo struct + Config []byte + DbDir string + ExecPath string + Id string + LogDir string + Name string + PluginDir string + Uri string + WhitelistedSubnets string + func (*NodeInfo) Descriptor() ([]byte, []int) + func (*NodeInfo) ProtoMessage() + 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 (x *NodeInfo) ProtoReflect() protoreflect.Message + func (x *NodeInfo) Reset() + func (x *NodeInfo) String() string + type PingRequest struct + func (*PingRequest) Descriptor() ([]byte, []int) + func (*PingRequest) ProtoMessage() + func (x *PingRequest) ProtoReflect() protoreflect.Message + func (x *PingRequest) Reset() + func (x *PingRequest) String() string + type PingResponse struct + Pid int32 + func (*PingResponse) Descriptor() ([]byte, []int) + func (*PingResponse) ProtoMessage() + func (x *PingResponse) GetPid() int32 + func (x *PingResponse) ProtoReflect() protoreflect.Message + func (x *PingResponse) Reset() + func (x *PingResponse) String() string + type PingServiceClient interface + Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) + func NewPingServiceClient(cc grpc.ClientConnInterface) PingServiceClient + type PingServiceServer interface + Ping func(context.Context, *PingRequest) (*PingResponse, error) + type RemoveNodeRequest struct + Name string + func (*RemoveNodeRequest) Descriptor() ([]byte, []int) + func (*RemoveNodeRequest) ProtoMessage() + func (x *RemoveNodeRequest) GetName() string + func (x *RemoveNodeRequest) ProtoReflect() protoreflect.Message + func (x *RemoveNodeRequest) Reset() + func (x *RemoveNodeRequest) String() string + type RemoveNodeResponse struct + ClusterInfo *ClusterInfo + func (*RemoveNodeResponse) Descriptor() ([]byte, []int) + func (*RemoveNodeResponse) ProtoMessage() + func (x *RemoveNodeResponse) GetClusterInfo() *ClusterInfo + func (x *RemoveNodeResponse) ProtoReflect() protoreflect.Message + func (x *RemoveNodeResponse) Reset() + func (x *RemoveNodeResponse) String() string + type RemoveSnapshotRequest struct + SnapshotName string + func (*RemoveSnapshotRequest) Descriptor() ([]byte, []int) + func (*RemoveSnapshotRequest) ProtoMessage() + func (x *RemoveSnapshotRequest) GetSnapshotName() string + func (x *RemoveSnapshotRequest) ProtoReflect() protoreflect.Message + func (x *RemoveSnapshotRequest) Reset() + func (x *RemoveSnapshotRequest) String() string + type RemoveSnapshotResponse struct + func (*RemoveSnapshotResponse) Descriptor() ([]byte, []int) + func (*RemoveSnapshotResponse) ProtoMessage() + func (x *RemoveSnapshotResponse) ProtoReflect() protoreflect.Message + func (x *RemoveSnapshotResponse) Reset() + func (x *RemoveSnapshotResponse) String() string + type RestartNodeRequest struct + ChainConfigs map[string]string + ExecPath *string + Name string + UpgradeConfigs map[string]string + WhitelistedSubnets *string + func (*RestartNodeRequest) Descriptor() ([]byte, []int) + func (*RestartNodeRequest) ProtoMessage() + 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 (x *RestartNodeRequest) ProtoReflect() protoreflect.Message + func (x *RestartNodeRequest) Reset() + func (x *RestartNodeRequest) String() string + type RestartNodeResponse struct + ClusterInfo *ClusterInfo + func (*RestartNodeResponse) Descriptor() ([]byte, []int) + func (*RestartNodeResponse) ProtoMessage() + func (x *RestartNodeResponse) GetClusterInfo() *ClusterInfo + func (x *RestartNodeResponse) ProtoReflect() protoreflect.Message + func (x *RestartNodeResponse) Reset() + func (x *RestartNodeResponse) String() string + type SaveSnapshotRequest struct + SnapshotName string + func (*SaveSnapshotRequest) Descriptor() ([]byte, []int) + func (*SaveSnapshotRequest) ProtoMessage() + func (x *SaveSnapshotRequest) GetSnapshotName() string + func (x *SaveSnapshotRequest) ProtoReflect() protoreflect.Message + func (x *SaveSnapshotRequest) Reset() + func (x *SaveSnapshotRequest) String() string + type SaveSnapshotResponse struct + SnapshotPath string + func (*SaveSnapshotResponse) Descriptor() ([]byte, []int) + func (*SaveSnapshotResponse) ProtoMessage() + func (x *SaveSnapshotResponse) GetSnapshotPath() string + func (x *SaveSnapshotResponse) ProtoReflect() protoreflect.Message + func (x *SaveSnapshotResponse) Reset() + func (x *SaveSnapshotResponse) String() string + type SendOutboundMessageRequest struct + Bytes []byte + NodeName string + Op uint32 + PeerId string + func (*SendOutboundMessageRequest) Descriptor() ([]byte, []int) + func (*SendOutboundMessageRequest) ProtoMessage() + func (x *SendOutboundMessageRequest) GetBytes() []byte + func (x *SendOutboundMessageRequest) GetNodeName() string + func (x *SendOutboundMessageRequest) GetOp() uint32 + func (x *SendOutboundMessageRequest) GetPeerId() string + func (x *SendOutboundMessageRequest) ProtoReflect() protoreflect.Message + func (x *SendOutboundMessageRequest) Reset() + func (x *SendOutboundMessageRequest) String() string + type SendOutboundMessageResponse struct + Sent bool + func (*SendOutboundMessageResponse) Descriptor() ([]byte, []int) + func (*SendOutboundMessageResponse) ProtoMessage() + func (x *SendOutboundMessageResponse) GetSent() bool + func (x *SendOutboundMessageResponse) ProtoReflect() protoreflect.Message + func (x *SendOutboundMessageResponse) Reset() + func (x *SendOutboundMessageResponse) String() string + type StartRequest struct + BlockchainSpecs []*BlockchainSpec + ChainConfigs map[string]string + CustomNodeConfigs map[string]string + DynamicPorts *bool + ExecPath string + GlobalNodeConfig *string + NumNodes *uint32 + PluginDir *string + ReassignPortsIfUsed *bool + RootDataDir *string + UpgradeConfigs map[string]string + WhitelistedSubnets *string + func (*StartRequest) Descriptor() ([]byte, []int) + func (*StartRequest) ProtoMessage() + 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 (x *StartRequest) ProtoReflect() protoreflect.Message + func (x *StartRequest) Reset() + func (x *StartRequest) String() string + type StartResponse struct + ClusterInfo *ClusterInfo + func (*StartResponse) Descriptor() ([]byte, []int) + func (*StartResponse) ProtoMessage() + func (x *StartResponse) GetClusterInfo() *ClusterInfo + func (x *StartResponse) ProtoReflect() protoreflect.Message + func (x *StartResponse) Reset() + func (x *StartResponse) String() string + type StatusRequest struct + func (*StatusRequest) Descriptor() ([]byte, []int) + func (*StatusRequest) ProtoMessage() + func (x *StatusRequest) ProtoReflect() protoreflect.Message + func (x *StatusRequest) Reset() + func (x *StatusRequest) String() string + type StatusResponse struct + ClusterInfo *ClusterInfo + func (*StatusResponse) Descriptor() ([]byte, []int) + func (*StatusResponse) ProtoMessage() + func (x *StatusResponse) GetClusterInfo() *ClusterInfo + func (x *StatusResponse) ProtoReflect() protoreflect.Message + func (x *StatusResponse) Reset() + func (x *StatusResponse) String() string + type StopRequest struct + func (*StopRequest) Descriptor() ([]byte, []int) + func (*StopRequest) ProtoMessage() + func (x *StopRequest) ProtoReflect() protoreflect.Message + func (x *StopRequest) Reset() + func (x *StopRequest) String() string + type StopResponse struct + ClusterInfo *ClusterInfo + func (*StopResponse) Descriptor() ([]byte, []int) + func (*StopResponse) ProtoMessage() + func (x *StopResponse) GetClusterInfo() *ClusterInfo + func (x *StopResponse) ProtoReflect() protoreflect.Message + func (x *StopResponse) Reset() + func (x *StopResponse) String() string + type StreamStatusRequest struct + PushInterval int64 + func (*StreamStatusRequest) Descriptor() ([]byte, []int) + func (*StreamStatusRequest) ProtoMessage() + func (x *StreamStatusRequest) GetPushInterval() int64 + func (x *StreamStatusRequest) ProtoReflect() protoreflect.Message + func (x *StreamStatusRequest) Reset() + func (x *StreamStatusRequest) String() string + type StreamStatusResponse struct + ClusterInfo *ClusterInfo + func (*StreamStatusResponse) Descriptor() ([]byte, []int) + func (*StreamStatusResponse) ProtoMessage() + func (x *StreamStatusResponse) GetClusterInfo() *ClusterInfo + func (x *StreamStatusResponse) ProtoReflect() protoreflect.Message + func (x *StreamStatusResponse) Reset() + func (x *StreamStatusResponse) String() string + type URIsRequest struct + func (*URIsRequest) Descriptor() ([]byte, []int) + func (*URIsRequest) ProtoMessage() + func (x *URIsRequest) ProtoReflect() protoreflect.Message + func (x *URIsRequest) Reset() + func (x *URIsRequest) String() string + type URIsResponse struct + Uris []string + func (*URIsResponse) Descriptor() ([]byte, []int) + func (*URIsResponse) ProtoMessage() + func (x *URIsResponse) GetUris() []string + func (x *URIsResponse) ProtoReflect() protoreflect.Message + func (x *URIsResponse) Reset() + func (x *URIsResponse) String() string + type UnimplementedControlServiceServer struct + 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 struct + func (UnimplementedPingServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error) + type UnsafeControlServiceServer interface + type UnsafePingServiceServer interface
Go to main page