Documentation
¶
Index ¶
- func IsConnError(err error) bool
- type RPCClient
- func (this *RPCClient) Close()
- func (this *RPCClient) ClusterContext(clusterId string, clusterSecret string) context.Context
- func (this *RPCClient) Context() context.Context
- func (this *RPCClient) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error
- func (this *RPCClient) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
- func (this *RPCClient) UpdateConfig(config *configs.APIConfig) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type RPCClient ¶
type RPCClient struct {
NodeRPC pb.NodeServiceClient
NodeLogRPC pb.NodeLogServiceClient
NodeTaskRPC pb.NodeTaskServiceClient
NodeValueRPC pb.NodeValueServiceClient
HTTPAccessLogRPC pb.HTTPAccessLogServiceClient
HTTPCacheTaskKeyRPC pb.HTTPCacheTaskKeyServiceClient
APINodeRPC pb.APINodeServiceClient
IPLibraryArtifactRPC pb.IPLibraryArtifactServiceClient
IPListRPC pb.IPListServiceClient
IPItemRPC pb.IPItemServiceClient
FileRPC pb.FileServiceClient
FileChunkRPC pb.FileChunkServiceClient
ACMEAuthenticationRPC pb.ACMEAuthenticationServiceClient
ServerRPC pb.ServerServiceClient
ServerDailyStatRPC pb.ServerDailyStatServiceClient
ServerBandwidthStatRPC pb.ServerBandwidthStatServiceClient
MetricStatRPC pb.MetricStatServiceClient
FirewallRPC pb.FirewallServiceClient
SSLCertRPC pb.SSLCertServiceClient
ScriptRPC pb.ScriptServiceClient
// contains filtered or unexported fields
}
func (*RPCClient) ClusterContext ¶
ClusterContext 集群上下文
func (*RPCClient) NewStream ¶ added in v0.5.2
func (this *RPCClient) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
Source Files
Click to show internal directories.
Click to hide internal directories.