client

package

Go to main page

Versions in this module

v1

v1.6.43

Jul 26, 2021

Changes in this version

type SelectMode

+ const EtcdV3Method

v1.6.42

Jul 22, 2021

v1.6.41

Jul 22, 2021

Changes in this version

+ const EventTypeDelete

+ const EventTypePut

+ const FileTransferBufferSize

+ var ConnFactories = map[string]ConnFactoryFn

+ func CalculateWeight(rtt int) int

+ func Ping(host string) (rtt int, err error)

+ func RegisterCacheClientBuilder(network string, builder CacheClientBuilder)

type Breaker

+ Fail func()

+ Ready func() bool

+ Success func()

+ type CacheClientBuilder interface

+ DeleteCachedClient func(client RPCClient, k, servicePath, serviceMethod string)

+ FindCachedClient func(k, servicePath, serviceMethod string) RPCClient

+ GenerateClient func(k, servicePath, serviceMethod string) (client RPCClient, err error)

+ SetCachedClient func(client RPCClient, k, servicePath, serviceMethod string)

type Client

+ ServerMessageChanMu sync.RWMutex

+ func (c *Client) GetConn() net.Conn

+ func (c *Client) RemoteAddr() string

+ type ClientAfterDecodePlugin interface

+ ClientAfterDecode func(*protocol.Message) error

+ type ClientBeforeEncodePlugin interface

+ ClientBeforeEncode func(*protocol.Message) error

+ type ClientConnectedPlugin interface

+ ClientConnected func(net.Conn) (net.Conn, error)

+ type ClientConnectionClosePlugin interface

+ ClientConnectionClose func(net.Conn) error

+ type ConnCreatedPlugin interface

+ ConnCreated func(net.Conn) (net.Conn, error)

+ type ConnFactoryFn func(c *Client, network, address string) (net.Conn, error)

type ConsecCircuitBreaker

+ func (cb *ConsecCircuitBreaker) Fail()

+ func (cb *ConsecCircuitBreaker) Ready() bool

+ func (cb *ConsecCircuitBreaker) Success()

+ type ConsulDiscovery struct

+ RetriesAfterWatchFailed int

+ func (d *ConsulDiscovery) Clone(servicePath string) (ServiceDiscovery, error)

+ func (d *ConsulDiscovery) Close()

+ func (d *ConsulDiscovery) GetServices() []*KVPair

+ func (d *ConsulDiscovery) RemoveWatcher(ch chan []*KVPair)

+ func (d *ConsulDiscovery) SetFilter(filter ServiceDiscoveryFilter)

+ func (d *ConsulDiscovery) WatchService() chan []*KVPair

+ type DNSDiscovery struct

+ func (d *DNSDiscovery) Clone(servicePath string) (ServiceDiscovery, error)

+ func (d *DNSDiscovery) Close()

+ func (d *DNSDiscovery) GetServices() []*KVPair

+ func (d *DNSDiscovery) RemoveWatcher(ch chan []*KVPair)

+ func (d *DNSDiscovery) SetFilter(filter ServiceDiscoveryFilter)

+ func (d *DNSDiscovery) WatchService() chan []*KVPair

type FailMode

+ func FailModeString(s string) (FailMode, error)

+ func FailModeValues() []FailMode

+ func (i FailMode) IsAFailMode() bool

+ func (i FailMode) String() string

type KVPair

+ Type uint64

type MDNSDiscovery

+ func (d *MDNSDiscovery) SetFilter(filter ServiceDiscoveryFilter)

type MultipleServersDiscovery

+ func (d *MultipleServersDiscovery) SetFilter(filter ServiceDiscoveryFilter)

+ type Node struct

+ Addr string

+ Info *util.ServiceInfo

+ type OneClient struct

+ Plugins PluginContainer

+ func NewBidirectionalOneClient(failMode FailMode, selectMode SelectMode, discovery ServiceDiscovery, ...) *OneClient

+ func NewOneClient(failMode FailMode, selectMode SelectMode, discovery ServiceDiscovery, ...) *OneClient

+ func (c *OneClient) Auth(auth string)

+ func (c *OneClient) Broadcast(ctx context.Context, servicePath string, serviceMethod string, ...) error

+ func (c *OneClient) Call(ctx context.Context, servicePath string, serviceMethod string, ...) error

+ func (c *OneClient) Close() error

+ func (c *OneClient) ConfigGeoSelector(latitude, longitude float64)

+ func (c *OneClient) DownloadFile(ctx context.Context, requestFileName string, saveTo io.Writer, ...) error

+ func (c *OneClient) Fork(ctx context.Context, servicePath string, serviceMethod string, ...) error

+ func (c *OneClient) GetPlugins() PluginContainer

+ func (c *OneClient) Go(ctx context.Context, servicePath string, serviceMethod string, ...) (*Call, error)

+ func (c *OneClient) SendFile(ctx context.Context, fileName string, rateInBytesPerSecond int64, ...) error

+ func (c *OneClient) SendRaw(ctx context.Context, r *protocol.Message) (map[string]string, []byte, error)

+ func (c *OneClient) SetPlugins(plugins PluginContainer)

+ func (c *OneClient) SetSelector(servicePath string, s Selector)

+ func (c *OneClient) Stream(ctx context.Context, meta map[string]string) (net.Conn, error)

+ type OneClientPool struct

+ func NewBidirectionalOneClientPool(count int, failMode FailMode, selectMode SelectMode, ...) *OneClientPool

+ func NewOneClientPool(count int, failMode FailMode, selectMode SelectMode, ...) *OneClientPool

+ func (c *OneClientPool) Auth(auth string)

+ func (p *OneClientPool) Get() *OneClient

+ func (p OneClientPool) Close()

+ type OpenCensusPlugin struct

+ func (p *OpenCensusPlugin) PostCall(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) error

+ func (p *OpenCensusPlugin) PreCall(ctx context.Context, servicePath, serviceMethod string, args interface{}) error

+ type OpenTracingPlugin struct

+ func (p *OpenTracingPlugin) PostCall(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) error

+ func (p *OpenTracingPlugin) PreCall(ctx context.Context, servicePath, serviceMethod string, args interface{}) error

type Option

+ GenBreaker func() Breaker

+ IdleTimeout time.Duration

+ MaxWaitForHeartbeat time.Duration

+ TCPKeepAlivePeriod time.Duration

type Peer2PeerDiscovery

+ func (d *Peer2PeerDiscovery) SetFilter(filter ServiceDiscoveryFilter)

type PluginContainer

+ func NewPluginContainer() PluginContainer

+ DoClientAfterDecode func(*protocol.Message) error

+ DoClientBeforeEncode func(*protocol.Message) error

+ DoClientConnected func(net.Conn) (net.Conn, error)

+ DoClientConnectionClose func(net.Conn) error

+ DoConnCreated func(net.Conn) (net.Conn, error)

+ DoWrapSelect func(SelectFunc) SelectFunc

type PostCallPlugin

+ PostCall func(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) error

type PreCallPlugin

+ PreCall func(ctx context.Context, servicePath, serviceMethod string, args interface{}) error

type RPCClient

+ GetConn func() net.Conn

+ RemoteAddr func() string

+ type RedisDiscovery struct

+ RetriesAfterWatchFailed int

+ func (d *RedisDiscovery) Clone(servicePath string) (ServiceDiscovery, error)

+ func (d *RedisDiscovery) Close()

+ func (d *RedisDiscovery) GetServices() []*KVPair

+ func (d *RedisDiscovery) RemoveWatcher(ch chan []*KVPair)

+ func (d *RedisDiscovery) SetFilter(filter ServiceDiscoveryFilter)

+ func (d *RedisDiscovery) WatchService() chan []*KVPair

+ type SelectFunc func(ctx context.Context, servicePath, serviceMethod string, args interface{}) string

type SelectMode

+ func SelectModeString(s string) (SelectMode, error)

+ func SelectModeValues() []SelectMode

+ func (i SelectMode) IsASelectMode() bool

+ type SelectNodePlugin interface

+ WrapSelect func(SelectFunc) SelectFunc

type Selector

+ AddNode func(key string, info *util.ServiceInfo)

+ DelNode func(key string)

type ServiceDiscovery

+ func NewConsulDiscovery(basePath, servicePath string, consulAddr []string, options *store.Config) (ServiceDiscovery, error)

+ func NewConsulDiscoveryStore(basePath string, kv store.Store) (ServiceDiscovery, error)

+ func NewConsulDiscoveryTemplate(basePath string, consulAddr []string, options *store.Config) (ServiceDiscovery, error)

+ func NewDNSDiscovery(domain string, network string, port int, d time.Duration) (ServiceDiscovery, error)

+ func NewRedisDiscovery(basePath string, servicePath string, redisAddr []string, options *store.Config) (ServiceDiscovery, error)

+ func NewRedisDiscoveryStore(basePath string, kv store.Store) (ServiceDiscovery, error)

+ func NewRedisDiscoveryTemplate(basePath string, etcdAddr []string, options *store.Config) (ServiceDiscovery, error)

+ func NewZookeeperDiscovery(basePath string, servicePath string, zkAddr []string, options *store.Config) (ServiceDiscovery, error)

+ func NewZookeeperDiscoveryTemplate(basePath string, zkAddr []string, options *store.Config) (ServiceDiscovery, error)

+ func NewZookeeperDiscoveryWithStore(basePath string, kv store.Store) (ServiceDiscovery, error)

+ SetFilter func(ServiceDiscoveryFilter)

+ type ServiceDiscoveryFilter func(kvp *KVPair) bool

type XClient

+ func NewXClientNodes(servicePath string, failMode FailMode, discovery ServiceDiscovery, ...) XClient

+ DownloadFile func(ctx context.Context, requestFileName string, saveTo io.Writer, ...) error

+ GetPlugins func() PluginContainer

+ SendFile func(ctx context.Context, fileName string, rateInBytesPerSecond int64, ...) error

+ Stream func(ctx context.Context, meta map[string]string) (net.Conn, error)

+ type XClientPool struct

+ func NewBidirectionalXClientPool(count int, servicePath string, failMode FailMode, selectMode SelectMode, ...) *XClientPool

+ func NewXClientPool(count int, servicePath string, failMode FailMode, selectMode SelectMode, ...) *XClientPool

+ func (c *XClientPool) Auth(auth string)

+ func (p *XClientPool) Close()

+ func (p *XClientPool) Get() XClient

+ type ZookeeperDiscovery struct

+ RetriesAfterWatchFailed int

+ func (d *ZookeeperDiscovery) Clone(servicePath string) (ServiceDiscovery, error)

+ func (d *ZookeeperDiscovery) Close()

+ func (d *ZookeeperDiscovery) GetServices() []*KVPair

+ func (d *ZookeeperDiscovery) RemoveWatcher(ch chan []*KVPair)

+ func (d *ZookeeperDiscovery) SetFilter(filter ServiceDiscoveryFilter)

+ func (d *ZookeeperDiscovery) WatchService() chan []*KVPair

v1.3.1

Feb 22, 2018

Changes in this version

+ const ReaderBuffsize

+ const WriterBuffsize

+ const XErrorMessage

+ const XHeartbeat

+ const XMessageID

+ const XMessageStatusType

+ const XMessageType

+ const XMeta

+ const XOneway

+ const XSerializeType

+ const XServiceMethod

+ const XServicePath

+ const XVersion

+ var DefaultOption = Option

+ var ErrBreakerOpen = errors.New("breaker open")

+ var ErrBreakerTimeout = errors.New("breaker time out")

+ var ErrServerUnavailable = errors.New("selected server is unavilable")

+ var ErrShutdown = errors.New("connection is shut down")

+ var ErrUnsupportedCodec = errors.New("unsupported codec")

+ var ErrXClientNoServer = errors.New("can not found any server")

+ var ErrXClientShutdown = errors.New("xClient is shut down")

+ var InprocessClient = &inprocessClient

+ func Hash(key uint64, buckets int32) int32

+ func HashString(s string) uint64

+ func JumpConsistentHash(len int, options ...interface{}) int

+ type Breaker interface

+ Call func(func() error, time.Duration) error

+ var CircuitBreaker Breaker = circuit.NewRateBreaker(0.95, 100)

+ type Call struct

+ Args interface{}

+ Done chan *Call

+ Error error

+ Metadata map[string]string

+ Raw bool

+ Reply interface{}

+ ResMetadata map[string]string

+ ServiceMethod string

+ ServicePath string

+ type Client struct

+ Conn net.Conn

+ Plugins PluginContainer

+ ServerMessageChan chan<- *protocol.Message

+ func NewClient(option Option) *Client

+ func (c *Client) Connect(network, address string) error

+ func (client *Client) Call(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) error

+ func (client *Client) Close() error

+ func (client *Client) Go(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) *Call

+ func (client *Client) IsClosing() bool

+ func (client *Client) IsShutdown() bool

+ func (client *Client) RegisterServerMessageChan(ch chan<- *protocol.Message)

+ func (client *Client) SendRaw(ctx context.Context, r *protocol.Message) (map[string]string, []byte, error)

+ func (client *Client) UnregisterServerMessageChan()

+ type ConsecCircuitBreaker struct

+ func NewConsecCircuitBreaker(failureThreshold uint64, window time.Duration) *ConsecCircuitBreaker

+ func (cb *ConsecCircuitBreaker) Call(fn func() error, d time.Duration) error

+ type ConsistentAddrStrFunction func(options ...interface{}) string

+ type FailMode int

+ const Failbackup

+ const Failfast

+ const Failover

+ const Failtry

+ type HashServiceAndArgs func(len int, options ...interface{}) int

+ type InprocessDiscovery struct

+ func (d *InprocessDiscovery) Close()

+ func (d InprocessDiscovery) Clone(servicePath string) ServiceDiscovery

+ func (d InprocessDiscovery) GetServices() []*KVPair

+ func (d InprocessDiscovery) RemoveWatcher(ch chan []*KVPair)

+ func (d InprocessDiscovery) WatchService() chan []*KVPair

+ type KVPair struct

+ Key string

+ Value string

+ type MDNSDiscovery struct

+ Timeout time.Duration

+ WatchInterval time.Duration

+ func (d *MDNSDiscovery) Close()

+ func (d *MDNSDiscovery) RemoveWatcher(ch chan []*KVPair)

+ func (d *MDNSDiscovery) WatchService() chan []*KVPair

+ func (d MDNSDiscovery) Clone(servicePath string) ServiceDiscovery

+ func (d MDNSDiscovery) GetServices() []*KVPair

+ type MultipleServersDiscovery struct

+ func (d *MultipleServersDiscovery) Close()

+ func (d *MultipleServersDiscovery) RemoveWatcher(ch chan []*KVPair)

+ func (d *MultipleServersDiscovery) Update(pairs []*KVPair)

+ func (d *MultipleServersDiscovery) WatchService() chan []*KVPair

+ func (d MultipleServersDiscovery) Clone(servicePath string) ServiceDiscovery

+ func (d MultipleServersDiscovery) GetServices() []*KVPair

+ type Option struct

+ BackupLatency time.Duration

+ Block interface{}

+ Breaker Breaker

+ CompressType protocol.CompressType

+ ConnectTimeout time.Duration

+ Group string

+ Heartbeat bool

+ HeartbeatInterval time.Duration

+ RPCPath string

+ ReadTimeout time.Duration

+ Retries int

+ SerializeType protocol.SerializeType

+ TLSConfig *tls.Config

+ WriteTimeout time.Duration

+ type Peer2PeerDiscovery struct

+ func (d *Peer2PeerDiscovery) Close()

+ func (d *Peer2PeerDiscovery) RemoveWatcher(ch chan []*KVPair)

+ func (d Peer2PeerDiscovery) Clone(servicePath string) ServiceDiscovery

+ func (d Peer2PeerDiscovery) GetServices() []*KVPair

+ func (d Peer2PeerDiscovery) WatchService() chan []*KVPair

+ type Plugin interface

+ type PluginContainer interface

+ Add func(plugin Plugin)

+ All func() []Plugin

+ DoPostCall func(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) error

+ DoPreCall func(ctx context.Context, servicePath, serviceMethod string, args interface{}) error

+ Remove func(plugin Plugin)

+ type PostCallPlugin interface

+ DoPostCall func(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) error

+ type PreCallPlugin interface

+ DoPreCall func(ctx context.Context, servicePath, serviceMethod string, args interface{}) error

+ type RPCClient interface

+ Call func(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) error

+ Close func() error

+ Connect func(network, address string) error

+ Go func(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) *Call

+ IsClosing func() bool

+ IsShutdown func() bool

+ RegisterServerMessageChan func(ch chan<- *protocol.Message)

+ SendRaw func(ctx context.Context, r *protocol.Message) (map[string]string, []byte, error)

+ UnregisterServerMessageChan func()

+ type SelectMode int

+ const Closest

+ const ConsistentHash

+ const RandomSelect

+ const RoundRobin

+ const SelectByUser

+ const WeightedICMP

+ const WeightedRoundRobin

+ func (s SelectMode) String() string

+ type Selector interface

+ Select func(ctx context.Context, servicePath, serviceMethod string, args interface{}) string

+ UpdateServer func(servers map[string]string)

+ type ServiceDiscovery interface

+ Clone func(servicePath string) ServiceDiscovery

+ Close func()

+ GetServices func() []*KVPair

+ RemoveWatcher func(ch chan []*KVPair)

+ WatchService func() chan []*KVPair

+ func NewInprocessDiscovery() ServiceDiscovery

+ func NewMDNSDiscovery(service string, timeout time.Duration, watchInterval time.Duration, ...) ServiceDiscovery

+ func NewMDNSDiscoveryTemplate(timeout time.Duration, watchInterval time.Duration, domain string) ServiceDiscovery

+ func NewMultipleServersDiscovery(pairs []*KVPair) ServiceDiscovery

+ func NewPeer2PeerDiscovery(server, metadata string) ServiceDiscovery

+ type ServiceError string

+ func (e ServiceError) Error() string

+ type Weighted struct

+ CurrentWeight int

+ EffectiveWeight int

+ Server string

+ Weight int

+ type XClient interface

+ Auth func(auth string)

+ Broadcast func(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

+ Call func(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

+ Close func() error

+ ConfigGeoSelector func(latitude, longitude float64)

+ Fork func(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

+ Go func(ctx context.Context, serviceMethod string, args interface{}, reply interface{}, ...) (*Call, error)

+ SendRaw func(ctx context.Context, r *protocol.Message) (map[string]string, []byte, error)

+ SetPlugins func(plugins PluginContainer)

+ SetSelector func(s Selector)

+ func NewBidirectionalXClient(servicePath string, failMode FailMode, selectMode SelectMode, ...) XClient

+ func NewXClient(servicePath string, failMode FailMode, selectMode SelectMode, ...) XClient

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