client

Documentation

Index

• func WithCircuitBreaker(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

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 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)