client

Documentation

Index

• func WithCircuitBreaker(dest, src string, zookeeperClient zookeeper.Client, opts utils.Options) []client.Option
• func WithRPCTimeout(dest, src string, zookeeperClient zookeeper.Client, opts utils.Options) []client.Option
• func WithRetryPolicy(dest, src string, zookeeperClient zookeeper.Client, opts utils.Options) []client.Option
• type ZookeeperClientSuite
  • func NewSuite(service, client string, cli zookeeper.Client, opts ...utils.Option) *ZookeeperClientSuite
  • func (s *ZookeeperClientSuite) Options() []client.Option

Functions

func WithCircuitBreaker

func WithCircuitBreaker(dest, src string, zookeeperClient zookeeper.Client, opts utils.Options) []client.Option

WithCircuitBreaker sets the circuit breaker policy from zookeeper configuration center.

func WithRPCTimeout

func WithRPCTimeout(dest, src string, zookeeperClient zookeeper.Client, opts utils.Options) []client.Option

WithRPCTimeout sets the RPC timeout policy from zookeeper configuration center.

func WithRetryPolicy

func WithRetryPolicy(dest, src string, zookeeperClient zookeeper.Client, opts utils.Options) []client.Option

WithRetryPolicy sets the retry policy from zookeeper configuration center.

Types

type ZookeeperClientSuite

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

ZookeeperClientSuite zookeeper client config suite, configure retry timeout limit and circuitbreak dynamically from zookeeper.

func NewSuite

func NewSuite(service, client string, cli zookeeper.Client, opts ...utils.Option) *ZookeeperClientSuite

NewSuite service is the destination service name and client is the local identity.

func (*ZookeeperClientSuite) Options

func (s *ZookeeperClientSuite) Options() []client.Option

Options return a list client.Option