client

Documentation

Index

• func Log(logger log.Logger, logBody bool) request.Middleware
• func Metrics(storage MetricStorage) request.Middleware
• func RequestId() request.Middleware
• type Client
  • func Default(restMiddlewares ...request.Middleware) (*Client, error)
  • func New(initialHosts []string, opts ...Option) (*Client, error)
  • func (cli *Client) BackendClient() isp.BackendServiceClient
  • func (cli *Client) Close() error
  • func (cli *Client) Invoke(endpoint string) *request.Builder
  • func (cli *Client) Upgrade(hosts []string)
• type MetricStorage
• type Option
  • func WithDialOptions(dialOptions ...grpc.DialOption) Option
  • func WithMiddlewares(middlewares ...request.Middleware) Option

Functions

func Log

func Log(logger log.Logger, logBody bool) request.Middleware

func Metrics

func Metrics(storage MetricStorage) request.Middleware

func RequestId

func RequestId() request.Middleware

Types

type Client

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

func Default

func Default(restMiddlewares ...request.Middleware) (*Client, error)

func New

func New(initialHosts []string, opts ...Option) (*Client, error)

func (*Client) BackendClient

func (cli *Client) BackendClient() isp.BackendServiceClient

func (*Client) Close

func (cli *Client) Close() error

func (*Client) Invoke

func (cli *Client) Invoke(endpoint string) *request.Builder

func (*Client) Upgrade

func (cli *Client) Upgrade(hosts []string)

type MetricStorage

type MetricStorage interface {
	ObserveDuration(endpoint string, duration time.Duration)
}

type Option

type Option func(cli *Client)

func WithDialOptions

func WithDialOptions(dialOptions ...grpc.DialOption) Option

func WithMiddlewares

func WithMiddlewares(middlewares ...request.Middleware) Option