client

Documentation

Index

• type Client
  • func New(config Config, fileWatcher *fsnotify.Watcher, logger log.Logger, ...) (*Client, error)
  • func (c *Client) AddCloseFunc(f func())
  • func (c *Client) Close() error
  • func (c *Client) GRPC() *grpc.ClientConn
• type Config
  • func (c *Config) Validate() error
• type KeepAliveConfig

Types

type Client

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

GRPC Client.

func New

func New(config Config, fileWatcher *fsnotify.Watcher, logger log.Logger, tracerProvider trace.TracerProvider, opts ...grpc.DialOption) (*Client, error)

func (*Client) AddCloseFunc

func (c *Client) AddCloseFunc(f func())

AddCloseFunc adds a function to be called by the Close method. This eliminates the need for wrapping the Client.

func (*Client) Close

func (c *Client) Close() error

func (*Client) GRPC

func (c *Client) GRPC() *grpc.ClientConn

type Config

type Config struct {
	Addr      string          `yaml:"address" json:"address"`
	KeepAlive KeepAliveConfig `yaml:"keepAlive" json:"keepAlive"`
	TLS       client.Config   `yaml:"tls" json:"tls"`
}

func (*Config) Validate

func (c *Config) Validate() error

type KeepAliveConfig

type KeepAliveConfig struct {
	// After a duration of this time if the client doesn't see any activity it
	// pings the server to see if the transport is still alive.
	// If set below 10s, a minimum value of 10s will be used instead.
	Time time.Duration `yaml:"time" json:"time"` // The current default value is infinity.
	// After having pinged for keepalive check, the client waits for a duration
	// of Timeout and if no activity is seen even after that the connection is
	// closed.
	Timeout time.Duration `yaml:"timeout" json:"timeout"` // The current default value is 20 seconds.
	// If true, client sends keepalive pings even with no active RPCs. If false,
	// when there are no active RPCs, Time and Timeout will be ignored and no
	// keepalive pings will be sent.
	PermitWithoutStream bool `yaml:"permitWithoutStream" json:"permitWithoutStream"` // false by default.
}