client

Documentation

Index

• type Client
  • func NewClient(opts *ClientOpts) *Client
• type ClientOpts

Types

type Client

type Client struct {
	client.Client
	// contains filtered or unexported fields
}

var DefaultClient *Client

func NewClient

func NewClient(opts *ClientOpts) *Client

type ClientOpts

type ClientOpts struct {
	RequestTimeout  config.Duration `yaml:"request_timeout" json:"request_timeout"` // Default: 5s
	Retries         int             `yaml:"retries" json:"retries"`                 // Default: 1
	PoolSize        int             `yaml:"pool_size" json:"pool_size"`             // Default: 0
	PoolTTL         config.Duration `yaml:"pool_ttl" json:"pool_ttl"`               // Default: 1m
	BrokerAddress   []string        `yaml:"broker_address" json:"broker_address"`
	RegistryAddress []string        `yaml:"registry_address" json:"registry_address"`
	Selector        string          `yaml:"selector" json:"selector"`
}