Documentation
¶
Overview ¶
Package rpcpb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func RegisterControlServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterControlServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ControlServiceClient) error
- func RegisterControlServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterControlServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ControlServiceServer) error
- func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)
- func RegisterPingServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterPingServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PingServiceClient) error
- func RegisterPingServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterPingServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PingServiceServer) error
- func RegisterPingServiceServer(s grpc.ServiceRegistrar, srv PingServiceServer)
- type AddNodeRequest
- func (*AddNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddNodeRequest) GetChainConfigFiles() map[string]string
- 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) GetPluginDir() 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 AddPermissionlessValidatorRequest
- func (*AddPermissionlessValidatorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddPermissionlessValidatorRequest) GetValidatorSpec() []*PermissionlessValidatorSpec
- func (*AddPermissionlessValidatorRequest) ProtoMessage()
- func (x *AddPermissionlessValidatorRequest) ProtoReflect() protoreflect.Message
- func (x *AddPermissionlessValidatorRequest) Reset()
- func (x *AddPermissionlessValidatorRequest) String() string
- type AddPermissionlessValidatorResponse
- func (*AddPermissionlessValidatorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AddPermissionlessValidatorResponse) GetClusterInfo() *ClusterInfo
- func (*AddPermissionlessValidatorResponse) ProtoMessage()
- func (x *AddPermissionlessValidatorResponse) ProtoReflect() protoreflect.Message
- func (x *AddPermissionlessValidatorResponse) Reset()
- func (x *AddPermissionlessValidatorResponse) String() string
- 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) GetBlockchainAlias() string
- func (x *BlockchainSpec) GetChainConfig() string
- func (x *BlockchainSpec) GetChainId() string
- func (x *BlockchainSpec) GetChainSpec() *ChainSpec
- func (x *BlockchainSpec) GetGenesis() string
- func (x *BlockchainSpec) GetNetworkUpgrade() string
- func (x *BlockchainSpec) GetPerNodeChainConfig() 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 ChainInfo
- func (*ChainInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ChainInfo) GetChainParticipants() *ChainParticipants
- func (x *ChainInfo) GetElasticChainId() string
- func (x *ChainInfo) GetIsElastic() bool
- func (*ChainInfo) ProtoMessage()
- func (x *ChainInfo) ProtoReflect() protoreflect.Message
- func (x *ChainInfo) Reset()
- func (x *ChainInfo) String() string
- type ChainParticipants
- func (*ChainParticipants) Descriptor() ([]byte, []int)deprecated
- func (x *ChainParticipants) GetNodeNames() []string
- func (*ChainParticipants) ProtoMessage()
- func (x *ChainParticipants) ProtoReflect() protoreflect.Message
- func (x *ChainParticipants) Reset()
- func (x *ChainParticipants) String() string
- type ChainSpec
- func (*ChainSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ChainSpec) GetChainConfigFile() string
- func (x *ChainSpec) GetParticipants() []string
- func (*ChainSpec) ProtoMessage()
- func (x *ChainSpec) ProtoReflect() protoreflect.Message
- func (x *ChainSpec) Reset()
- func (x *ChainSpec) String() string
- type ClusterInfo
- func (*ClusterInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterInfo) GetAttachedPeerInfos() map[string]*ListOfAttachedPeerInfo
- func (x *ClusterInfo) GetChains() map[string]*ChainInfo
- 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 (*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) GetChainIds() []string
- func (x *CreateBlockchainsResponse) GetClusterInfo() *ClusterInfo
- func (*CreateBlockchainsResponse) ProtoMessage()
- func (x *CreateBlockchainsResponse) ProtoReflect() protoreflect.Message
- func (x *CreateBlockchainsResponse) Reset()
- func (x *CreateBlockchainsResponse) String() string
- type CreateChainsRequest
- func (*CreateChainsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateChainsRequest) GetChainSpecs() []*ChainSpec
- func (*CreateChainsRequest) ProtoMessage()
- func (x *CreateChainsRequest) ProtoReflect() protoreflect.Message
- func (x *CreateChainsRequest) Reset()
- func (x *CreateChainsRequest) String() string
- type CreateChainsResponse
- func (*CreateChainsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateChainsResponse) GetChainIds() []string
- func (x *CreateChainsResponse) GetClusterInfo() *ClusterInfo
- func (*CreateChainsResponse) ProtoMessage()
- func (x *CreateChainsResponse) ProtoReflect() protoreflect.Message
- func (x *CreateChainsResponse) Reset()
- func (x *CreateChainsResponse) String() string
- type CustomChainInfo
- func (*CustomChainInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CustomChainInfo) GetBlockchainId() string
- func (x *CustomChainInfo) GetChainName() string
- func (x *CustomChainInfo) GetPchainId() 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 ElasticChainSpec
- func (*ElasticChainSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ElasticChainSpec) GetAssetName() string
- func (x *ElasticChainSpec) GetAssetSymbol() string
- func (x *ElasticChainSpec) GetChainId() string
- func (x *ElasticChainSpec) GetInitialSupply() uint64
- func (x *ElasticChainSpec) GetMaxConsumptionRate() uint64
- func (x *ElasticChainSpec) GetMaxStakeDuration() uint64
- func (x *ElasticChainSpec) GetMaxSupply() uint64
- func (x *ElasticChainSpec) GetMaxValidatorStake() uint64
- func (x *ElasticChainSpec) GetMaxValidatorWeightFactor() uint32
- func (x *ElasticChainSpec) GetMinConsumptionRate() uint64
- func (x *ElasticChainSpec) GetMinDelegationFee() uint32
- func (x *ElasticChainSpec) GetMinDelegatorStake() uint64
- func (x *ElasticChainSpec) GetMinStakeDuration() uint64
- func (x *ElasticChainSpec) GetMinValidatorStake() uint64
- func (x *ElasticChainSpec) GetUptimeRequirement() uint32
- func (*ElasticChainSpec) ProtoMessage()
- func (x *ElasticChainSpec) ProtoReflect() protoreflect.Message
- func (x *ElasticChainSpec) Reset()
- func (x *ElasticChainSpec) 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) GetChainConfigFiles() 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) 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) GetPaused() bool
- func (x *NodeInfo) GetPluginDir() string
- func (x *NodeInfo) GetUri() string
- func (x *NodeInfo) GetWhitelistedChains() string
- func (*NodeInfo) ProtoMessage()
- func (x *NodeInfo) ProtoReflect() protoreflect.Message
- func (x *NodeInfo) Reset()
- func (x *NodeInfo) String() string
- type PauseNodeRequest
- type PauseNodeResponse
- func (*PauseNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PauseNodeResponse) GetClusterInfo() *ClusterInfo
- func (*PauseNodeResponse) ProtoMessage()
- func (x *PauseNodeResponse) ProtoReflect() protoreflect.Message
- func (x *PauseNodeResponse) Reset()
- func (x *PauseNodeResponse) String() string
- type PermissionlessValidatorSpec
- func (*PermissionlessValidatorSpec) Descriptor() ([]byte, []int)deprecated
- func (x *PermissionlessValidatorSpec) GetAssetId() string
- func (x *PermissionlessValidatorSpec) GetChainId() string
- func (x *PermissionlessValidatorSpec) GetNodeName() string
- func (x *PermissionlessValidatorSpec) GetStakeDuration() uint64
- func (x *PermissionlessValidatorSpec) GetStakedTokenAmount() uint64
- func (x *PermissionlessValidatorSpec) GetStartTime() string
- func (*PermissionlessValidatorSpec) ProtoMessage()
- func (x *PermissionlessValidatorSpec) ProtoReflect() protoreflect.Message
- func (x *PermissionlessValidatorSpec) Reset()
- func (x *PermissionlessValidatorSpec) String() string
- type PingRequest
- type PingResponse
- type PingServiceClient
- type PingServiceServer
- type RPCVersionRequest
- type RPCVersionResponse
- func (*RPCVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RPCVersionResponse) GetVersion() uint32
- func (*RPCVersionResponse) ProtoMessage()
- func (x *RPCVersionResponse) ProtoReflect() protoreflect.Message
- func (x *RPCVersionResponse) Reset()
- func (x *RPCVersionResponse) String() string
- type RemoveChainValidatorRequest
- func (*RemoveChainValidatorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveChainValidatorRequest) GetValidatorSpec() []*RemoveChainValidatorSpec
- func (*RemoveChainValidatorRequest) ProtoMessage()
- func (x *RemoveChainValidatorRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveChainValidatorRequest) Reset()
- func (x *RemoveChainValidatorRequest) String() string
- type RemoveChainValidatorResponse
- func (*RemoveChainValidatorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveChainValidatorResponse) GetClusterInfo() *ClusterInfo
- func (*RemoveChainValidatorResponse) ProtoMessage()
- func (x *RemoveChainValidatorResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveChainValidatorResponse) Reset()
- func (x *RemoveChainValidatorResponse) String() string
- type RemoveChainValidatorSpec
- func (*RemoveChainValidatorSpec) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveChainValidatorSpec) GetChainId() string
- func (x *RemoveChainValidatorSpec) GetNodeNames() []string
- func (*RemoveChainValidatorSpec) ProtoMessage()
- func (x *RemoveChainValidatorSpec) ProtoReflect() protoreflect.Message
- func (x *RemoveChainValidatorSpec) Reset()
- func (x *RemoveChainValidatorSpec) String() string
- 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) GetChainConfigFiles() map[string]string
- func (x *RestartNodeRequest) GetChainConfigs() map[string]string
- func (x *RestartNodeRequest) GetExecPath() string
- func (x *RestartNodeRequest) GetName() string
- func (x *RestartNodeRequest) GetPluginDir() string
- func (x *RestartNodeRequest) GetUpgradeConfigs() map[string]string
- func (x *RestartNodeRequest) GetWhitelistedChains() 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 ResumeNodeRequest
- type ResumeNodeResponse
- func (*ResumeNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ResumeNodeResponse) GetClusterInfo() *ClusterInfo
- func (*ResumeNodeResponse) ProtoMessage()
- func (x *ResumeNodeResponse) ProtoReflect() protoreflect.Message
- func (x *ResumeNodeResponse) Reset()
- func (x *ResumeNodeResponse) 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) GetChainConfigFiles() map[string]string
- 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) GetWhitelistedChains() string
- func (*StartRequest) ProtoMessage()
- func (x *StartRequest) ProtoReflect() protoreflect.Message
- func (x *StartRequest) Reset()
- func (x *StartRequest) String() string
- type StartResponse
- func (*StartResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StartResponse) GetChainIds() []string
- func (x *StartResponse) GetClusterInfo() *ClusterInfo
- func (*StartResponse) ProtoMessage()
- func (x *StartResponse) ProtoReflect() protoreflect.Message
- func (x *StartResponse) Reset()
- func (x *StartResponse) String() string
- 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 TransformElasticChainsRequest
- func (*TransformElasticChainsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TransformElasticChainsRequest) GetElasticChainSpec() []*ElasticChainSpec
- func (*TransformElasticChainsRequest) ProtoMessage()
- func (x *TransformElasticChainsRequest) ProtoReflect() protoreflect.Message
- func (x *TransformElasticChainsRequest) Reset()
- func (x *TransformElasticChainsRequest) String() string
- type TransformElasticChainsResponse
- func (*TransformElasticChainsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TransformElasticChainsResponse) GetAssetIds() []string
- func (x *TransformElasticChainsResponse) GetClusterInfo() *ClusterInfo
- func (x *TransformElasticChainsResponse) GetTxIds() []string
- func (*TransformElasticChainsResponse) ProtoMessage()
- func (x *TransformElasticChainsResponse) ProtoReflect() protoreflect.Message
- func (x *TransformElasticChainsResponse) Reset()
- func (x *TransformElasticChainsResponse) String() string
- type URIsRequest
- type URIsResponse
- type UnimplementedControlServiceServer
- func (UnimplementedControlServiceServer) AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)
- func (UnimplementedControlServiceServer) AddPermissionlessValidator(context.Context, *AddPermissionlessValidatorRequest) (*AddPermissionlessValidatorResponse, error)
- func (UnimplementedControlServiceServer) AttachPeer(context.Context, *AttachPeerRequest) (*AttachPeerResponse, error)
- func (UnimplementedControlServiceServer) CreateBlockchains(context.Context, *CreateBlockchainsRequest) (*CreateBlockchainsResponse, error)
- func (UnimplementedControlServiceServer) CreateChains(context.Context, *CreateChainsRequest) (*CreateChainsResponse, 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) PauseNode(context.Context, *PauseNodeRequest) (*PauseNodeResponse, error)
- func (UnimplementedControlServiceServer) RPCVersion(context.Context, *RPCVersionRequest) (*RPCVersionResponse, error)
- func (UnimplementedControlServiceServer) RemoveChainValidator(context.Context, *RemoveChainValidatorRequest) (*RemoveChainValidatorResponse, 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) ResumeNode(context.Context, *ResumeNodeRequest) (*ResumeNodeResponse, 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, grpc.ServerStreamingServer[StreamStatusResponse]) error
- func (UnimplementedControlServiceServer) TransformElasticChains(context.Context, *TransformElasticChainsRequest) (*TransformElasticChainsResponse, error)
- func (UnimplementedControlServiceServer) URIs(context.Context, *URIsRequest) (*URIsResponse, error)
- func (UnimplementedControlServiceServer) WaitForHealthy(context.Context, *WaitForHealthyRequest) (*WaitForHealthyResponse, error)
- type UnimplementedPingServiceServer
- type UnsafeControlServiceServer
- type UnsafePingServiceServer
- type WaitForHealthyRequest
- type WaitForHealthyResponse
- func (*WaitForHealthyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WaitForHealthyResponse) GetClusterInfo() *ClusterInfo
- func (*WaitForHealthyResponse) ProtoMessage()
- func (x *WaitForHealthyResponse) ProtoReflect() protoreflect.Message
- func (x *WaitForHealthyResponse) Reset()
- func (x *WaitForHealthyResponse) String() string
Constants ¶
const ( ControlService_RPCVersion_FullMethodName = "/rpcpb.ControlService/RPCVersion" ControlService_Start_FullMethodName = "/rpcpb.ControlService/Start" ControlService_CreateBlockchains_FullMethodName = "/rpcpb.ControlService/CreateBlockchains" ControlService_TransformElasticChains_FullMethodName = "/rpcpb.ControlService/TransformElasticChains" ControlService_AddPermissionlessValidator_FullMethodName = "/rpcpb.ControlService/AddPermissionlessValidator" ControlService_RemoveChainValidator_FullMethodName = "/rpcpb.ControlService/RemoveChainValidator" ControlService_CreateChains_FullMethodName = "/rpcpb.ControlService/CreateChains" ControlService_Health_FullMethodName = "/rpcpb.ControlService/Health" ControlService_URIs_FullMethodName = "/rpcpb.ControlService/URIs" ControlService_WaitForHealthy_FullMethodName = "/rpcpb.ControlService/WaitForHealthy" ControlService_Status_FullMethodName = "/rpcpb.ControlService/Status" ControlService_StreamStatus_FullMethodName = "/rpcpb.ControlService/StreamStatus" ControlService_RemoveNode_FullMethodName = "/rpcpb.ControlService/RemoveNode" ControlService_AddNode_FullMethodName = "/rpcpb.ControlService/AddNode" ControlService_RestartNode_FullMethodName = "/rpcpb.ControlService/RestartNode" ControlService_PauseNode_FullMethodName = "/rpcpb.ControlService/PauseNode" ControlService_ResumeNode_FullMethodName = "/rpcpb.ControlService/ResumeNode" ControlService_Stop_FullMethodName = "/rpcpb.ControlService/Stop" ControlService_AttachPeer_FullMethodName = "/rpcpb.ControlService/AttachPeer" ControlService_SendOutboundMessage_FullMethodName = "/rpcpb.ControlService/SendOutboundMessage" ControlService_SaveSnapshot_FullMethodName = "/rpcpb.ControlService/SaveSnapshot" ControlService_LoadSnapshot_FullMethodName = "/rpcpb.ControlService/LoadSnapshot" ControlService_RemoveSnapshot_FullMethodName = "/rpcpb.ControlService/RemoveSnapshot" ControlService_GetSnapshotNames_FullMethodName = "/rpcpb.ControlService/GetSnapshotNames" )
const (
PingService_Ping_FullMethodName = "/rpcpb.PingService/Ping"
)
Variables ¶
var ControlService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "rpcpb.ControlService", HandlerType: (*ControlServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RPCVersion", Handler: _ControlService_RPCVersion_Handler, }, { MethodName: "Start", Handler: _ControlService_Start_Handler, }, { MethodName: "CreateBlockchains", Handler: _ControlService_CreateBlockchains_Handler, }, { MethodName: "TransformElasticChains", Handler: _ControlService_TransformElasticChains_Handler, }, { MethodName: "AddPermissionlessValidator", Handler: _ControlService_AddPermissionlessValidator_Handler, }, { MethodName: "RemoveChainValidator", Handler: _ControlService_RemoveChainValidator_Handler, }, { MethodName: "CreateChains", Handler: _ControlService_CreateChains_Handler, }, { MethodName: "Health", Handler: _ControlService_Health_Handler, }, { MethodName: "URIs", Handler: _ControlService_URIs_Handler, }, { MethodName: "WaitForHealthy", Handler: _ControlService_WaitForHealthy_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: "PauseNode", Handler: _ControlService_PauseNode_Handler, }, { MethodName: "ResumeNode", Handler: _ControlService_ResumeNode_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 RegisterControlServiceHandler ¶
func RegisterControlServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterControlServiceHandler registers the http handlers for service ControlService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterControlServiceHandlerClient ¶
func RegisterControlServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ControlServiceClient) error
RegisterControlServiceHandlerClient registers the http handlers for service ControlService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ControlServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ControlServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ControlServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.
func RegisterControlServiceHandlerFromEndpoint ¶
func RegisterControlServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterControlServiceHandlerFromEndpoint is same as RegisterControlServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterControlServiceHandlerServer ¶
func RegisterControlServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ControlServiceServer) error
RegisterControlServiceHandlerServer registers the http handlers for service ControlService to "mux". UnaryRPC :call ControlServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterControlServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.
func RegisterControlServiceServer ¶
func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)
func RegisterPingServiceHandler ¶
func RegisterPingServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterPingServiceHandler registers the http handlers for service PingService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterPingServiceHandlerClient ¶
func RegisterPingServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PingServiceClient) error
RegisterPingServiceHandlerClient registers the http handlers for service PingService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PingServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PingServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PingServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.
func RegisterPingServiceHandlerFromEndpoint ¶
func RegisterPingServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterPingServiceHandlerFromEndpoint is same as RegisterPingServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterPingServiceHandlerServer ¶
func RegisterPingServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PingServiceServer) error
RegisterPingServiceHandlerServer registers the http handlers for service PingService to "mux". UnaryRPC :call PingServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPingServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.
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 `` /* 171-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 `` /* 177-byte string literal not displayed */
// Map of chain id to chain config file contents.
// If specified, will create a file "chainid.json" under chains config dir with
// the contents provided here.
ChainConfigFiles map[string]string `` /* 185-byte string literal not displayed */
// Plugin dir from which to load all custom VM executables.
PluginDir string `protobuf:"bytes,7,opt,name=plugin_dir,json=pluginDir,proto3" json:"plugin_dir,omitempty"`
// contains filtered or unexported fields
}
func (*AddNodeRequest) Descriptor
deprecated
func (*AddNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddNodeRequest.ProtoReflect.Descriptor instead.
func (*AddNodeRequest) GetChainConfigFiles ¶ added in v1.6.1
func (x *AddNodeRequest) GetChainConfigFiles() map[string]string
func (*AddNodeRequest) GetChainConfigs ¶
func (x *AddNodeRequest) GetChainConfigs() map[string]string
func (*AddNodeRequest) GetExecPath ¶
func (x *AddNodeRequest) GetExecPath() string
func (*AddNodeRequest) GetName ¶
func (x *AddNodeRequest) GetName() string
func (*AddNodeRequest) GetNodeConfig ¶
func (x *AddNodeRequest) GetNodeConfig() string
func (*AddNodeRequest) GetPluginDir ¶
func (x *AddNodeRequest) GetPluginDir() string
func (*AddNodeRequest) GetUpgradeConfigs ¶
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 AddPermissionlessValidatorRequest ¶
type AddPermissionlessValidatorRequest struct {
ValidatorSpec []*PermissionlessValidatorSpec `protobuf:"bytes,1,rep,name=validator_spec,json=validatorSpec,proto3" json:"validator_spec,omitempty"`
// contains filtered or unexported fields
}
func (*AddPermissionlessValidatorRequest) Descriptor
deprecated
func (*AddPermissionlessValidatorRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddPermissionlessValidatorRequest.ProtoReflect.Descriptor instead.
func (*AddPermissionlessValidatorRequest) GetValidatorSpec ¶
func (x *AddPermissionlessValidatorRequest) GetValidatorSpec() []*PermissionlessValidatorSpec
func (*AddPermissionlessValidatorRequest) ProtoMessage ¶
func (*AddPermissionlessValidatorRequest) ProtoMessage()
func (*AddPermissionlessValidatorRequest) ProtoReflect ¶
func (x *AddPermissionlessValidatorRequest) ProtoReflect() protoreflect.Message
func (*AddPermissionlessValidatorRequest) Reset ¶
func (x *AddPermissionlessValidatorRequest) Reset()
func (*AddPermissionlessValidatorRequest) String ¶
func (x *AddPermissionlessValidatorRequest) String() string
type AddPermissionlessValidatorResponse ¶
type AddPermissionlessValidatorResponse struct {
ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
// contains filtered or unexported fields
}
func (*AddPermissionlessValidatorResponse) Descriptor
deprecated
func (*AddPermissionlessValidatorResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddPermissionlessValidatorResponse.ProtoReflect.Descriptor instead.
func (*AddPermissionlessValidatorResponse) GetClusterInfo ¶
func (x *AddPermissionlessValidatorResponse) GetClusterInfo() *ClusterInfo
func (*AddPermissionlessValidatorResponse) ProtoMessage ¶
func (*AddPermissionlessValidatorResponse) ProtoMessage()
func (*AddPermissionlessValidatorResponse) ProtoReflect ¶
func (x *AddPermissionlessValidatorResponse) ProtoReflect() protoreflect.Message
func (*AddPermissionlessValidatorResponse) Reset ¶
func (x *AddPermissionlessValidatorResponse) Reset()
func (*AddPermissionlessValidatorResponse) String ¶
func (x *AddPermissionlessValidatorResponse) 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 ¶
type BlockchainSpec struct {
VmName string `protobuf:"bytes,1,opt,name=vm_name,json=vmName,proto3" json:"vm_name,omitempty"`
// either file path or file contents
Genesis string `protobuf:"bytes,2,opt,name=genesis,proto3" json:"genesis,omitempty"`
// either a chain_id is given for a previously created chain,
// or a chain specification is given for a new chain generation
ChainId *string `protobuf:"bytes,3,opt,name=chain_id,json=chainId,proto3,oneof" json:"chain_id,omitempty"`
ChainSpec *ChainSpec `protobuf:"bytes,4,opt,name=chain_spec,json=chainSpec,proto3,oneof" json:"chain_spec,omitempty"`
// General chain config, either file path or file contents
ChainConfig string `protobuf:"bytes,5,opt,name=chain_config,json=chainConfig,proto3" json:"chain_config,omitempty"`
// either file path or file contents
NetworkUpgrade string `protobuf:"bytes,6,opt,name=network_upgrade,json=networkUpgrade,proto3" json:"network_upgrade,omitempty"`
BlockchainAlias string `protobuf:"bytes,7,opt,name=blockchain_alias,json=blockchainAlias,proto3" json:"blockchain_alias,omitempty"`
// Per node chain config, either file path or file contents
PerNodeChainConfig string `protobuf:"bytes,8,opt,name=per_node_chain_config,json=perNodeChainConfig,proto3" json:"per_node_chain_config,omitempty"`
// contains filtered or unexported fields
}
func (*BlockchainSpec) Descriptor
deprecated
func (*BlockchainSpec) Descriptor() ([]byte, []int)
Deprecated: Use BlockchainSpec.ProtoReflect.Descriptor instead.
func (*BlockchainSpec) GetBlockchainAlias ¶
func (x *BlockchainSpec) GetBlockchainAlias() string
func (*BlockchainSpec) GetChainConfig ¶
func (x *BlockchainSpec) GetChainConfig() string
func (*BlockchainSpec) GetChainId ¶ added in v1.6.1
func (x *BlockchainSpec) GetChainId() string
func (*BlockchainSpec) GetChainSpec ¶ added in v1.6.1
func (x *BlockchainSpec) GetChainSpec() *ChainSpec
func (*BlockchainSpec) GetGenesis ¶
func (x *BlockchainSpec) GetGenesis() string
func (*BlockchainSpec) GetNetworkUpgrade ¶
func (x *BlockchainSpec) GetNetworkUpgrade() string
func (*BlockchainSpec) GetPerNodeChainConfig ¶
func (x *BlockchainSpec) GetPerNodeChainConfig() string
func (*BlockchainSpec) GetVmName ¶
func (x *BlockchainSpec) GetVmName() string
func (*BlockchainSpec) ProtoMessage ¶
func (*BlockchainSpec) ProtoMessage()
func (*BlockchainSpec) ProtoReflect ¶
func (x *BlockchainSpec) ProtoReflect() protoreflect.Message
func (*BlockchainSpec) Reset ¶
func (x *BlockchainSpec) Reset()
func (*BlockchainSpec) String ¶
func (x *BlockchainSpec) String() string
type ChainInfo ¶ added in v1.6.1
type ChainInfo struct {
// If Chain is an Elastic Chain
IsElastic bool `protobuf:"varint,1,opt,name=is_elastic,json=isElastic,proto3" json:"is_elastic,omitempty"`
// TXID for the elastic chain transform
ElasticChainId string `protobuf:"bytes,2,opt,name=elastic_chain_id,json=elasticChainId,proto3" json:"elastic_chain_id,omitempty"`
// node validators of chain
ChainParticipants *ChainParticipants `protobuf:"bytes,3,opt,name=chain_participants,json=chainParticipants,proto3" json:"chain_participants,omitempty"`
// contains filtered or unexported fields
}
func (*ChainInfo) Descriptor
deprecated
added in
v1.6.1
func (*ChainInfo) GetChainParticipants ¶ added in v1.6.1
func (x *ChainInfo) GetChainParticipants() *ChainParticipants
func (*ChainInfo) GetElasticChainId ¶ added in v1.6.1
func (*ChainInfo) GetIsElastic ¶ added in v1.6.1
func (*ChainInfo) ProtoMessage ¶ added in v1.6.1
func (*ChainInfo) ProtoMessage()
func (*ChainInfo) ProtoReflect ¶ added in v1.6.1
func (x *ChainInfo) ProtoReflect() protoreflect.Message
type ChainParticipants ¶ added in v1.6.1
type ChainParticipants struct {
NodeNames []string `protobuf:"bytes,1,rep,name=node_names,json=nodeNames,proto3" json:"node_names,omitempty"`
// contains filtered or unexported fields
}
func (*ChainParticipants) Descriptor
deprecated
added in
v1.6.1
func (*ChainParticipants) Descriptor() ([]byte, []int)
Deprecated: Use ChainParticipants.ProtoReflect.Descriptor instead.
func (*ChainParticipants) GetNodeNames ¶ added in v1.6.1
func (x *ChainParticipants) GetNodeNames() []string
func (*ChainParticipants) ProtoMessage ¶ added in v1.6.1
func (*ChainParticipants) ProtoMessage()
func (*ChainParticipants) ProtoReflect ¶ added in v1.6.1
func (x *ChainParticipants) ProtoReflect() protoreflect.Message
func (*ChainParticipants) Reset ¶ added in v1.6.1
func (x *ChainParticipants) Reset()
func (*ChainParticipants) String ¶ added in v1.6.1
func (x *ChainParticipants) String() string
type ChainSpec ¶ added in v1.6.1
type ChainSpec struct {
// if empty, assumes all nodes should be participants
Participants []string `protobuf:"bytes,1,rep,name=participants,proto3" json:"participants,omitempty"`
// either file path or file contents
ChainConfigFile string `protobuf:"bytes,2,opt,name=chain_config_file,json=chainConfigFile,proto3" json:"chain_config_file,omitempty"`
// contains filtered or unexported fields
}
func (*ChainSpec) Descriptor
deprecated
added in
v1.6.1
func (*ChainSpec) GetChainConfigFile ¶ added in v1.6.1
func (*ChainSpec) GetParticipants ¶ added in v1.6.1
func (*ChainSpec) ProtoMessage ¶ added in v1.6.1
func (*ChainSpec) ProtoMessage()
func (*ChainSpec) ProtoReflect ¶ added in v1.6.1
func (x *ChainSpec) ProtoReflect() protoreflect.Message
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 `` /* 162-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 `` /* 188-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 `` /* 171-byte string literal not displayed */
Chains map[string]*ChainInfo `` /* 139-byte string literal not displayed */
// 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) GetChains ¶ added in v1.6.1
func (x *ClusterInfo) GetChains() map[string]*ChainInfo
func (*ClusterInfo) GetCustomChains ¶
func (x *ClusterInfo) GetCustomChains() map[string]*CustomChainInfo
func (*ClusterInfo) GetCustomChainsHealthy ¶
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) 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 {
RPCVersion(ctx context.Context, in *RPCVersionRequest, opts ...grpc.CallOption) (*RPCVersionResponse, error)
Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
CreateBlockchains(ctx context.Context, in *CreateBlockchainsRequest, opts ...grpc.CallOption) (*CreateBlockchainsResponse, error)
TransformElasticChains(ctx context.Context, in *TransformElasticChainsRequest, opts ...grpc.CallOption) (*TransformElasticChainsResponse, error)
AddPermissionlessValidator(ctx context.Context, in *AddPermissionlessValidatorRequest, opts ...grpc.CallOption) (*AddPermissionlessValidatorResponse, error)
RemoveChainValidator(ctx context.Context, in *RemoveChainValidatorRequest, opts ...grpc.CallOption) (*RemoveChainValidatorResponse, error)
CreateChains(ctx context.Context, in *CreateChainsRequest, opts ...grpc.CallOption) (*CreateChainsResponse, error)
Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
URIs(ctx context.Context, in *URIsRequest, opts ...grpc.CallOption) (*URIsResponse, error)
WaitForHealthy(ctx context.Context, in *WaitForHealthyRequest, opts ...grpc.CallOption) (*WaitForHealthyResponse, error)
Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
StreamStatus(ctx context.Context, in *StreamStatusRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamStatusResponse], 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)
PauseNode(ctx context.Context, in *PauseNodeRequest, opts ...grpc.CallOption) (*PauseNodeResponse, error)
ResumeNode(ctx context.Context, in *ResumeNodeRequest, opts ...grpc.CallOption) (*ResumeNodeResponse, 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 {
RPCVersion(context.Context, *RPCVersionRequest) (*RPCVersionResponse, error)
Start(context.Context, *StartRequest) (*StartResponse, error)
CreateBlockchains(context.Context, *CreateBlockchainsRequest) (*CreateBlockchainsResponse, error)
TransformElasticChains(context.Context, *TransformElasticChainsRequest) (*TransformElasticChainsResponse, error)
AddPermissionlessValidator(context.Context, *AddPermissionlessValidatorRequest) (*AddPermissionlessValidatorResponse, error)
RemoveChainValidator(context.Context, *RemoveChainValidatorRequest) (*RemoveChainValidatorResponse, error)
CreateChains(context.Context, *CreateChainsRequest) (*CreateChainsResponse, error)
Health(context.Context, *HealthRequest) (*HealthResponse, error)
URIs(context.Context, *URIsRequest) (*URIsResponse, error)
WaitForHealthy(context.Context, *WaitForHealthyRequest) (*WaitForHealthyResponse, error)
Status(context.Context, *StatusRequest) (*StatusResponse, error)
StreamStatus(*StreamStatusRequest, grpc.ServerStreamingServer[StreamStatusResponse]) error
RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)
RestartNode(context.Context, *RestartNodeRequest) (*RestartNodeResponse, error)
PauseNode(context.Context, *PauseNodeRequest) (*PauseNodeResponse, error)
ResumeNode(context.Context, *ResumeNodeRequest) (*ResumeNodeResponse, 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 = grpc.ServerStreamingClient[StreamStatusResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ControlService_StreamStatusServer ¶
type ControlService_StreamStatusServer = grpc.ServerStreamingServer[StreamStatusResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type CreateBlockchainsRequest ¶
type CreateBlockchainsRequest struct {
// The list of:
// - custom chain's VM name
// - genesis file path
// - (optional) chain id to use.
// - chain config file path
// - network upgrade file path
// - chain config file path
// - chain config file path for specific nodes
//
// The matching file with the name in "ids.ID" format must exist.
// e.g., ids.ToID(hashing.ComputeHash256("chainevm")).String()
// e.g., chain-cli create VMID chainevm
//
// 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
func (*CreateBlockchainsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateBlockchainsRequest.ProtoReflect.Descriptor instead.
func (*CreateBlockchainsRequest) GetBlockchainSpecs ¶
func (x *CreateBlockchainsRequest) GetBlockchainSpecs() []*BlockchainSpec
func (*CreateBlockchainsRequest) ProtoMessage ¶
func (*CreateBlockchainsRequest) ProtoMessage()
func (*CreateBlockchainsRequest) ProtoReflect ¶
func (x *CreateBlockchainsRequest) ProtoReflect() protoreflect.Message
func (*CreateBlockchainsRequest) Reset ¶
func (x *CreateBlockchainsRequest) Reset()
func (*CreateBlockchainsRequest) String ¶
func (x *CreateBlockchainsRequest) String() string
type CreateBlockchainsResponse ¶
type CreateBlockchainsResponse struct {
ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
ChainIds []string `protobuf:"bytes,2,rep,name=chain_ids,json=chainIds,proto3" json:"chain_ids,omitempty"`
// contains filtered or unexported fields
}
func (*CreateBlockchainsResponse) Descriptor
deprecated
func (*CreateBlockchainsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateBlockchainsResponse.ProtoReflect.Descriptor instead.
func (*CreateBlockchainsResponse) GetChainIds ¶
func (x *CreateBlockchainsResponse) GetChainIds() []string
func (*CreateBlockchainsResponse) GetClusterInfo ¶
func (x *CreateBlockchainsResponse) GetClusterInfo() *ClusterInfo
func (*CreateBlockchainsResponse) ProtoMessage ¶
func (*CreateBlockchainsResponse) ProtoMessage()
func (*CreateBlockchainsResponse) ProtoReflect ¶
func (x *CreateBlockchainsResponse) ProtoReflect() protoreflect.Message
func (*CreateBlockchainsResponse) Reset ¶
func (x *CreateBlockchainsResponse) Reset()
func (*CreateBlockchainsResponse) String ¶
func (x *CreateBlockchainsResponse) String() string
type CreateChainsRequest ¶ added in v1.6.1
type CreateChainsRequest struct {
ChainSpecs []*ChainSpec `protobuf:"bytes,1,rep,name=chain_specs,json=chainSpecs,proto3" json:"chain_specs,omitempty"`
// contains filtered or unexported fields
}
func (*CreateChainsRequest) Descriptor
deprecated
added in
v1.6.1
func (*CreateChainsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateChainsRequest.ProtoReflect.Descriptor instead.
func (*CreateChainsRequest) GetChainSpecs ¶ added in v1.6.1
func (x *CreateChainsRequest) GetChainSpecs() []*ChainSpec
func (*CreateChainsRequest) ProtoMessage ¶ added in v1.6.1
func (*CreateChainsRequest) ProtoMessage()
func (*CreateChainsRequest) ProtoReflect ¶ added in v1.6.1
func (x *CreateChainsRequest) ProtoReflect() protoreflect.Message
func (*CreateChainsRequest) Reset ¶ added in v1.6.1
func (x *CreateChainsRequest) Reset()
func (*CreateChainsRequest) String ¶ added in v1.6.1
func (x *CreateChainsRequest) String() string
type CreateChainsResponse ¶ added in v1.6.1
type CreateChainsResponse struct {
ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
ChainIds []string `protobuf:"bytes,2,rep,name=chain_ids,json=chainIds,proto3" json:"chain_ids,omitempty"`
// contains filtered or unexported fields
}
func (*CreateChainsResponse) Descriptor
deprecated
added in
v1.6.1
func (*CreateChainsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateChainsResponse.ProtoReflect.Descriptor instead.
func (*CreateChainsResponse) GetChainIds ¶ added in v1.6.1
func (x *CreateChainsResponse) GetChainIds() []string
func (*CreateChainsResponse) GetClusterInfo ¶ added in v1.6.1
func (x *CreateChainsResponse) GetClusterInfo() *ClusterInfo
func (*CreateChainsResponse) ProtoMessage ¶ added in v1.6.1
func (*CreateChainsResponse) ProtoMessage()
func (*CreateChainsResponse) ProtoReflect ¶ added in v1.6.1
func (x *CreateChainsResponse) ProtoReflect() protoreflect.Message
func (*CreateChainsResponse) Reset ¶ added in v1.6.1
func (x *CreateChainsResponse) Reset()
func (*CreateChainsResponse) String ¶ added in v1.6.1
func (x *CreateChainsResponse) String() string
type CustomChainInfo ¶
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 chain transaction ID -- P-Chain chain ID.
// The chain ID must be whitelisted by the lux node.
PchainId string `protobuf:"bytes,3,opt,name=pchain_id,json=pchainId,proto3" json:"pchain_id,omitempty"`
// Create blockchain transaction ID -- blockchain ID>
// The blockchain ID is used for RPC endpoints.
BlockchainId string `protobuf:"bytes,4,opt,name=blockchain_id,json=blockchainId,proto3" json:"blockchain_id,omitempty"`
// contains filtered or unexported fields
}
func (*CustomChainInfo) Descriptor
deprecated
func (*CustomChainInfo) Descriptor() ([]byte, []int)
Deprecated: Use CustomChainInfo.ProtoReflect.Descriptor instead.
func (*CustomChainInfo) GetBlockchainId ¶ added in v1.6.1
func (x *CustomChainInfo) GetBlockchainId() string
func (*CustomChainInfo) GetChainName ¶
func (x *CustomChainInfo) GetChainName() string
func (*CustomChainInfo) GetPchainId ¶ added in v1.6.1
func (x *CustomChainInfo) GetPchainId() string
func (*CustomChainInfo) GetVmId ¶
func (x *CustomChainInfo) GetVmId() string
func (*CustomChainInfo) ProtoMessage ¶
func (*CustomChainInfo) ProtoMessage()
func (*CustomChainInfo) ProtoReflect ¶
func (x *CustomChainInfo) ProtoReflect() protoreflect.Message
func (*CustomChainInfo) Reset ¶
func (x *CustomChainInfo) Reset()
func (*CustomChainInfo) String ¶
func (x *CustomChainInfo) String() string
type ElasticChainSpec ¶ added in v1.6.1
type ElasticChainSpec struct {
ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
AssetName string `protobuf:"bytes,2,opt,name=asset_name,json=assetName,proto3" json:"asset_name,omitempty"`
AssetSymbol string `protobuf:"bytes,3,opt,name=asset_symbol,json=assetSymbol,proto3" json:"asset_symbol,omitempty"`
InitialSupply uint64 `protobuf:"varint,4,opt,name=initial_supply,json=initialSupply,proto3" json:"initial_supply,omitempty"`
MaxSupply uint64 `protobuf:"varint,5,opt,name=max_supply,json=maxSupply,proto3" json:"max_supply,omitempty"`
MinConsumptionRate uint64 `protobuf:"varint,6,opt,name=min_consumption_rate,json=minConsumptionRate,proto3" json:"min_consumption_rate,omitempty"`
MaxConsumptionRate uint64 `protobuf:"varint,7,opt,name=max_consumption_rate,json=maxConsumptionRate,proto3" json:"max_consumption_rate,omitempty"`
MinValidatorStake uint64 `protobuf:"varint,8,opt,name=min_validator_stake,json=minValidatorStake,proto3" json:"min_validator_stake,omitempty"`
MaxValidatorStake uint64 `protobuf:"varint,9,opt,name=max_validator_stake,json=maxValidatorStake,proto3" json:"max_validator_stake,omitempty"`
MinStakeDuration uint64 `protobuf:"varint,10,opt,name=min_stake_duration,json=minStakeDuration,proto3" json:"min_stake_duration,omitempty"`
MaxStakeDuration uint64 `protobuf:"varint,11,opt,name=max_stake_duration,json=maxStakeDuration,proto3" json:"max_stake_duration,omitempty"`
MinDelegationFee uint32 `protobuf:"varint,12,opt,name=min_delegation_fee,json=minDelegationFee,proto3" json:"min_delegation_fee,omitempty"`
MinDelegatorStake uint64 `protobuf:"varint,13,opt,name=min_delegator_stake,json=minDelegatorStake,proto3" json:"min_delegator_stake,omitempty"`
MaxValidatorWeightFactor uint32 `` /* 139-byte string literal not displayed */
UptimeRequirement uint32 `protobuf:"varint,15,opt,name=uptime_requirement,json=uptimeRequirement,proto3" json:"uptime_requirement,omitempty"`
// contains filtered or unexported fields
}
func (*ElasticChainSpec) Descriptor
deprecated
added in
v1.6.1
func (*ElasticChainSpec) Descriptor() ([]byte, []int)
Deprecated: Use ElasticChainSpec.ProtoReflect.Descriptor instead.
func (*ElasticChainSpec) GetAssetName ¶ added in v1.6.1
func (x *ElasticChainSpec) GetAssetName() string
func (*ElasticChainSpec) GetAssetSymbol ¶ added in v1.6.1
func (x *ElasticChainSpec) GetAssetSymbol() string
func (*ElasticChainSpec) GetChainId ¶ added in v1.6.1
func (x *ElasticChainSpec) GetChainId() string
func (*ElasticChainSpec) GetInitialSupply ¶ added in v1.6.1
func (x *ElasticChainSpec) GetInitialSupply() uint64
func (*ElasticChainSpec) GetMaxConsumptionRate ¶ added in v1.6.1
func (x *ElasticChainSpec) GetMaxConsumptionRate() uint64
func (*ElasticChainSpec) GetMaxStakeDuration ¶ added in v1.6.1
func (x *ElasticChainSpec) GetMaxStakeDuration() uint64
func (*ElasticChainSpec) GetMaxSupply ¶ added in v1.6.1
func (x *ElasticChainSpec) GetMaxSupply() uint64
func (*ElasticChainSpec) GetMaxValidatorStake ¶ added in v1.6.1
func (x *ElasticChainSpec) GetMaxValidatorStake() uint64
func (*ElasticChainSpec) GetMaxValidatorWeightFactor ¶ added in v1.6.1
func (x *ElasticChainSpec) GetMaxValidatorWeightFactor() uint32
func (*ElasticChainSpec) GetMinConsumptionRate ¶ added in v1.6.1
func (x *ElasticChainSpec) GetMinConsumptionRate() uint64
func (*ElasticChainSpec) GetMinDelegationFee ¶ added in v1.6.1
func (x *ElasticChainSpec) GetMinDelegationFee() uint32
func (*ElasticChainSpec) GetMinDelegatorStake ¶ added in v1.6.1
func (x *ElasticChainSpec) GetMinDelegatorStake() uint64
func (*ElasticChainSpec) GetMinStakeDuration ¶ added in v1.6.1
func (x *ElasticChainSpec) GetMinStakeDuration() uint64
func (*ElasticChainSpec) GetMinValidatorStake ¶ added in v1.6.1
func (x *ElasticChainSpec) GetMinValidatorStake() uint64
func (*ElasticChainSpec) GetUptimeRequirement ¶ added in v1.6.1
func (x *ElasticChainSpec) GetUptimeRequirement() uint32
func (*ElasticChainSpec) ProtoMessage ¶ added in v1.6.1
func (*ElasticChainSpec) ProtoMessage()
func (*ElasticChainSpec) ProtoReflect ¶ added in v1.6.1
func (x *ElasticChainSpec) ProtoReflect() protoreflect.Message
func (*ElasticChainSpec) Reset ¶ added in v1.6.1
func (x *ElasticChainSpec) Reset()
func (*ElasticChainSpec) String ¶ added in v1.6.1
func (x *ElasticChainSpec) String() string
type GetSnapshotNamesRequest ¶
type GetSnapshotNamesRequest struct {
// contains filtered or unexported fields
}
func (*GetSnapshotNamesRequest) Descriptor
deprecated
func (*GetSnapshotNamesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSnapshotNamesRequest.ProtoReflect.Descriptor instead.
func (*GetSnapshotNamesRequest) ProtoMessage ¶
func (*GetSnapshotNamesRequest) ProtoMessage()
func (*GetSnapshotNamesRequest) ProtoReflect ¶
func (x *GetSnapshotNamesRequest) ProtoReflect() protoreflect.Message
func (*GetSnapshotNamesRequest) Reset ¶
func (x *GetSnapshotNamesRequest) Reset()
func (*GetSnapshotNamesRequest) String ¶
func (x *GetSnapshotNamesRequest) String() string
type GetSnapshotNamesResponse ¶
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
func (*GetSnapshotNamesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSnapshotNamesResponse.ProtoReflect.Descriptor instead.
func (*GetSnapshotNamesResponse) GetSnapshotNames ¶
func (x *GetSnapshotNamesResponse) GetSnapshotNames() []string
func (*GetSnapshotNamesResponse) ProtoMessage ¶
func (*GetSnapshotNamesResponse) ProtoMessage()
func (*GetSnapshotNamesResponse) ProtoReflect ¶
func (x *GetSnapshotNamesResponse) ProtoReflect() protoreflect.Message
func (*GetSnapshotNamesResponse) Reset ¶
func (x *GetSnapshotNamesResponse) Reset()
func (*GetSnapshotNamesResponse) String ¶
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 ¶
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" 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 `` /* 171-byte string literal not displayed */
UpgradeConfigs map[string]string `` /* 177-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 */
ChainConfigFiles map[string]string `` /* 185-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*LoadSnapshotRequest) Descriptor
deprecated
func (*LoadSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadSnapshotRequest.ProtoReflect.Descriptor instead.
func (*LoadSnapshotRequest) GetChainConfigFiles ¶ added in v1.6.1
func (x *LoadSnapshotRequest) GetChainConfigFiles() map[string]string
func (*LoadSnapshotRequest) GetChainConfigs ¶
func (x *LoadSnapshotRequest) GetChainConfigs() map[string]string
func (*LoadSnapshotRequest) GetExecPath ¶
func (x *LoadSnapshotRequest) GetExecPath() string
func (*LoadSnapshotRequest) GetGlobalNodeConfig ¶
func (x *LoadSnapshotRequest) GetGlobalNodeConfig() string
func (*LoadSnapshotRequest) GetPluginDir ¶
func (x *LoadSnapshotRequest) GetPluginDir() string
func (*LoadSnapshotRequest) GetReassignPortsIfUsed ¶
func (x *LoadSnapshotRequest) GetReassignPortsIfUsed() bool
func (*LoadSnapshotRequest) GetRootDataDir ¶
func (x *LoadSnapshotRequest) GetRootDataDir() string
func (*LoadSnapshotRequest) GetSnapshotName ¶
func (x *LoadSnapshotRequest) GetSnapshotName() string
func (*LoadSnapshotRequest) GetUpgradeConfigs ¶
func (x *LoadSnapshotRequest) GetUpgradeConfigs() map[string]string
func (*LoadSnapshotRequest) ProtoMessage ¶
func (*LoadSnapshotRequest) ProtoMessage()
func (*LoadSnapshotRequest) ProtoReflect ¶
func (x *LoadSnapshotRequest) ProtoReflect() protoreflect.Message
func (*LoadSnapshotRequest) Reset ¶
func (x *LoadSnapshotRequest) Reset()
func (*LoadSnapshotRequest) String ¶
func (x *LoadSnapshotRequest) String() string
type LoadSnapshotResponse ¶
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
func (*LoadSnapshotResponse) Descriptor() ([]byte, []int)
Deprecated: Use LoadSnapshotResponse.ProtoReflect.Descriptor instead.
func (*LoadSnapshotResponse) GetClusterInfo ¶
func (x *LoadSnapshotResponse) GetClusterInfo() *ClusterInfo
func (*LoadSnapshotResponse) ProtoMessage ¶
func (*LoadSnapshotResponse) ProtoMessage()
func (*LoadSnapshotResponse) ProtoReflect ¶
func (x *LoadSnapshotResponse) ProtoReflect() protoreflect.Message
func (*LoadSnapshotResponse) Reset ¶
func (x *LoadSnapshotResponse) Reset()
func (*LoadSnapshotResponse) String ¶
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"`
WhitelistedChains string `protobuf:"bytes,8,opt,name=whitelisted_chains,json=whitelistedChains,proto3" json:"whitelisted_chains,omitempty"`
Config []byte `protobuf:"bytes,9,opt,name=config,proto3" json:"config,omitempty"`
Paused bool `protobuf:"varint,10,opt,name=paused,proto3" json:"paused,omitempty"`
// contains filtered or unexported fields
}
func (*NodeInfo) Descriptor
deprecated
func (*NodeInfo) GetExecPath ¶
func (*NodeInfo) GetPluginDir ¶
func (*NodeInfo) GetWhitelistedChains ¶ added in v1.6.1
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) ProtoReflect ¶
func (x *NodeInfo) ProtoReflect() protoreflect.Message
type PauseNodeRequest ¶
type PauseNodeRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*PauseNodeRequest) Descriptor
deprecated
func (*PauseNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use PauseNodeRequest.ProtoReflect.Descriptor instead.
func (*PauseNodeRequest) GetName ¶
func (x *PauseNodeRequest) GetName() string
func (*PauseNodeRequest) ProtoMessage ¶
func (*PauseNodeRequest) ProtoMessage()
func (*PauseNodeRequest) ProtoReflect ¶
func (x *PauseNodeRequest) ProtoReflect() protoreflect.Message
func (*PauseNodeRequest) Reset ¶
func (x *PauseNodeRequest) Reset()
func (*PauseNodeRequest) String ¶
func (x *PauseNodeRequest) String() string
type PauseNodeResponse ¶
type PauseNodeResponse struct {
ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
// contains filtered or unexported fields
}
func (*PauseNodeResponse) Descriptor
deprecated
func (*PauseNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use PauseNodeResponse.ProtoReflect.Descriptor instead.
func (*PauseNodeResponse) GetClusterInfo ¶
func (x *PauseNodeResponse) GetClusterInfo() *ClusterInfo
func (*PauseNodeResponse) ProtoMessage ¶
func (*PauseNodeResponse) ProtoMessage()
func (*PauseNodeResponse) ProtoReflect ¶
func (x *PauseNodeResponse) ProtoReflect() protoreflect.Message
func (*PauseNodeResponse) Reset ¶
func (x *PauseNodeResponse) Reset()
func (*PauseNodeResponse) String ¶
func (x *PauseNodeResponse) String() string
type PermissionlessValidatorSpec ¶
type PermissionlessValidatorSpec struct {
ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
StakedTokenAmount uint64 `protobuf:"varint,3,opt,name=staked_token_amount,json=stakedTokenAmount,proto3" json:"staked_token_amount,omitempty"`
AssetId string `protobuf:"bytes,4,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
StartTime string `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
StakeDuration uint64 `protobuf:"varint,6,opt,name=stake_duration,json=stakeDuration,proto3" json:"stake_duration,omitempty"`
// contains filtered or unexported fields
}
func (*PermissionlessValidatorSpec) Descriptor
deprecated
func (*PermissionlessValidatorSpec) Descriptor() ([]byte, []int)
Deprecated: Use PermissionlessValidatorSpec.ProtoReflect.Descriptor instead.
func (*PermissionlessValidatorSpec) GetAssetId ¶
func (x *PermissionlessValidatorSpec) GetAssetId() string
func (*PermissionlessValidatorSpec) GetChainId ¶ added in v1.6.1
func (x *PermissionlessValidatorSpec) GetChainId() string
func (*PermissionlessValidatorSpec) GetNodeName ¶
func (x *PermissionlessValidatorSpec) GetNodeName() string
func (*PermissionlessValidatorSpec) GetStakeDuration ¶
func (x *PermissionlessValidatorSpec) GetStakeDuration() uint64
func (*PermissionlessValidatorSpec) GetStakedTokenAmount ¶
func (x *PermissionlessValidatorSpec) GetStakedTokenAmount() uint64
func (*PermissionlessValidatorSpec) GetStartTime ¶
func (x *PermissionlessValidatorSpec) GetStartTime() string
func (*PermissionlessValidatorSpec) ProtoMessage ¶
func (*PermissionlessValidatorSpec) ProtoMessage()
func (*PermissionlessValidatorSpec) ProtoReflect ¶
func (x *PermissionlessValidatorSpec) ProtoReflect() protoreflect.Message
func (*PermissionlessValidatorSpec) Reset ¶
func (x *PermissionlessValidatorSpec) Reset()
func (*PermissionlessValidatorSpec) String ¶
func (x *PermissionlessValidatorSpec) String() string
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 RPCVersionRequest ¶
type RPCVersionRequest struct {
// contains filtered or unexported fields
}
func (*RPCVersionRequest) Descriptor
deprecated
func (*RPCVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use RPCVersionRequest.ProtoReflect.Descriptor instead.
func (*RPCVersionRequest) ProtoMessage ¶
func (*RPCVersionRequest) ProtoMessage()
func (*RPCVersionRequest) ProtoReflect ¶
func (x *RPCVersionRequest) ProtoReflect() protoreflect.Message
func (*RPCVersionRequest) Reset ¶
func (x *RPCVersionRequest) Reset()
func (*RPCVersionRequest) String ¶
func (x *RPCVersionRequest) String() string
type RPCVersionResponse ¶
type RPCVersionResponse struct {
Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*RPCVersionResponse) Descriptor
deprecated
func (*RPCVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use RPCVersionResponse.ProtoReflect.Descriptor instead.
func (*RPCVersionResponse) GetVersion ¶
func (x *RPCVersionResponse) GetVersion() uint32
func (*RPCVersionResponse) ProtoMessage ¶
func (*RPCVersionResponse) ProtoMessage()
func (*RPCVersionResponse) ProtoReflect ¶
func (x *RPCVersionResponse) ProtoReflect() protoreflect.Message
func (*RPCVersionResponse) Reset ¶
func (x *RPCVersionResponse) Reset()
func (*RPCVersionResponse) String ¶
func (x *RPCVersionResponse) String() string
type RemoveChainValidatorRequest ¶ added in v1.6.1
type RemoveChainValidatorRequest struct {
ValidatorSpec []*RemoveChainValidatorSpec `protobuf:"bytes,1,rep,name=validator_spec,json=validatorSpec,proto3" json:"validator_spec,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveChainValidatorRequest) Descriptor
deprecated
added in
v1.6.1
func (*RemoveChainValidatorRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveChainValidatorRequest.ProtoReflect.Descriptor instead.
func (*RemoveChainValidatorRequest) GetValidatorSpec ¶ added in v1.6.1
func (x *RemoveChainValidatorRequest) GetValidatorSpec() []*RemoveChainValidatorSpec
func (*RemoveChainValidatorRequest) ProtoMessage ¶ added in v1.6.1
func (*RemoveChainValidatorRequest) ProtoMessage()
func (*RemoveChainValidatorRequest) ProtoReflect ¶ added in v1.6.1
func (x *RemoveChainValidatorRequest) ProtoReflect() protoreflect.Message
func (*RemoveChainValidatorRequest) Reset ¶ added in v1.6.1
func (x *RemoveChainValidatorRequest) Reset()
func (*RemoveChainValidatorRequest) String ¶ added in v1.6.1
func (x *RemoveChainValidatorRequest) String() string
type RemoveChainValidatorResponse ¶ added in v1.6.1
type RemoveChainValidatorResponse struct {
ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveChainValidatorResponse) Descriptor
deprecated
added in
v1.6.1
func (*RemoveChainValidatorResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveChainValidatorResponse.ProtoReflect.Descriptor instead.
func (*RemoveChainValidatorResponse) GetClusterInfo ¶ added in v1.6.1
func (x *RemoveChainValidatorResponse) GetClusterInfo() *ClusterInfo
func (*RemoveChainValidatorResponse) ProtoMessage ¶ added in v1.6.1
func (*RemoveChainValidatorResponse) ProtoMessage()
func (*RemoveChainValidatorResponse) ProtoReflect ¶ added in v1.6.1
func (x *RemoveChainValidatorResponse) ProtoReflect() protoreflect.Message
func (*RemoveChainValidatorResponse) Reset ¶ added in v1.6.1
func (x *RemoveChainValidatorResponse) Reset()
func (*RemoveChainValidatorResponse) String ¶ added in v1.6.1
func (x *RemoveChainValidatorResponse) String() string
type RemoveChainValidatorSpec ¶ added in v1.6.1
type RemoveChainValidatorSpec struct {
ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
NodeNames []string `protobuf:"bytes,2,rep,name=node_names,json=nodeNames,proto3" json:"node_names,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveChainValidatorSpec) Descriptor
deprecated
added in
v1.6.1
func (*RemoveChainValidatorSpec) Descriptor() ([]byte, []int)
Deprecated: Use RemoveChainValidatorSpec.ProtoReflect.Descriptor instead.
func (*RemoveChainValidatorSpec) GetChainId ¶ added in v1.6.1
func (x *RemoveChainValidatorSpec) GetChainId() string
func (*RemoveChainValidatorSpec) GetNodeNames ¶ added in v1.6.1
func (x *RemoveChainValidatorSpec) GetNodeNames() []string
func (*RemoveChainValidatorSpec) ProtoMessage ¶ added in v1.6.1
func (*RemoveChainValidatorSpec) ProtoMessage()
func (*RemoveChainValidatorSpec) ProtoReflect ¶ added in v1.6.1
func (x *RemoveChainValidatorSpec) ProtoReflect() protoreflect.Message
func (*RemoveChainValidatorSpec) Reset ¶ added in v1.6.1
func (x *RemoveChainValidatorSpec) Reset()
func (*RemoveChainValidatorSpec) String ¶ added in v1.6.1
func (x *RemoveChainValidatorSpec) String() string
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 ¶
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
func (*RemoveSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveSnapshotRequest.ProtoReflect.Descriptor instead.
func (*RemoveSnapshotRequest) GetSnapshotName ¶
func (x *RemoveSnapshotRequest) GetSnapshotName() string
func (*RemoveSnapshotRequest) ProtoMessage ¶
func (*RemoveSnapshotRequest) ProtoMessage()
func (*RemoveSnapshotRequest) ProtoReflect ¶
func (x *RemoveSnapshotRequest) ProtoReflect() protoreflect.Message
func (*RemoveSnapshotRequest) Reset ¶
func (x *RemoveSnapshotRequest) Reset()
func (*RemoveSnapshotRequest) String ¶
func (x *RemoveSnapshotRequest) String() string
type RemoveSnapshotResponse ¶
type RemoveSnapshotResponse struct {
// contains filtered or unexported fields
}
func (*RemoveSnapshotResponse) Descriptor
deprecated
func (*RemoveSnapshotResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveSnapshotResponse.ProtoReflect.Descriptor instead.
func (*RemoveSnapshotResponse) ProtoMessage ¶
func (*RemoveSnapshotResponse) ProtoMessage()
func (*RemoveSnapshotResponse) ProtoReflect ¶
func (x *RemoveSnapshotResponse) ProtoReflect() protoreflect.Message
func (*RemoveSnapshotResponse) Reset ¶
func (x *RemoveSnapshotResponse) Reset()
func (*RemoveSnapshotResponse) String ¶
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"`
WhitelistedChains *string `protobuf:"bytes,3,opt,name=whitelisted_chains,json=whitelistedChains,proto3,oneof" json:"whitelisted_chains,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 `` /* 171-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 `` /* 177-byte string literal not displayed */
// Map of chain id to chain config file contents.
// If specified, will create a file "chainid.json" under chains config dir with
// the contents provided here.
ChainConfigFiles map[string]string `` /* 185-byte string literal not displayed */
// Plugin dir from which to load all custom VM executables.
PluginDir string `protobuf:"bytes,7,opt,name=plugin_dir,json=pluginDir,proto3" json:"plugin_dir,omitempty"`
// contains filtered or unexported fields
}
func (*RestartNodeRequest) Descriptor
deprecated
func (*RestartNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestartNodeRequest.ProtoReflect.Descriptor instead.
func (*RestartNodeRequest) GetChainConfigFiles ¶ added in v1.6.1
func (x *RestartNodeRequest) GetChainConfigFiles() map[string]string
func (*RestartNodeRequest) GetChainConfigs ¶
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) GetPluginDir ¶
func (x *RestartNodeRequest) GetPluginDir() string
func (*RestartNodeRequest) GetUpgradeConfigs ¶
func (x *RestartNodeRequest) GetUpgradeConfigs() map[string]string
func (*RestartNodeRequest) GetWhitelistedChains ¶ added in v1.6.1
func (x *RestartNodeRequest) GetWhitelistedChains() 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 ResumeNodeRequest ¶
type ResumeNodeRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*ResumeNodeRequest) Descriptor
deprecated
func (*ResumeNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResumeNodeRequest.ProtoReflect.Descriptor instead.
func (*ResumeNodeRequest) GetName ¶
func (x *ResumeNodeRequest) GetName() string
func (*ResumeNodeRequest) ProtoMessage ¶
func (*ResumeNodeRequest) ProtoMessage()
func (*ResumeNodeRequest) ProtoReflect ¶
func (x *ResumeNodeRequest) ProtoReflect() protoreflect.Message
func (*ResumeNodeRequest) Reset ¶
func (x *ResumeNodeRequest) Reset()
func (*ResumeNodeRequest) String ¶
func (x *ResumeNodeRequest) String() string
type ResumeNodeResponse ¶
type ResumeNodeResponse struct {
ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
// contains filtered or unexported fields
}
func (*ResumeNodeResponse) Descriptor
deprecated
func (*ResumeNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResumeNodeResponse.ProtoReflect.Descriptor instead.
func (*ResumeNodeResponse) GetClusterInfo ¶
func (x *ResumeNodeResponse) GetClusterInfo() *ClusterInfo
func (*ResumeNodeResponse) ProtoMessage ¶
func (*ResumeNodeResponse) ProtoMessage()
func (*ResumeNodeResponse) ProtoReflect ¶
func (x *ResumeNodeResponse) ProtoReflect() protoreflect.Message
func (*ResumeNodeResponse) Reset ¶
func (x *ResumeNodeResponse) Reset()
func (*ResumeNodeResponse) String ¶
func (x *ResumeNodeResponse) String() string
type SaveSnapshotRequest ¶
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
func (*SaveSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use SaveSnapshotRequest.ProtoReflect.Descriptor instead.
func (*SaveSnapshotRequest) GetSnapshotName ¶
func (x *SaveSnapshotRequest) GetSnapshotName() string
func (*SaveSnapshotRequest) ProtoMessage ¶
func (*SaveSnapshotRequest) ProtoMessage()
func (*SaveSnapshotRequest) ProtoReflect ¶
func (x *SaveSnapshotRequest) ProtoReflect() protoreflect.Message
func (*SaveSnapshotRequest) Reset ¶
func (x *SaveSnapshotRequest) Reset()
func (*SaveSnapshotRequest) String ¶
func (x *SaveSnapshotRequest) String() string
type SaveSnapshotResponse ¶
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
func (*SaveSnapshotResponse) Descriptor() ([]byte, []int)
Deprecated: Use SaveSnapshotResponse.ProtoReflect.Descriptor instead.
func (*SaveSnapshotResponse) GetSnapshotPath ¶
func (x *SaveSnapshotResponse) GetSnapshotPath() string
func (*SaveSnapshotResponse) ProtoMessage ¶
func (*SaveSnapshotResponse) ProtoMessage()
func (*SaveSnapshotResponse) ProtoReflect ¶
func (x *SaveSnapshotResponse) ProtoReflect() protoreflect.Message
func (*SaveSnapshotResponse) Reset ¶
func (x *SaveSnapshotResponse) Reset()
func (*SaveSnapshotResponse) String ¶
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"`
WhitelistedChains *string `protobuf:"bytes,3,opt,name=whitelisted_chains,json=whitelistedChains,proto3,oneof" json:"whitelisted_chains,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"`
// Plugin dir from which to load all custom VM executables.
PluginDir string `protobuf:"bytes,6,opt,name=plugin_dir,json=pluginDir,proto3" json:"plugin_dir,omitempty"`
// The list of:
// - custom chain's VM name
// - genesis file path
// - (optional) chain id to use.
// - chain config file path
// - network upgrade file path
//
// chain id must be always nil when using StartRequest, as the network is empty and has no preloaded
// chain ids available.
//
// The matching file with the name in "ids.ID" format must exist.
// e.g., ids.ToID(hashing.ComputeHash256("chainevm")).String()
// e.g., chain-cli create VMID chainevm
//
// If this field is set to none (by default), the node/network-runner
// does not install the custom chain and does not create the chain,
// 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 `` /* 188-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 `` /* 171-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 `` /* 178-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"`
// Map of chain id to chain config file contents.
// If specified, will create a file "chainid.json" under chains config dir with
// the contents provided here.
ChainConfigFiles map[string]string `` /* 186-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*StartRequest) Descriptor
deprecated
func (*StartRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
func (*StartRequest) GetBlockchainSpecs ¶
func (x *StartRequest) GetBlockchainSpecs() []*BlockchainSpec
func (*StartRequest) GetChainConfigFiles ¶ added in v1.6.1
func (x *StartRequest) GetChainConfigFiles() map[string]string
func (*StartRequest) GetChainConfigs ¶
func (x *StartRequest) GetChainConfigs() map[string]string
func (*StartRequest) GetCustomNodeConfigs ¶
func (x *StartRequest) GetCustomNodeConfigs() map[string]string
func (*StartRequest) GetDynamicPorts ¶
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 ¶
func (x *StartRequest) GetReassignPortsIfUsed() bool
func (*StartRequest) GetRootDataDir ¶
func (x *StartRequest) GetRootDataDir() string
func (*StartRequest) GetUpgradeConfigs ¶
func (x *StartRequest) GetUpgradeConfigs() map[string]string
func (*StartRequest) GetWhitelistedChains ¶ added in v1.6.1
func (x *StartRequest) GetWhitelistedChains() 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"`
ChainIds []string `protobuf:"bytes,2,rep,name=chain_ids,json=chainIds,proto3" json:"chain_ids,omitempty"`
// contains filtered or unexported fields
}
func (*StartResponse) Descriptor
deprecated
func (*StartResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.
func (*StartResponse) GetChainIds ¶
func (x *StartResponse) GetChainIds() []string
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 TransformElasticChainsRequest ¶ added in v1.6.1
type TransformElasticChainsRequest struct {
ElasticChainSpec []*ElasticChainSpec `protobuf:"bytes,1,rep,name=elastic_chain_spec,json=elasticChainSpec,proto3" json:"elastic_chain_spec,omitempty"`
// contains filtered or unexported fields
}
func (*TransformElasticChainsRequest) Descriptor
deprecated
added in
v1.6.1
func (*TransformElasticChainsRequest) Descriptor() ([]byte, []int)
Deprecated: Use TransformElasticChainsRequest.ProtoReflect.Descriptor instead.
func (*TransformElasticChainsRequest) GetElasticChainSpec ¶ added in v1.6.1
func (x *TransformElasticChainsRequest) GetElasticChainSpec() []*ElasticChainSpec
func (*TransformElasticChainsRequest) ProtoMessage ¶ added in v1.6.1
func (*TransformElasticChainsRequest) ProtoMessage()
func (*TransformElasticChainsRequest) ProtoReflect ¶ added in v1.6.1
func (x *TransformElasticChainsRequest) ProtoReflect() protoreflect.Message
func (*TransformElasticChainsRequest) Reset ¶ added in v1.6.1
func (x *TransformElasticChainsRequest) Reset()
func (*TransformElasticChainsRequest) String ¶ added in v1.6.1
func (x *TransformElasticChainsRequest) String() string
type TransformElasticChainsResponse ¶ added in v1.6.1
type TransformElasticChainsResponse struct {
ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
TxIds []string `protobuf:"bytes,2,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"`
AssetIds []string `protobuf:"bytes,3,rep,name=asset_ids,json=assetIds,proto3" json:"asset_ids,omitempty"`
// contains filtered or unexported fields
}
func (*TransformElasticChainsResponse) Descriptor
deprecated
added in
v1.6.1
func (*TransformElasticChainsResponse) Descriptor() ([]byte, []int)
Deprecated: Use TransformElasticChainsResponse.ProtoReflect.Descriptor instead.
func (*TransformElasticChainsResponse) GetAssetIds ¶ added in v1.6.1
func (x *TransformElasticChainsResponse) GetAssetIds() []string
func (*TransformElasticChainsResponse) GetClusterInfo ¶ added in v1.6.1
func (x *TransformElasticChainsResponse) GetClusterInfo() *ClusterInfo
func (*TransformElasticChainsResponse) GetTxIds ¶ added in v1.6.1
func (x *TransformElasticChainsResponse) GetTxIds() []string
func (*TransformElasticChainsResponse) ProtoMessage ¶ added in v1.6.1
func (*TransformElasticChainsResponse) ProtoMessage()
func (*TransformElasticChainsResponse) ProtoReflect ¶ added in v1.6.1
func (x *TransformElasticChainsResponse) ProtoReflect() protoreflect.Message
func (*TransformElasticChainsResponse) Reset ¶ added in v1.6.1
func (x *TransformElasticChainsResponse) Reset()
func (*TransformElasticChainsResponse) String ¶ added in v1.6.1
func (x *TransformElasticChainsResponse) 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.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedControlServiceServer) AddNode ¶
func (UnimplementedControlServiceServer) AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)
func (UnimplementedControlServiceServer) AddPermissionlessValidator ¶
func (UnimplementedControlServiceServer) AddPermissionlessValidator(context.Context, *AddPermissionlessValidatorRequest) (*AddPermissionlessValidatorResponse, error)
func (UnimplementedControlServiceServer) AttachPeer ¶
func (UnimplementedControlServiceServer) AttachPeer(context.Context, *AttachPeerRequest) (*AttachPeerResponse, error)
func (UnimplementedControlServiceServer) CreateBlockchains ¶
func (UnimplementedControlServiceServer) CreateBlockchains(context.Context, *CreateBlockchainsRequest) (*CreateBlockchainsResponse, error)
func (UnimplementedControlServiceServer) CreateChains ¶ added in v1.6.1
func (UnimplementedControlServiceServer) CreateChains(context.Context, *CreateChainsRequest) (*CreateChainsResponse, error)
func (UnimplementedControlServiceServer) GetSnapshotNames ¶
func (UnimplementedControlServiceServer) GetSnapshotNames(context.Context, *GetSnapshotNamesRequest) (*GetSnapshotNamesResponse, error)
func (UnimplementedControlServiceServer) Health ¶
func (UnimplementedControlServiceServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)
func (UnimplementedControlServiceServer) LoadSnapshot ¶
func (UnimplementedControlServiceServer) LoadSnapshot(context.Context, *LoadSnapshotRequest) (*LoadSnapshotResponse, error)
func (UnimplementedControlServiceServer) PauseNode ¶
func (UnimplementedControlServiceServer) PauseNode(context.Context, *PauseNodeRequest) (*PauseNodeResponse, error)
func (UnimplementedControlServiceServer) RPCVersion ¶
func (UnimplementedControlServiceServer) RPCVersion(context.Context, *RPCVersionRequest) (*RPCVersionResponse, error)
func (UnimplementedControlServiceServer) RemoveChainValidator ¶ added in v1.6.1
func (UnimplementedControlServiceServer) RemoveChainValidator(context.Context, *RemoveChainValidatorRequest) (*RemoveChainValidatorResponse, error)
func (UnimplementedControlServiceServer) RemoveNode ¶
func (UnimplementedControlServiceServer) RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
func (UnimplementedControlServiceServer) RemoveSnapshot ¶
func (UnimplementedControlServiceServer) RemoveSnapshot(context.Context, *RemoveSnapshotRequest) (*RemoveSnapshotResponse, error)
func (UnimplementedControlServiceServer) RestartNode ¶
func (UnimplementedControlServiceServer) RestartNode(context.Context, *RestartNodeRequest) (*RestartNodeResponse, error)
func (UnimplementedControlServiceServer) ResumeNode ¶
func (UnimplementedControlServiceServer) ResumeNode(context.Context, *ResumeNodeRequest) (*ResumeNodeResponse, error)
func (UnimplementedControlServiceServer) SaveSnapshot ¶
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, grpc.ServerStreamingServer[StreamStatusResponse]) error
func (UnimplementedControlServiceServer) TransformElasticChains ¶ added in v1.6.1
func (UnimplementedControlServiceServer) TransformElasticChains(context.Context, *TransformElasticChainsRequest) (*TransformElasticChainsResponse, error)
func (UnimplementedControlServiceServer) URIs ¶
func (UnimplementedControlServiceServer) URIs(context.Context, *URIsRequest) (*URIsResponse, error)
func (UnimplementedControlServiceServer) WaitForHealthy ¶
func (UnimplementedControlServiceServer) WaitForHealthy(context.Context, *WaitForHealthyRequest) (*WaitForHealthyResponse, error)
type UnimplementedPingServiceServer ¶
type UnimplementedPingServiceServer struct{}
UnimplementedPingServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
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.
type WaitForHealthyRequest ¶
type WaitForHealthyRequest struct {
// contains filtered or unexported fields
}
func (*WaitForHealthyRequest) Descriptor
deprecated
func (*WaitForHealthyRequest) Descriptor() ([]byte, []int)
Deprecated: Use WaitForHealthyRequest.ProtoReflect.Descriptor instead.
func (*WaitForHealthyRequest) ProtoMessage ¶
func (*WaitForHealthyRequest) ProtoMessage()
func (*WaitForHealthyRequest) ProtoReflect ¶
func (x *WaitForHealthyRequest) ProtoReflect() protoreflect.Message
func (*WaitForHealthyRequest) Reset ¶
func (x *WaitForHealthyRequest) Reset()
func (*WaitForHealthyRequest) String ¶
func (x *WaitForHealthyRequest) String() string
type WaitForHealthyResponse ¶
type WaitForHealthyResponse struct {
ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
// contains filtered or unexported fields
}
func (*WaitForHealthyResponse) Descriptor
deprecated
func (*WaitForHealthyResponse) Descriptor() ([]byte, []int)
Deprecated: Use WaitForHealthyResponse.ProtoReflect.Descriptor instead.
func (*WaitForHealthyResponse) GetClusterInfo ¶
func (x *WaitForHealthyResponse) GetClusterInfo() *ClusterInfo
func (*WaitForHealthyResponse) ProtoMessage ¶
func (*WaitForHealthyResponse) ProtoMessage()
func (*WaitForHealthyResponse) ProtoReflect ¶
func (x *WaitForHealthyResponse) ProtoReflect() protoreflect.Message
func (*WaitForHealthyResponse) Reset ¶
func (x *WaitForHealthyResponse) Reset()
func (*WaitForHealthyResponse) String ¶
func (x *WaitForHealthyResponse) String() string