rpcpb

package
v1.0.15 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 11, 2022 License: BSD-3-Clause Imports: 16 Imported by: 9

Documentation

Overview

Package rpcpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var ControlService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpcpb.ControlService",
	HandlerType: (*ControlServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _ControlService_Start_Handler,
		},
		{
			MethodName: "Health",
			Handler:    _ControlService_Health_Handler,
		},
		{
			MethodName: "URIs",
			Handler:    _ControlService_URIs_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _ControlService_Status_Handler,
		},
		{
			MethodName: "RemoveNode",
			Handler:    _ControlService_RemoveNode_Handler,
		},
		{
			MethodName: "AddNode",
			Handler:    _ControlService_AddNode_Handler,
		},
		{
			MethodName: "RestartNode",
			Handler:    _ControlService_RestartNode_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _ControlService_Stop_Handler,
		},
		{
			MethodName: "AttachPeer",
			Handler:    _ControlService_AttachPeer_Handler,
		},
		{
			MethodName: "SendOutboundMessage",
			Handler:    _ControlService_SendOutboundMessage_Handler,
		},
	},
	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)

View Source 
var File_rpcpb_rpc_proto protoreflect.FileDescriptor
View Source 
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.

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.

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.

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.

func RegisterPingServiceServer 

func RegisterPingServiceServer(s grpc.ServiceRegistrar, srv PingServiceServer)

Types

type AddNodeRequest added in v1.0.13 

type AddNodeRequest struct {
	Name         string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	StartRequest *StartRequest `protobuf:"bytes,2,opt,name=start_request,json=startRequest,proto3" json:"start_request,omitempty"`
	// contains filtered or unexported fields
}

func (*AddNodeRequest) Descriptor deprecated added in v1.0.13 

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

Deprecated: Use AddNodeRequest.ProtoReflect.Descriptor instead.

func (*AddNodeRequest) GetName added in v1.0.13 

func (x *AddNodeRequest) GetName() string

func (*AddNodeRequest) GetStartRequest added in v1.0.13 

func (x *AddNodeRequest) GetStartRequest() *StartRequest

func (*AddNodeRequest) ProtoMessage added in v1.0.13 

func (*AddNodeRequest) ProtoMessage()

func (*AddNodeRequest) ProtoReflect added in v1.0.13 

func (x *AddNodeRequest) ProtoReflect() protoreflect.Message

func (*AddNodeRequest) Reset added in v1.0.13 

func (x *AddNodeRequest) Reset()

func (*AddNodeRequest) String added in v1.0.13 

func (x *AddNodeRequest) String() string

type AddNodeResponse added in v1.0.13 

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 added in v1.0.13 

func (*AddNodeResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddNodeResponse.ProtoReflect.Descriptor instead.

func (*AddNodeResponse) GetClusterInfo added in v1.0.13 

func (x *AddNodeResponse) GetClusterInfo() *ClusterInfo

func (*AddNodeResponse) ProtoMessage added in v1.0.13 

func (*AddNodeResponse) ProtoMessage()

func (*AddNodeResponse) ProtoReflect added in v1.0.13 

func (x *AddNodeResponse) ProtoReflect() protoreflect.Message

func (*AddNodeResponse) Reset added in v1.0.13 

func (x *AddNodeResponse) Reset()

func (*AddNodeResponse) String added in v1.0.13 

func (x *AddNodeResponse) String() string

type AttachPeerRequest added in v1.0.10 

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 added in v1.0.10 

func (*AttachPeerRequest) Descriptor() ([]byte, []int)

Deprecated: Use AttachPeerRequest.ProtoReflect.Descriptor instead.

func (*AttachPeerRequest) GetNodeName added in v1.0.10 

func (x *AttachPeerRequest) GetNodeName() string

func (*AttachPeerRequest) ProtoMessage added in v1.0.10 

func (*AttachPeerRequest) ProtoMessage()

func (*AttachPeerRequest) ProtoReflect added in v1.0.10 

func (x *AttachPeerRequest) ProtoReflect() protoreflect.Message

func (*AttachPeerRequest) Reset added in v1.0.10 

func (x *AttachPeerRequest) Reset()

func (*AttachPeerRequest) String added in v1.0.10 

func (x *AttachPeerRequest) String() string

type AttachPeerResponse added in v1.0.10 

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 added in v1.0.10 

func (*AttachPeerResponse) Descriptor() ([]byte, []int)

Deprecated: Use AttachPeerResponse.ProtoReflect.Descriptor instead.

func (*AttachPeerResponse) GetAttachedPeerInfo added in v1.0.10 

func (x *AttachPeerResponse) GetAttachedPeerInfo() *AttachedPeerInfo

func (*AttachPeerResponse) GetClusterInfo added in v1.0.10 

func (x *AttachPeerResponse) GetClusterInfo() *ClusterInfo

func (*AttachPeerResponse) ProtoMessage added in v1.0.10 

func (*AttachPeerResponse) ProtoMessage()

func (*AttachPeerResponse) ProtoReflect added in v1.0.10 

func (x *AttachPeerResponse) ProtoReflect() protoreflect.Message

func (*AttachPeerResponse) Reset added in v1.0.10 

func (x *AttachPeerResponse) Reset()

func (*AttachPeerResponse) String added in v1.0.10 

func (x *AttachPeerResponse) String() string

type AttachedPeerInfo added in v1.0.10 

type AttachedPeerInfo struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachedPeerInfo) Descriptor deprecated added in v1.0.10 

func (*AttachedPeerInfo) Descriptor() ([]byte, []int)

Deprecated: Use AttachedPeerInfo.ProtoReflect.Descriptor instead.

func (*AttachedPeerInfo) GetId added in v1.0.10 

func (x *AttachedPeerInfo) GetId() string

func (*AttachedPeerInfo) ProtoMessage added in v1.0.10 

func (*AttachedPeerInfo) ProtoMessage()

func (*AttachedPeerInfo) ProtoReflect added in v1.0.10 

func (x *AttachedPeerInfo) ProtoReflect() protoreflect.Message

func (*AttachedPeerInfo) Reset added in v1.0.10 

func (x *AttachedPeerInfo) Reset()

func (*AttachedPeerInfo) String added in v1.0.10 

func (x *AttachedPeerInfo) String() string

type ClusterInfo 

type ClusterInfo struct {
	NodeNames   []string             `protobuf:"bytes,1,rep,name=node_names,json=nodeNames,proto3" json:"node_names,omitempty"`
	NodeInfos   map[string]*NodeInfo `` /* 176-byte string literal not displayed */
	Pid         int32                `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"`
	RootDataDir string               `protobuf:"bytes,4,opt,name=root_data_dir,json=rootDataDir,proto3" json:"root_data_dir,omitempty"`
	Healthy     bool                 `protobuf:"varint,5,opt,name=healthy,proto3" json:"healthy,omitempty"`
	// Maps from the node ID to its attached peer infos.
	AttachedPeerInfos map[string]*ListOfAttachedPeerInfo `` /* 202-byte string literal not displayed */
	// Set to "true" once custom VMs are ready.
	CustomVmsHealthy bool `protobuf:"varint,7,opt,name=custom_vms_healthy,json=customVmsHealthy,proto3" json:"custom_vms_healthy,omitempty"`
	// The map of custom VM IDs in "ids.ID" format to its VM information.
	CustomVms map[string]*CustomVmInfo `` /* 176-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 added in v1.0.10 

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

func (*ClusterInfo) GetCustomVms added in v1.0.11 

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

func (*ClusterInfo) GetCustomVmsHealthy added in v1.0.11 

func (x *ClusterInfo) GetCustomVmsHealthy() 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 {
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
	URIs(ctx context.Context, in *URIsRequest, opts ...grpc.CallOption) (*URIsResponse, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	StreamStatus(ctx context.Context, in *StreamStatusRequest, opts ...grpc.CallOption) (ControlService_StreamStatusClient, error)
	RemoveNode(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error)
	AddNode(ctx context.Context, in *AddNodeRequest, opts ...grpc.CallOption) (*AddNodeResponse, error)
	RestartNode(ctx context.Context, in *RestartNodeRequest, opts ...grpc.CallOption) (*RestartNodeResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
	AttachPeer(ctx context.Context, in *AttachPeerRequest, opts ...grpc.CallOption) (*AttachPeerResponse, error)
	SendOutboundMessage(ctx context.Context, in *SendOutboundMessageRequest, opts ...grpc.CallOption) (*SendOutboundMessageResponse, error)
}

ControlServiceClient is the client API for ControlService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewControlServiceClient 

func NewControlServiceClient(cc grpc.ClientConnInterface) ControlServiceClient

type ControlServiceServer 

type ControlServiceServer interface {
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	URIs(context.Context, *URIsRequest) (*URIsResponse, error)
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	StreamStatus(*StreamStatusRequest, ControlService_StreamStatusServer) error
	RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
	AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)
	RestartNode(context.Context, *RestartNodeRequest) (*RestartNodeResponse, error)
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	AttachPeer(context.Context, *AttachPeerRequest) (*AttachPeerResponse, error)
	SendOutboundMessage(context.Context, *SendOutboundMessageRequest) (*SendOutboundMessageResponse, error)
	// contains filtered or unexported methods
}

ControlServiceServer is the server API for ControlService service. All implementations must embed UnimplementedControlServiceServer for forward compatibility

type ControlService_StreamStatusClient 

type ControlService_StreamStatusClient interface {
	Recv() (*StreamStatusResponse, error)
	grpc.ClientStream
}

type ControlService_StreamStatusServer 

type ControlService_StreamStatusServer interface {
	Send(*StreamStatusResponse) error
	grpc.ServerStream
}

type CustomVmInfo added in v1.0.11 

type CustomVmInfo struct {
	VmName string `protobuf:"bytes,1,opt,name=vm_name,json=vmName,proto3" json:"vm_name,omitempty"`
	// VM ID in "ids.ID" format.
	VmId string `protobuf:"bytes,2,opt,name=vm_id,json=vmId,proto3" json:"vm_id,omitempty"`
	// Create subnet transaction ID -- subnet ID.
	// The subnet ID must be whitelisted by the avalanche node.
	SubnetId string `protobuf:"bytes,3,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"`
	// Create blockchain transaction ID -- blockchain ID>
	// The blockchain ID is used for RPC endpoints for the custom VM.
	BlockchainId string `protobuf:"bytes,4,opt,name=blockchain_id,json=blockchainId,proto3" json:"blockchain_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CustomVmInfo) Descriptor deprecated added in v1.0.11 

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

Deprecated: Use CustomVmInfo.ProtoReflect.Descriptor instead.

func (*CustomVmInfo) GetBlockchainId added in v1.0.11 

func (x *CustomVmInfo) GetBlockchainId() string

func (*CustomVmInfo) GetSubnetId added in v1.0.11 

func (x *CustomVmInfo) GetSubnetId() string

func (*CustomVmInfo) GetVmId added in v1.0.11 

func (x *CustomVmInfo) GetVmId() string

func (*CustomVmInfo) GetVmName added in v1.0.11 

func (x *CustomVmInfo) GetVmName() string

func (*CustomVmInfo) ProtoMessage added in v1.0.11 

func (*CustomVmInfo) ProtoMessage()

func (*CustomVmInfo) ProtoReflect added in v1.0.11 

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

func (*CustomVmInfo) Reset added in v1.0.11 

func (x *CustomVmInfo) Reset()

func (*CustomVmInfo) String added in v1.0.11 

func (x *CustomVmInfo) 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 added in v1.0.10 

type ListOfAttachedPeerInfo struct {
	Peers []*AttachedPeerInfo `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOfAttachedPeerInfo) Descriptor deprecated added in v1.0.10 

func (*ListOfAttachedPeerInfo) Descriptor() ([]byte, []int)

Deprecated: Use ListOfAttachedPeerInfo.ProtoReflect.Descriptor instead.

func (*ListOfAttachedPeerInfo) GetPeers added in v1.0.10 

func (x *ListOfAttachedPeerInfo) GetPeers() []*AttachedPeerInfo

func (*ListOfAttachedPeerInfo) ProtoMessage added in v1.0.10 

func (*ListOfAttachedPeerInfo) ProtoMessage()

func (*ListOfAttachedPeerInfo) ProtoReflect added in v1.0.10 

func (x *ListOfAttachedPeerInfo) ProtoReflect() protoreflect.Message

func (*ListOfAttachedPeerInfo) Reset added in v1.0.10 

func (x *ListOfAttachedPeerInfo) Reset()

func (*ListOfAttachedPeerInfo) String added in v1.0.10 

func (x *ListOfAttachedPeerInfo) String() string

type NodeInfo 

type NodeInfo struct {
	Name               string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ExecPath           string `protobuf:"bytes,2,opt,name=exec_path,json=execPath,proto3" json:"exec_path,omitempty"`
	Uri                string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	Id                 string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	LogDir             string `protobuf:"bytes,5,opt,name=log_dir,json=logDir,proto3" json:"log_dir,omitempty"`
	DbDir              string `protobuf:"bytes,6,opt,name=db_dir,json=dbDir,proto3" json:"db_dir,omitempty"`
	PluginDir          string `protobuf:"bytes,7,opt,name=plugin_dir,json=pluginDir,proto3" json:"plugin_dir,omitempty"`
	WhitelistedSubnets string `protobuf:"bytes,8,opt,name=whitelisted_subnets,json=whitelistedSubnets,proto3" json:"whitelisted_subnets,omitempty"`
	Config             []byte `protobuf:"bytes,9,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

func (*NodeInfo) Descriptor() ([]byte, []int)

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetConfig 

func (x *NodeInfo) GetConfig() []byte

func (*NodeInfo) GetDbDir 

func (x *NodeInfo) GetDbDir() string

func (*NodeInfo) GetExecPath 

func (x *NodeInfo) GetExecPath() string

func (*NodeInfo) GetId 

func (x *NodeInfo) GetId() string

func (*NodeInfo) GetLogDir 

func (x *NodeInfo) GetLogDir() string

func (*NodeInfo) GetName 

func (x *NodeInfo) GetName() string

func (*NodeInfo) GetPluginDir added in v1.0.11 

func (x *NodeInfo) GetPluginDir() string

func (*NodeInfo) GetUri 

func (x *NodeInfo) GetUri() string

func (*NodeInfo) GetWhitelistedSubnets 

func (x *NodeInfo) GetWhitelistedSubnets() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

func (x *NodeInfo) ProtoReflect() protoreflect.Message

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

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

type RestartNodeRequest struct {

	// Must be a valid node name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional fields are set to the previous values if empty.
	ExecPath           *string `protobuf:"bytes,2,opt,name=exec_path,json=execPath,proto3,oneof" json:"exec_path,omitempty"`
	WhitelistedSubnets *string `protobuf:"bytes,3,opt,name=whitelisted_subnets,json=whitelistedSubnets,proto3,oneof" json:"whitelisted_subnets,omitempty"`
	LogLevel           *string `protobuf:"bytes,4,opt,name=log_level,json=logLevel,proto3,oneof" json:"log_level,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"`
	// contains filtered or unexported fields
}

func (*RestartNodeRequest) Descriptor deprecated 

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

Deprecated: Use RestartNodeRequest.ProtoReflect.Descriptor instead.

func (*RestartNodeRequest) GetExecPath added in v1.0.11 

func (x *RestartNodeRequest) GetExecPath() string

func (*RestartNodeRequest) GetLogLevel added in v1.0.11 

func (x *RestartNodeRequest) GetLogLevel() string

func (*RestartNodeRequest) GetName 

func (x *RestartNodeRequest) GetName() string

func (*RestartNodeRequest) GetRootDataDir added in v1.0.11 

func (x *RestartNodeRequest) GetRootDataDir() string

func (*RestartNodeRequest) GetWhitelistedSubnets added in v1.0.11 

func (x *RestartNodeRequest) GetWhitelistedSubnets() string

func (*RestartNodeRequest) ProtoMessage 

func (*RestartNodeRequest) ProtoMessage()

func (*RestartNodeRequest) ProtoReflect 

func (x *RestartNodeRequest) ProtoReflect() protoreflect.Message

func (*RestartNodeRequest) Reset 

func (x *RestartNodeRequest) Reset()

func (*RestartNodeRequest) String 

func (x *RestartNodeRequest) String() string

type RestartNodeResponse 

type RestartNodeResponse struct {
	ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartNodeResponse) Descriptor deprecated 

func (*RestartNodeResponse) Descriptor() ([]byte, []int)

Deprecated: Use RestartNodeResponse.ProtoReflect.Descriptor instead.

func (*RestartNodeResponse) GetClusterInfo 

func (x *RestartNodeResponse) GetClusterInfo() *ClusterInfo

func (*RestartNodeResponse) ProtoMessage 

func (*RestartNodeResponse) ProtoMessage()

func (*RestartNodeResponse) ProtoReflect 

func (x *RestartNodeResponse) ProtoReflect() protoreflect.Message

func (*RestartNodeResponse) Reset 

func (x *RestartNodeResponse) Reset()

func (*RestartNodeResponse) String 

func (x *RestartNodeResponse) String() string

type SendOutboundMessageRequest added in v1.0.10 

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 added in v1.0.10 

func (*SendOutboundMessageRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendOutboundMessageRequest.ProtoReflect.Descriptor instead.

func (*SendOutboundMessageRequest) GetBytes added in v1.0.10 

func (x *SendOutboundMessageRequest) GetBytes() []byte

func (*SendOutboundMessageRequest) GetNodeName added in v1.0.10 

func (x *SendOutboundMessageRequest) GetNodeName() string

func (*SendOutboundMessageRequest) GetOp added in v1.0.10 

func (x *SendOutboundMessageRequest) GetOp() uint32

func (*SendOutboundMessageRequest) GetPeerId added in v1.0.10 

func (x *SendOutboundMessageRequest) GetPeerId() string

func (*SendOutboundMessageRequest) ProtoMessage added in v1.0.10 

func (*SendOutboundMessageRequest) ProtoMessage()

func (*SendOutboundMessageRequest) ProtoReflect added in v1.0.10 

func (x *SendOutboundMessageRequest) ProtoReflect() protoreflect.Message

func (*SendOutboundMessageRequest) Reset added in v1.0.10 

func (x *SendOutboundMessageRequest) Reset()

func (*SendOutboundMessageRequest) String added in v1.0.10 

func (x *SendOutboundMessageRequest) String() string

type SendOutboundMessageResponse added in v1.0.10 

type SendOutboundMessageResponse struct {
	Sent bool `protobuf:"varint,1,opt,name=sent,proto3" json:"sent,omitempty"`
	// contains filtered or unexported fields
}

func (*SendOutboundMessageResponse) Descriptor deprecated added in v1.0.10 

func (*SendOutboundMessageResponse) Descriptor() ([]byte, []int)

Deprecated: Use SendOutboundMessageResponse.ProtoReflect.Descriptor instead.

func (*SendOutboundMessageResponse) GetSent added in v1.0.10 

func (x *SendOutboundMessageResponse) GetSent() bool

func (*SendOutboundMessageResponse) ProtoMessage added in v1.0.10 

func (*SendOutboundMessageResponse) ProtoMessage()

func (*SendOutboundMessageResponse) ProtoReflect added in v1.0.10 

func (x *SendOutboundMessageResponse) ProtoReflect() protoreflect.Message

func (*SendOutboundMessageResponse) Reset added in v1.0.10 

func (x *SendOutboundMessageResponse) Reset()

func (*SendOutboundMessageResponse) String added in v1.0.10 

func (x *SendOutboundMessageResponse) String() string

type StartRequest 

type StartRequest struct {
	ExecPath           string  `protobuf:"bytes,1,opt,name=exec_path,json=execPath,proto3" json:"exec_path,omitempty"`
	NumNodes           *uint32 `protobuf:"varint,2,opt,name=num_nodes,json=numNodes,proto3,oneof" json:"num_nodes,omitempty"`
	WhitelistedSubnets *string `protobuf:"bytes,3,opt,name=whitelisted_subnets,json=whitelistedSubnets,proto3,oneof" json:"whitelisted_subnets,omitempty"`
	LogLevel           *string `protobuf:"bytes,4,opt,name=log_level,json=logLevel,proto3,oneof" json:"log_level,omitempty"`
	GlobalNodeConfig   *string `protobuf:"bytes,5,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,6,opt,name=root_data_dir,json=rootDataDir,proto3,oneof" json:"root_data_dir,omitempty"`
	// Plugin directory to load all custom VM executables.
	// Must be non-empty to install custom VMs.
	PluginDir *string `protobuf:"bytes,7,opt,name=plugin_dir,json=pluginDir,proto3,oneof" json:"plugin_dir,omitempty"`
	// The map of custom VM name to its genesis file path.
	//
	// The matching file with the name in "ids.ID" format must exist.
	// e.g., ids.ToID(hashing.ComputeHash256("subnetevm")).String()
	// e.g., subnet-cli create VMID subnetevm
	//
	// If this field is set to none (by default), the node/network-runner
	// does not install the custom VM and does not create the subnet,
	// even if the VM binary exists on the local plugins directory.
	CustomVms         map[string]string `` /* 176-byte string literal not displayed */
	CustomNodeConfigs map[string]string `` /* 202-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) GetCustomNodeConfigs added in v1.0.13 

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

func (*StartRequest) GetCustomVms added in v1.0.11 

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

func (*StartRequest) GetExecPath 

func (x *StartRequest) GetExecPath() string

func (*StartRequest) GetGlobalNodeConfig added in v1.0.13 

func (x *StartRequest) GetGlobalNodeConfig() string

func (*StartRequest) GetLogLevel 

func (x *StartRequest) GetLogLevel() string

func (*StartRequest) GetNumNodes added in v1.0.9 

func (x *StartRequest) GetNumNodes() uint32

func (*StartRequest) GetPluginDir added in v1.0.11 

func (x *StartRequest) GetPluginDir() string

func (*StartRequest) GetRootDataDir added in v1.0.9 

func (x *StartRequest) GetRootDataDir() string

func (*StartRequest) GetWhitelistedSubnets 

func (x *StartRequest) GetWhitelistedSubnets() string

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect 

func (x *StartRequest) ProtoReflect() protoreflect.Message

func (*StartRequest) Reset 

func (x *StartRequest) Reset()

func (*StartRequest) String 

func (x *StartRequest) String() string

type StartResponse 

type StartResponse struct {
	ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
	// contains filtered or unexported fields
}

func (*StartResponse) Descriptor deprecated 

func (*StartResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.

func (*StartResponse) GetClusterInfo 

func (x *StartResponse) GetClusterInfo() *ClusterInfo

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) ProtoReflect 

func (x *StartResponse) ProtoReflect() protoreflect.Message

func (*StartResponse) Reset 

func (x *StartResponse) Reset()

func (*StartResponse) String 

func (x *StartResponse) String() string

type StatusRequest 

type StatusRequest struct {
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor deprecated 

func (*StatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

func (x *StatusRequest) ProtoReflect() protoreflect.Message

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

func (*StatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetClusterInfo 

func (x *StatusResponse) GetClusterInfo() *ClusterInfo

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

func (x *StatusResponse) ProtoReflect() protoreflect.Message

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StopRequest 

type StopRequest struct {
	// contains filtered or unexported fields
}

func (*StopRequest) Descriptor deprecated 

func (*StopRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect 

func (x *StopRequest) ProtoReflect() protoreflect.Message

func (*StopRequest) Reset 

func (x *StopRequest) Reset()

func (*StopRequest) String 

func (x *StopRequest) String() string

type StopResponse 

type StopResponse struct {
	ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
	// contains filtered or unexported fields
}

func (*StopResponse) Descriptor deprecated 

func (*StopResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) GetClusterInfo 

func (x *StopResponse) GetClusterInfo() *ClusterInfo

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) ProtoReflect 

func (x *StopResponse) ProtoReflect() protoreflect.Message

func (*StopResponse) Reset 

func (x *StopResponse) Reset()

func (*StopResponse) String 

func (x *StopResponse) String() string

type StreamStatusRequest 

type StreamStatusRequest struct {
	PushInterval int64 `protobuf:"varint,1,opt,name=push_interval,json=pushInterval,proto3" json:"push_interval,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamStatusRequest) Descriptor deprecated 

func (*StreamStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamStatusRequest.ProtoReflect.Descriptor instead.

func (*StreamStatusRequest) GetPushInterval 

func (x *StreamStatusRequest) GetPushInterval() int64

func (*StreamStatusRequest) ProtoMessage 

func (*StreamStatusRequest) ProtoMessage()

func (*StreamStatusRequest) ProtoReflect 

func (x *StreamStatusRequest) ProtoReflect() protoreflect.Message

func (*StreamStatusRequest) Reset 

func (x *StreamStatusRequest) Reset()

func (*StreamStatusRequest) String 

func (x *StreamStatusRequest) String() string

type StreamStatusResponse 

type StreamStatusResponse struct {
	ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamStatusResponse) Descriptor deprecated 

func (*StreamStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamStatusResponse.ProtoReflect.Descriptor instead.

func (*StreamStatusResponse) GetClusterInfo 

func (x *StreamStatusResponse) GetClusterInfo() *ClusterInfo

func (*StreamStatusResponse) ProtoMessage 

func (*StreamStatusResponse) ProtoMessage()

func (*StreamStatusResponse) ProtoReflect 

func (x *StreamStatusResponse) ProtoReflect() protoreflect.Message

func (*StreamStatusResponse) Reset 

func (x *StreamStatusResponse) Reset()

func (*StreamStatusResponse) String 

func (x *StreamStatusResponse) String() string

type URIsRequest 

type URIsRequest struct {
	// contains filtered or unexported fields
}

func (*URIsRequest) Descriptor deprecated 

func (*URIsRequest) Descriptor() ([]byte, []int)

Deprecated: Use URIsRequest.ProtoReflect.Descriptor instead.

func (*URIsRequest) ProtoMessage 

func (*URIsRequest) ProtoMessage()

func (*URIsRequest) ProtoReflect 

func (x *URIsRequest) ProtoReflect() protoreflect.Message

func (*URIsRequest) Reset 

func (x *URIsRequest) Reset()

func (*URIsRequest) String 

func (x *URIsRequest) String() string

type URIsResponse 

type URIsResponse struct {
	Uris []string `protobuf:"bytes,1,rep,name=uris,proto3" json:"uris,omitempty"`
	// contains filtered or unexported fields
}

func (*URIsResponse) Descriptor deprecated 

func (*URIsResponse) Descriptor() ([]byte, []int)

Deprecated: Use URIsResponse.ProtoReflect.Descriptor instead.

func (*URIsResponse) GetUris 

func (x *URIsResponse) GetUris() []string

func (*URIsResponse) ProtoMessage 

func (*URIsResponse) ProtoMessage()

func (*URIsResponse) ProtoReflect 

func (x *URIsResponse) ProtoReflect() protoreflect.Message

func (*URIsResponse) Reset 

func (x *URIsResponse) Reset()

func (*URIsResponse) String 

func (x *URIsResponse) String() string

type UnimplementedControlServiceServer 

type UnimplementedControlServiceServer struct {
}

UnimplementedControlServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedControlServiceServer) AddNode added in v1.0.13 

func (UnimplementedControlServiceServer) AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)

func (UnimplementedControlServiceServer) AttachPeer added in v1.0.10 

func (UnimplementedControlServiceServer) AttachPeer(context.Context, *AttachPeerRequest) (*AttachPeerResponse, error)

func (UnimplementedControlServiceServer) Health 

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

func (UnimplementedControlServiceServer) RemoveNode 

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

func (UnimplementedControlServiceServer) RestartNode 

func (UnimplementedControlServiceServer) RestartNode(context.Context, *RestartNodeRequest) (*RestartNodeResponse, error)

func (UnimplementedControlServiceServer) SendOutboundMessage added in v1.0.10 

func (UnimplementedControlServiceServer) SendOutboundMessage(context.Context, *SendOutboundMessageRequest) (*SendOutboundMessageResponse, error)

func (UnimplementedControlServiceServer) Start 

func (UnimplementedControlServiceServer) Start(context.Context, *StartRequest) (*StartResponse, error)

func (UnimplementedControlServiceServer) Status 

func (UnimplementedControlServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

func (UnimplementedControlServiceServer) Stop 

func (UnimplementedControlServiceServer) Stop(context.Context, *StopRequest) (*StopResponse, error)

func (UnimplementedControlServiceServer) StreamStatus 

func (UnimplementedControlServiceServer) StreamStatus(*StreamStatusRequest, ControlService_StreamStatusServer) error

func (UnimplementedControlServiceServer) URIs 

func (UnimplementedControlServiceServer) URIs(context.Context, *URIsRequest) (*URIsResponse, error)

type UnimplementedPingServiceServer 

type UnimplementedPingServiceServer struct {
}

UnimplementedPingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPingServiceServer) Ping 

func (UnimplementedPingServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

type UnsafeControlServiceServer 

type UnsafeControlServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeControlServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServiceServer will result in compilation errors.

type UnsafePingServiceServer 

type UnsafePingServiceServer interface {
	// contains filtered or unexported methods
}

UnsafePingServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PingServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.