client

Documentation

Index

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

Functions

func WithCircuitBreaker

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

WithCircuitBreaker sets the circuit breaker policy from consul configuration center.

func WithRPCTimeout

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

WithRPCTimeout sets the RPC timeout policy from consul configuration center.

func WithRetryPolicy

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

WithRetryPolicy sets the retry policy from consul configuration center.

Types

type ConsulClientSuite

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

func NewSuite

func NewSuite(service, client string, cli consul.Client,
	opts ...utils.Option,
) *ConsulClientSuite

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

func (*ConsulClientSuite) Options

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

Options return a list client.Option