rpc

package
v1.2.5 Latest Latest
Warning

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

Go to latest
Published: Jul 26, 2023 License: BSD-3-Clause Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsConnError added in v1.0.4

func IsConnError(err error) bool

IsConnError 是否为连接错误

func IsUnimplementedError added in v1.2.0

func IsUnimplementedError(err error) bool

IsUnimplementedError 检查是否为未实现错误

Types

type RPCClient

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

RPCClient RPC客户端

func NewRPCClient

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

NewRPCClient 构造新的RPC客户端

func SharedRPC

func SharedRPC() (*RPCClient, error)

func (*RPCClient) ACMEProviderAccountRPC added in v0.3.2

func (this *RPCClient) ACMEProviderAccountRPC() pb.ACMEProviderAccountServiceClient

func (*RPCClient) ACMEProviderRPC added in v0.3.2

func (this *RPCClient) ACMEProviderRPC() pb.ACMEProviderServiceClient

func (*RPCClient) ACMETaskRPC

func (this *RPCClient) ACMETaskRPC() pb.ACMETaskServiceClient

func (*RPCClient) ACMEUserRPC

func (this *RPCClient) ACMEUserRPC() pb.ACMEUserServiceClient

func (*RPCClient) APIContext

func (this *RPCClient) APIContext(apiNodeId int64) context.Context

APIContext 构造API上下文

func (*RPCClient) APIMethodStatRPC added in v0.4.1

func (this *RPCClient) APIMethodStatRPC() pb.APIMethodStatServiceClient

func (*RPCClient) APINodeRPC

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

func (*RPCClient) APITokenRPC added in v0.2.8

func (this *RPCClient) APITokenRPC() pb.APITokenServiceClient

func (*RPCClient) AdminRPC

func (this *RPCClient) AdminRPC() pb.AdminServiceClient

func (*RPCClient) AuthorityKeyRPC added in v0.0.13

func (this *RPCClient) AuthorityKeyRPC() pb.AuthorityKeyServiceClient

func (*RPCClient) AuthorityNodeRPC added in v0.0.13

func (this *RPCClient) AuthorityNodeRPC() pb.AuthorityNodeServiceClient

func (*RPCClient) Close added in v0.3.5

func (this *RPCClient) Close() error

Close 关闭

func (*RPCClient) Context

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

Context 构造Admin上下文

func (*RPCClient) DBNodeRPC

func (this *RPCClient) DBNodeRPC() pb.DBNodeServiceClient

func (*RPCClient) DBRPC added in v0.0.9

func (this *RPCClient) DBRPC() pb.DBServiceClient

func (*RPCClient) DNSDomainRPC

func (this *RPCClient) DNSDomainRPC() pb.DNSDomainServiceClient

func (*RPCClient) DNSProviderRPC

func (this *RPCClient) DNSProviderRPC() pb.DNSProviderServiceClient

func (*RPCClient) DNSRPC

func (this *RPCClient) DNSRPC() pb.DNSServiceClient

func (*RPCClient) DNSTaskRPC added in v0.0.10

func (this *RPCClient) DNSTaskRPC() pb.DNSTaskServiceClient

func (*RPCClient) FileChunkRPC

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

func (*RPCClient) FileRPC

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

func (*RPCClient) FirewallRPC added in v0.2.8

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

func (*RPCClient) HTTPAccessLogPolicyRPC

func (this *RPCClient) HTTPAccessLogPolicyRPC() pb.HTTPAccessLogPolicyServiceClient

func (*RPCClient) HTTPAccessLogRPC

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

HTTPAccessLogRPC 访问日志

func (*RPCClient) HTTPAuthPolicyRPC added in v0.2.3

func (this *RPCClient) HTTPAuthPolicyRPC() pb.HTTPAuthPolicyServiceClient

func (*RPCClient) HTTPCachePolicyRPC

func (this *RPCClient) HTTPCachePolicyRPC() pb.HTTPCachePolicyServiceClient

func (*RPCClient) HTTPCacheTaskKeyRPC added in v0.4.8

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

func (*RPCClient) HTTPCacheTaskRPC added in v0.4.8

func (this *RPCClient) HTTPCacheTaskRPC() pb.HTTPCacheTaskServiceClient

func (*RPCClient) HTTPFastcgiRPC added in v0.1.0

func (this *RPCClient) HTTPFastcgiRPC() pb.HTTPFastcgiServiceClient

func (*RPCClient) HTTPFirewallPolicyRPC

func (this *RPCClient) HTTPFirewallPolicyRPC() pb.HTTPFirewallPolicyServiceClient

func (*RPCClient) HTTPFirewallRuleGroupRPC

func (this *RPCClient) HTTPFirewallRuleGroupRPC() pb.HTTPFirewallRuleGroupServiceClient

func (*RPCClient) HTTPFirewallRuleSetRPC

func (this *RPCClient) HTTPFirewallRuleSetRPC() pb.HTTPFirewallRuleSetServiceClient

func (*RPCClient) HTTPGzipRPC

func (this *RPCClient) HTTPGzipRPC() pb.HTTPGzipServiceClient

func (*RPCClient) HTTPHeaderPolicyRPC

func (this *RPCClient) HTTPHeaderPolicyRPC() pb.HTTPHeaderPolicyServiceClient

func (*RPCClient) HTTPHeaderRPC

func (this *RPCClient) HTTPHeaderRPC() pb.HTTPHeaderServiceClient

func (*RPCClient) HTTPLocationRPC

func (this *RPCClient) HTTPLocationRPC() pb.HTTPLocationServiceClient

func (*RPCClient) HTTPPageRPC

func (this *RPCClient) HTTPPageRPC() pb.HTTPPageServiceClient

func (*RPCClient) HTTPRewriteRuleRPC

func (this *RPCClient) HTTPRewriteRuleRPC() pb.HTTPRewriteRuleServiceClient

func (*RPCClient) HTTPWebRPC

func (this *RPCClient) HTTPWebRPC() pb.HTTPWebServiceClient

func (*RPCClient) HTTPWebsocketRPC

func (this *RPCClient) HTTPWebsocketRPC() pb.HTTPWebsocketServiceClient

func (*RPCClient) IPItemRPC

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

func (*RPCClient) IPLibraryArtifactRPC added in v0.5.2

func (this *RPCClient) IPLibraryArtifactRPC() pb.IPLibraryArtifactServiceClient

func (*RPCClient) IPLibraryFileRPC added in v0.5.0

func (this *RPCClient) IPLibraryFileRPC() pb.IPLibraryFileServiceClient

func (*RPCClient) IPLibraryRPC

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

func (*RPCClient) IPListRPC

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

func (*RPCClient) LatestItemRPC added in v0.1.0

func (this *RPCClient) LatestItemRPC() pb.LatestItemServiceClient

func (*RPCClient) LogRPC

func (this *RPCClient) LogRPC() pb.LogServiceClient

func (*RPCClient) LoginRPC

func (this *RPCClient) LoginRPC() pb.LoginServiceClient

func (*RPCClient) LoginSessionRPC added in v0.6.4

func (this *RPCClient) LoginSessionRPC() pb.LoginSessionServiceClient

func (*RPCClient) MessageMediaInstanceRPC added in v0.0.13

func (this *RPCClient) MessageMediaInstanceRPC() pb.MessageMediaInstanceServiceClient

func (*RPCClient) MessageMediaRPC added in v0.0.13

func (this *RPCClient) MessageMediaRPC() pb.MessageMediaServiceClient

func (*RPCClient) MessageRPC

func (this *RPCClient) MessageRPC() pb.MessageServiceClient

func (*RPCClient) MessageReceiverRPC added in v0.0.13

func (this *RPCClient) MessageReceiverRPC() pb.MessageReceiverServiceClient

func (*RPCClient) MessageRecipientGroupRPC added in v0.0.13

func (this *RPCClient) MessageRecipientGroupRPC() pb.MessageRecipientGroupServiceClient

func (*RPCClient) MessageRecipientRPC added in v0.0.13

func (this *RPCClient) MessageRecipientRPC() pb.MessageRecipientServiceClient

func (*RPCClient) MessageTaskLogRPC added in v0.0.13

func (this *RPCClient) MessageTaskLogRPC() pb.MessageTaskLogServiceClient

func (*RPCClient) MessageTaskRPC added in v0.0.13

func (this *RPCClient) MessageTaskRPC() pb.MessageTaskServiceClient

func (*RPCClient) MetricChartRPC added in v0.2.8

func (this *RPCClient) MetricChartRPC() pb.MetricChartServiceClient

func (*RPCClient) MetricItemRPC added in v0.2.4

func (this *RPCClient) MetricItemRPC() pb.MetricItemServiceClient

func (*RPCClient) MetricStatRPC added in v0.2.8

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

func (*RPCClient) NodeClusterFirewallActionRPC added in v0.0.10

func (this *RPCClient) NodeClusterFirewallActionRPC() pb.NodeClusterFirewallActionServiceClient

func (*RPCClient) NodeClusterMetricItemRPC added in v0.2.4

func (this *RPCClient) NodeClusterMetricItemRPC() pb.NodeClusterMetricItemServiceClient

func (*RPCClient) NodeClusterRPC

func (this *RPCClient) NodeClusterRPC() pb.NodeClusterServiceClient

func (*RPCClient) NodeGrantRPC

func (this *RPCClient) NodeGrantRPC() pb.NodeGrantServiceClient

func (*RPCClient) NodeGroupRPC

func (this *RPCClient) NodeGroupRPC() pb.NodeGroupServiceClient

func (*RPCClient) NodeIPAddressLogRPC added in v0.3.0

func (this *RPCClient) NodeIPAddressLogRPC() pb.NodeIPAddressLogServiceClient

func (*RPCClient) NodeIPAddressRPC

func (this *RPCClient) NodeIPAddressRPC() pb.NodeIPAddressServiceClient

func (*RPCClient) NodeIPAddressThresholdRPC added in v0.3.1

func (this *RPCClient) NodeIPAddressThresholdRPC() pb.NodeIPAddressThresholdServiceClient

func (*RPCClient) NodeLogRPC

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

func (*RPCClient) NodeLoginRPC added in v0.2.9

func (this *RPCClient) NodeLoginRPC() pb.NodeLoginServiceClient

func (*RPCClient) NodeRPC

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

func (*RPCClient) NodeRegionRPC

func (this *RPCClient) NodeRegionRPC() pb.NodeRegionServiceClient

func (*RPCClient) NodeTaskRPC

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

func (*RPCClient) NodeThresholdRPC added in v0.1.0

func (this *RPCClient) NodeThresholdRPC() pb.NodeThresholdServiceClient

func (*RPCClient) NodeValueRPC added in v0.1.0

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

func (*RPCClient) OriginRPC

func (this *RPCClient) OriginRPC() pb.OriginServiceClient

func (*RPCClient) RegionCityRPC added in v0.4.8

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

func (*RPCClient) RegionCountryRPC

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

func (*RPCClient) RegionProviderRPC added in v0.4.8

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

func (*RPCClient) RegionProvinceRPC

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

func (*RPCClient) RegionTownRPC added in v0.5.0

func (this *RPCClient) RegionTownRPC() pb.RegionTownServiceClient

func (*RPCClient) ReverseProxyRPC

func (this *RPCClient) ReverseProxyRPC() pb.ReverseProxyServiceClient

func (*RPCClient) SSLCertRPC

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

func (*RPCClient) SSLPolicyRPC

func (this *RPCClient) SSLPolicyRPC() pb.SSLPolicyServiceClient

func (*RPCClient) ServerBandwidthStatRPC added in v0.5.2

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

func (*RPCClient) ServerClientBrowserMonthlyStatRPC added in v0.0.10

func (this *RPCClient) ServerClientBrowserMonthlyStatRPC() pb.ServerClientBrowserMonthlyStatServiceClient

func (*RPCClient) ServerClientSystemMonthlyStatRPC added in v0.0.10

func (this *RPCClient) ServerClientSystemMonthlyStatRPC() pb.ServerClientSystemMonthlyStatServiceClient

func (*RPCClient) ServerDailyStatRPC added in v0.2.0

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

func (*RPCClient) ServerDomainHourlyStatRPC added in v0.4.7

func (this *RPCClient) ServerDomainHourlyStatRPC() pb.ServerDomainHourlyStatServiceClient

func (*RPCClient) ServerGroupRPC

func (this *RPCClient) ServerGroupRPC() pb.ServerGroupServiceClient

func (*RPCClient) ServerHTTPFirewallDailyStatRPC added in v0.0.10

func (this *RPCClient) ServerHTTPFirewallDailyStatRPC() pb.ServerHTTPFirewallDailyStatServiceClient

func (*RPCClient) ServerRPC

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

func (*RPCClient) ServerRegionCityMonthlyStatRPC added in v0.0.10

func (this *RPCClient) ServerRegionCityMonthlyStatRPC() pb.ServerRegionCityMonthlyStatServiceClient

func (*RPCClient) ServerRegionCountryMonthlyStatRPC added in v0.0.10

func (this *RPCClient) ServerRegionCountryMonthlyStatRPC() pb.ServerRegionCountryMonthlyStatServiceClient

func (*RPCClient) ServerRegionProviderMonthlyStatRPC added in v0.0.10

func (this *RPCClient) ServerRegionProviderMonthlyStatRPC() pb.ServerRegionProviderMonthlyStatServiceClient

func (*RPCClient) ServerRegionProvinceMonthlyStatRPC added in v0.0.10

func (this *RPCClient) ServerRegionProvinceMonthlyStatRPC() pb.ServerRegionProvinceMonthlyStatServiceClient

func (*RPCClient) ServerStatBoardChartRPC added in v0.2.8

func (this *RPCClient) ServerStatBoardChartRPC() pb.ServerStatBoardChartServiceClient

func (*RPCClient) ServerStatBoardRPC added in v0.2.8

func (this *RPCClient) ServerStatBoardRPC() pb.ServerStatBoardServiceClient

func (*RPCClient) SysSettingRPC

func (this *RPCClient) SysSettingRPC() pb.SysSettingServiceClient

func (*RPCClient) TrafficDailyStatRPC added in v0.4.7

func (this *RPCClient) TrafficDailyStatRPC() pb.TrafficDailyStatServiceClient

func (*RPCClient) UpdateConfig added in v0.0.12

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

UpdateConfig 修改配置

func (*RPCClient) UserAccessKeyRPC added in v0.2.1

func (this *RPCClient) UserAccessKeyRPC() pb.UserAccessKeyServiceClient

func (*RPCClient) UserIdentityRPC added in v0.4.10

func (this *RPCClient) UserIdentityRPC() pb.UserIdentityServiceClient

func (*RPCClient) UserRPC

func (this *RPCClient) UserRPC() pb.UserServiceClient

Jump to

Keyboard shortcuts

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