rpcpb

package

Go to main page

Versions in this module

v0

v0.3.0

Nov 2, 2022

Changes in this version

type BlockchainSpec

+ ChainConfig string

+ NetworkUpgrade string

+ func (x *BlockchainSpec) GetChainConfig() string

+ func (x *BlockchainSpec) GetNetworkUpgrade() string

type LoadSnapshotRequest

+ ReassignPortsIfUsed *bool

+ func (x *LoadSnapshotRequest) GetReassignPortsIfUsed() bool

type StartRequest

+ DynamicPorts *bool

+ ReassignPortsIfUsed *bool

+ func (x *StartRequest) GetDynamicPorts() bool

+ func (x *StartRequest) GetReassignPortsIfUsed() bool

v0.2.0

Sep 7, 2022

Changes in this version

type AddNodeRequest

+ ChainConfigs map[string]string

+ ExecPath string

+ NodeConfig *string

+ UpgradeConfigs map[string]string

+ func (x *AddNodeRequest) GetChainConfigs() map[string]string

+ func (x *AddNodeRequest) GetExecPath() string

+ func (x *AddNodeRequest) GetNodeConfig() string

+ func (x *AddNodeRequest) GetUpgradeConfigs() map[string]string

+ type BlockchainSpec struct

+ Genesis string

+ SubnetId *string

+ VmName string

+ func (*BlockchainSpec) Descriptor() ([]byte, []int)

+ func (*BlockchainSpec) ProtoMessage()

+ func (x *BlockchainSpec) GetGenesis() 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

+ CustomChains map[string]*CustomChainInfo

+ CustomChainsHealthy bool

+ Subnets []string

+ func (x *ClusterInfo) GetCustomChains() map[string]*CustomChainInfo

+ func (x *ClusterInfo) GetCustomChainsHealthy() bool

+ func (x *ClusterInfo) GetSubnets() []string

type ControlServiceClient

+ CreateBlockchains func(ctx context.Context, in *CreateBlockchainsRequest, opts ...grpc.CallOption) (*CreateBlockchainsResponse, error)

+ CreateSubnets func(ctx context.Context, in *CreateSubnetsRequest, opts ...grpc.CallOption) (*CreateSubnetsResponse, error)

type ControlServiceServer

+ CreateBlockchains func(context.Context, *CreateBlockchainsRequest) (*CreateBlockchainsResponse, error)

+ CreateSubnets func(context.Context, *CreateSubnetsRequest) (*CreateSubnetsResponse, 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 LoadSnapshotRequest

+ ChainConfigs map[string]string

+ ExecPath *string

+ GlobalNodeConfig *string

+ PluginDir *string

+ RootDataDir *string

+ UpgradeConfigs map[string]string

+ 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) GetRootDataDir() string

+ func (x *LoadSnapshotRequest) GetUpgradeConfigs() map[string]string

type RestartNodeRequest

+ ChainConfigs map[string]string

+ UpgradeConfigs map[string]string

+ func (x *RestartNodeRequest) GetChainConfigs() map[string]string

+ func (x *RestartNodeRequest) GetUpgradeConfigs() map[string]string

type StartRequest

+ BlockchainSpecs []*BlockchainSpec

+ ChainConfigs map[string]string

+ UpgradeConfigs map[string]string

+ func (x *StartRequest) GetBlockchainSpecs() []*BlockchainSpec

+ func (x *StartRequest) GetChainConfigs() map[string]string

+ func (x *StartRequest) GetUpgradeConfigs() map[string]string

type UnimplementedControlServiceServer

+ func (UnimplementedControlServiceServer) CreateBlockchains(context.Context, *CreateBlockchainsRequest) (*CreateBlockchainsResponse, error)

+ func (UnimplementedControlServiceServer) CreateSubnets(context.Context, *CreateSubnetsRequest) (*CreateSubnetsResponse, error)

v0.1.0

Jun 7, 2022

Changes in this version

type ControlServiceClient

+ GetSnapshotNames func(ctx context.Context, in *GetSnapshotNamesRequest, opts ...grpc.CallOption) (*GetSnapshotNamesResponse, error)

+ LoadSnapshot func(ctx context.Context, in *LoadSnapshotRequest, opts ...grpc.CallOption) (*LoadSnapshotResponse, error)

+ RemoveSnapshot func(ctx context.Context, in *RemoveSnapshotRequest, opts ...grpc.CallOption) (*RemoveSnapshotResponse, error)

+ SaveSnapshot func(ctx context.Context, in *SaveSnapshotRequest, opts ...grpc.CallOption) (*SaveSnapshotResponse, error)

type ControlServiceServer

+ GetSnapshotNames func(context.Context, *GetSnapshotNamesRequest) (*GetSnapshotNamesResponse, error)

+ LoadSnapshot func(context.Context, *LoadSnapshotRequest) (*LoadSnapshotResponse, error)

+ RemoveSnapshot func(context.Context, *RemoveSnapshotRequest) (*RemoveSnapshotResponse, error)

+ SaveSnapshot func(context.Context, *SaveSnapshotRequest) (*SaveSnapshotResponse, error)

+ 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 LoadSnapshotRequest struct

+ SnapshotName string

+ func (*LoadSnapshotRequest) Descriptor() ([]byte, []int)

+ func (*LoadSnapshotRequest) ProtoMessage()

+ func (x *LoadSnapshotRequest) GetSnapshotName() 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 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 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 UnimplementedControlServiceServer

+ func (UnimplementedControlServiceServer) GetSnapshotNames(context.Context, *GetSnapshotNamesRequest) (*GetSnapshotNamesResponse, error)

+ func (UnimplementedControlServiceServer) LoadSnapshot(context.Context, *LoadSnapshotRequest) (*LoadSnapshotResponse, error)

+ func (UnimplementedControlServiceServer) RemoveSnapshot(context.Context, *RemoveSnapshotRequest) (*RemoveSnapshotResponse, error)

+ func (UnimplementedControlServiceServer) SaveSnapshot(context.Context, *SaveSnapshotRequest) (*SaveSnapshotResponse, error)

v0.0.0

May 13, 2022

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

+ Name string

+ StartRequest *StartRequest

+ func (*AddNodeRequest) Descriptor() ([]byte, []int)

+ func (*AddNodeRequest) ProtoMessage()

+ func (x *AddNodeRequest) GetName() string

+ func (x *AddNodeRequest) GetStartRequest() *StartRequest

+ 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 ClusterInfo struct

+ AttachedPeerInfos map[string]*ListOfAttachedPeerInfo

+ CustomVms map[string]*CustomVmInfo

+ CustomVmsHealthy bool

+ Healthy bool

+ NodeInfos map[string]*NodeInfo

+ NodeNames []string

+ Pid int32

+ RootDataDir string

+ func (*ClusterInfo) Descriptor() ([]byte, []int)

+ func (*ClusterInfo) ProtoMessage()

+ func (x *ClusterInfo) GetAttachedPeerInfos() map[string]*ListOfAttachedPeerInfo

+ func (x *ClusterInfo) GetCustomVms() map[string]*CustomVmInfo

+ func (x *ClusterInfo) GetCustomVmsHealthy() 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) 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)

+ Health func(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)

+ RemoveNode func(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error)

+ RestartNode func(ctx context.Context, in *RestartNodeRequest, opts ...grpc.CallOption) (*RestartNodeResponse, 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)

+ Health func(context.Context, *HealthRequest) (*HealthResponse, error)

+ RemoveNode func(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)

+ RestartNode func(context.Context, *RestartNodeRequest) (*RestartNodeResponse, 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 CustomVmInfo struct

+ BlockchainId string

+ SubnetId string

+ VmId string

+ VmName string

+ func (*CustomVmInfo) Descriptor() ([]byte, []int)

+ func (*CustomVmInfo) ProtoMessage()

+ func (x *CustomVmInfo) GetBlockchainId() string

+ func (x *CustomVmInfo) GetSubnetId() string

+ func (x *CustomVmInfo) GetVmId() string

+ func (x *CustomVmInfo) GetVmName() string

+ func (x *CustomVmInfo) ProtoReflect() protoreflect.Message

+ func (x *CustomVmInfo) Reset()

+ func (x *CustomVmInfo) 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 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 RestartNodeRequest struct

+ ExecPath *string

+ LogLevel *string

+ Name string

+ RootDataDir *string

+ WhitelistedSubnets *string

+ func (*RestartNodeRequest) Descriptor() ([]byte, []int)

+ func (*RestartNodeRequest) ProtoMessage()

+ func (x *RestartNodeRequest) GetExecPath() string

+ func (x *RestartNodeRequest) GetLogLevel() string

+ func (x *RestartNodeRequest) GetName() string

+ func (x *RestartNodeRequest) GetRootDataDir() 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 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

+ CustomNodeConfigs map[string]string

+ CustomVms map[string]string

+ ExecPath string

+ GlobalNodeConfig *string

+ LogLevel *string

+ NumNodes *uint32

+ PluginDir *string

+ RootDataDir *string

+ WhitelistedSubnets *string

+ func (*StartRequest) Descriptor() ([]byte, []int)

+ func (*StartRequest) ProtoMessage()

+ func (x *StartRequest) GetCustomNodeConfigs() map[string]string

+ func (x *StartRequest) GetCustomVms() map[string]string

+ func (x *StartRequest) GetExecPath() string

+ func (x *StartRequest) GetGlobalNodeConfig() string

+ func (x *StartRequest) GetLogLevel() string

+ func (x *StartRequest) GetNumNodes() uint32

+ func (x *StartRequest) GetPluginDir() string

+ func (x *StartRequest) GetRootDataDir() 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) Health(context.Context, *HealthRequest) (*HealthResponse, error)

+ func (UnimplementedControlServiceServer) RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)

+ func (UnimplementedControlServiceServer) RestartNode(context.Context, *RestartNodeRequest) (*RestartNodeResponse, 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL