client

Documentation

Index

• func WithCircuitBreaker(dest, src string, etcdClient etcd.Client, uniqueID int64, opts utils.Options) []client.Option
• func WithDegradation(dest, src string, etcdClient etcd.Client, uniqueID int64, opts utils.Options) []client.Option
• func WithRPCTimeout(dest, src string, etcdClient etcd.Client, uniqueID int64, opts utils.Options) []client.Option
• func WithRetryPolicy(dest, src string, etcdClient etcd.Client, uniqueID int64, opts utils.Options) []client.Option
• type EtcdClientSuite
  • func NewSuite(service, client string, cli etcd.Client, opts ...utils.Option) *EtcdClientSuite
  • func (s *EtcdClientSuite) Options() []client.Option

Functions

func WithCircuitBreaker

func WithCircuitBreaker(dest, src string, etcdClient etcd.Client, uniqueID int64, opts utils.Options) []client.Option

WithCircuitBreaker sets the circuit breaker policy from etcd configuration center.

func WithDegradation

func WithDegradation(dest, src string, etcdClient etcd.Client, uniqueID int64, opts utils.Options) []client.Option

func WithRPCTimeout

func WithRPCTimeout(dest, src string, etcdClient etcd.Client, uniqueID int64, opts utils.Options) []client.Option

WithRPCTimeout sets the RPC timeout policy from etcd configuration center.

func WithRetryPolicy

func WithRetryPolicy(dest, src string, etcdClient etcd.Client, uniqueID int64, opts utils.Options) []client.Option

WithRetryPolicy sets the retry policy from etcd configuration center.

Types

type EtcdClientSuite

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

EtcdClientSuite etcd client config suite, configure retry timeout limit and circuitbreak dynamically from etcd.

func NewSuite

func NewSuite(service, client string, cli etcd.Client,
	opts ...utils.Option,
) *EtcdClientSuite

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

func (*EtcdClientSuite) Options

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

Options return a list client.Option