client

Documentation

Index

• Variables
• func WithCircuitBreaker(dest, src string, apolloClient apollo.Client, opts utils.Options) []client.Option
• func WithFault(dest, src string, apolloClient apollo.Client, opts utils.Options) []client.Option
• func WithRPCTimeout(dest, src string, apolloClient apollo.Client, opts utils.Options) []client.Option
• func WithRetryPolicy(dest, src string, apolloClient apollo.Client, opts utils.Options) []client.Option
• type ApolloClientSuite
  • func NewSuite(service, client string, cli apollo.Client, options ...utils.Option) *ApolloClientSuite
  • func (s *ApolloClientSuite) Options() []client.Option
• type ClientSuiteOption

Variables

var (
	ErrMockFault = errors.New("mock fault error")
)

Functions

func WithCircuitBreaker

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

WithCircuitBreaker sets the circuit breaker policy from apollo configuration center.

func WithFault

func WithFault(dest, src string, apolloClient apollo.Client,
	opts utils.Options,
) []client.Option

WithFault 故障注入

func WithRPCTimeout

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

WithRPCTimeout sets the RPC timeout policy from apollo configuration center.

func WithRetryPolicy

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

Types

type ApolloClientSuite

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

func NewSuite

func NewSuite(service, client string, cli apollo.Client,
	options ...utils.Option,
) *ApolloClientSuite

func (*ApolloClientSuite) Options

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

type ClientSuiteOption

type ClientSuiteOption func(*ApolloClientSuite)