rpc

Documentation

Index

• func IsConnError(err error) bool
• type RPCClient
  • func NewRPCClient(apiConfig *configs.APIConfig) (*RPCClient, error)
  • func SharedRPC() (*RPCClient, error)
  • func (this *RPCClient) ACMEAuthenticationRPC() pb.ACMEAuthenticationServiceClient
  • func (this *RPCClient) APINodeRPC() pb.APINodeServiceClient
  • func (this *RPCClient) Close()
  • func (this *RPCClient) ClusterContext(clusterId string, clusterSecret string) context.Context
  • func (this *RPCClient) Context() context.Context
  • func (this *RPCClient) FileChunkRPC() pb.FileChunkServiceClient
  • func (this *RPCClient) FileRPC() pb.FileServiceClient
  • func (this *RPCClient) FirewallRPC() pb.FirewallServiceClient
  • func (this *RPCClient) HTTPAccessLogRPC() pb.HTTPAccessLogServiceClient
  • func (this *RPCClient) HTTPCacheTaskKeyRPC() pb.HTTPCacheTaskKeyServiceClient
  • func (this *RPCClient) IPItemRPC() pb.IPItemServiceClient
  • func (this *RPCClient) IPLibraryRPC() pb.IPLibraryServiceClient
  • func (this *RPCClient) IPListRPC() pb.IPListServiceClient
  • func (this *RPCClient) MetricStatRPC() pb.MetricStatServiceClient
  • func (this *RPCClient) NodeLogRPC() pb.NodeLogServiceClient
  • func (this *RPCClient) NodeRPC() pb.NodeServiceClient
  • func (this *RPCClient) NodeTaskRPC() pb.NodeTaskServiceClient
  • func (this *RPCClient) NodeValueRPC() pb.NodeValueServiceClient
  • func (this *RPCClient) RegionCityRPC() pb.RegionCityServiceClient
  • func (this *RPCClient) RegionCountryRPC() pb.RegionCountryServiceClient
  • func (this *RPCClient) RegionProviderRPC() pb.RegionProviderServiceClient
  • func (this *RPCClient) RegionProvinceRPC() pb.RegionProvinceServiceClient
  • func (this *RPCClient) SSLCertRPC() pb.SSLCertServiceClient
  • func (this *RPCClient) ServerBandwidthStatRPC() pb.ServerBandwidthStatServiceClient
  • func (this *RPCClient) ServerDailyStatRPC() pb.ServerDailyStatServiceClient
  • func (this *RPCClient) ServerRPC() pb.ServerServiceClient
  • func (this *RPCClient) UpdateConfig(config *configs.APIConfig) error

Functions

func IsConnError

func IsConnError(err error) bool

IsConnError 是否为连接错误

Types

type RPCClient

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

func NewRPCClient

func NewRPCClient(apiConfig *configs.APIConfig) (*RPCClient, error)

func SharedRPC

func SharedRPC() (*RPCClient, error)

SharedRPC RPC对象

func (*RPCClient) ACMEAuthenticationRPC

func (this *RPCClient) ACMEAuthenticationRPC() pb.ACMEAuthenticationServiceClient

func (*RPCClient) APINodeRPC

func (this *RPCClient) APINodeRPC() pb.APINodeServiceClient

func (*RPCClient) Close

func (this *RPCClient) Close()

Close 关闭连接

func (*RPCClient) ClusterContext

func (this *RPCClient) ClusterContext(clusterId string, clusterSecret string) context.Context

ClusterContext 集群上下文

func (*RPCClient) Context

func (this *RPCClient) Context() context.Context

Context 节点上下文信息

func (*RPCClient) FileChunkRPC

func (this *RPCClient) FileChunkRPC() pb.FileChunkServiceClient

func (*RPCClient) FileRPC

func (this *RPCClient) FileRPC() pb.FileServiceClient

func (*RPCClient) FirewallRPC

func (this *RPCClient) FirewallRPC() pb.FirewallServiceClient

func (*RPCClient) HTTPAccessLogRPC

func (this *RPCClient) HTTPAccessLogRPC() pb.HTTPAccessLogServiceClient

func (*RPCClient) HTTPCacheTaskKeyRPC

func (this *RPCClient) HTTPCacheTaskKeyRPC() pb.HTTPCacheTaskKeyServiceClient

func (*RPCClient) IPItemRPC

func (this *RPCClient) IPItemRPC() pb.IPItemServiceClient

func (*RPCClient) IPLibraryRPC

func (this *RPCClient) IPLibraryRPC() pb.IPLibraryServiceClient

func (*RPCClient) IPListRPC

func (this *RPCClient) IPListRPC() pb.IPListServiceClient

func (*RPCClient) MetricStatRPC

func (this *RPCClient) MetricStatRPC() pb.MetricStatServiceClient

func (*RPCClient) NodeLogRPC

func (this *RPCClient) NodeLogRPC() pb.NodeLogServiceClient

func (*RPCClient) NodeRPC

func (this *RPCClient) NodeRPC() pb.NodeServiceClient

func (*RPCClient) NodeTaskRPC

func (this *RPCClient) NodeTaskRPC() pb.NodeTaskServiceClient

func (*RPCClient) NodeValueRPC

func (this *RPCClient) NodeValueRPC() pb.NodeValueServiceClient

func (*RPCClient) RegionCityRPC

func (this *RPCClient) RegionCityRPC() pb.RegionCityServiceClient

func (*RPCClient) RegionCountryRPC

func (this *RPCClient) RegionCountryRPC() pb.RegionCountryServiceClient

func (*RPCClient) RegionProviderRPC

func (this *RPCClient) RegionProviderRPC() pb.RegionProviderServiceClient

func (*RPCClient) RegionProvinceRPC

func (this *RPCClient) RegionProvinceRPC() pb.RegionProvinceServiceClient

func (*RPCClient) SSLCertRPC

func (this *RPCClient) SSLCertRPC() pb.SSLCertServiceClient

func (*RPCClient) ServerBandwidthStatRPC

func (this *RPCClient) ServerBandwidthStatRPC() pb.ServerBandwidthStatServiceClient

func (*RPCClient) ServerDailyStatRPC

func (this *RPCClient) ServerDailyStatRPC() pb.ServerDailyStatServiceClient

func (*RPCClient) ServerRPC

func (this *RPCClient) ServerRPC() pb.ServerServiceClient

func (*RPCClient) UpdateConfig

func (this *RPCClient) UpdateConfig(config *configs.APIConfig) error

UpdateConfig 修改配置