clientutil

Sep 8, 2024

Changes in this version

+ const Sep

Sep 8, 2024

Changes in this version

+ var OK int32 = 0

+ var StatusOK int32 = stdhttp.StatusOK

+ func CheckHTTPResponse(httpCode int, response Response) *errors.Error

+ func CheckHTTPStatus(statusCode int) *errors.Error

+ func CheckResponseCode(response Response) *errors.Error

+ func CheckResponseStatus(resp Response) *errors.Error

+ type GetMetadata interface

+ GetMetadata func() map[string]string

+ type Response interface

+ GetCode func() int32

+ GetMessage func() string

+ GetReason func() string

Sep 6, 2024

Changes in this version

+ const DefaultTimeout

+ func NewPingGRPCClient(serviceAPIManager ServiceAPIManager, rewriteServiceName ...ServiceName) (pingservicev1.SrvPingClient, error)

+ func NewPingHTTPClient(serviceAPIManager ServiceAPIManager, rewriteServiceName ...ServiceName) (pingservicev1.SrvPingHTTPClient, error)

+ type Config struct

+ RegistryType configpb.RegistryTypeEnum_RegistryType

+ ServiceName string

+ ServiceTarget string

+ TransportType configpb.TransportTypeEnum_TransportType

+ func ToConfig(apiConfigs []*configpb.ClusterServiceApi) ([]*Config, map[configpb.RegistryTypeEnum_RegistryType]bool, error)

+ func (s *Config) IsConsulRegistry() bool

+ func (s *Config) IsEtcdRegistry() bool

+ func (s *Config) SetByPbClusterServiceApi(cfg *configpb.ClusterServiceApi)

+ type Option func(*option)

+ func WithConsulClient(consulClient *consulapi.Client) Option

+ func WithEtcdClient(etcdClient *clientv3.Client) Option

+ func WithLogger(logger log.Logger) Option

+ type ServiceAPIConnection interface

+ GetGRPCConnection func() (*stdgrpc.ClientConn, error)

+ GetHTTPClient func() (*http.Client, error)

+ GetTransportType func() configpb.TransportTypeEnum_TransportType

+ IsTransportType func(tt configpb.TransportTypeEnum_TransportType) bool

+ func NewServiceAPIConnection(serviceAPIManager ServiceAPIManager, serviceName ServiceName) (ServiceAPIConnection, error)

+ func NewSingletonServiceAPIConnection(serviceAPIManager ServiceAPIManager, serviceName ServiceName) (ServiceAPIConnection, error)

+ type ServiceAPIManager interface

+ GetServiceAPIConfig func(serviceName ServiceName) (*Config, error)

+ NewAPIConnection func(serviceName ServiceName) (ServiceAPIConnection, error)

+ RegisterServiceAPIConfigs func(apis []*Config, opts ...Option) error

+ func NewServiceAPIManager(apiConfigs []*Config, opts ...Option) (ServiceAPIManager, error)

+ type ServiceName string

+ const DingtalkApi

+ const DingtalkApiOld

+ const FeishuApi

+ const NodeidService

+ const PingService

+ func (s ServiceName) String() string