grpcc

Documentation

Index

• type Client
  • func New(cfg *grpcc_config.Cfg, log *logging.Logger, ...) *Client
  • func (t *Client) Get() (r result.Result[grpc.ClientConnInterface])
  • func (t *Client) Healthy(ctx context.Context) error
  • func (t *Client) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) (err error)
  • func (t *Client) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
• type Interface

Types

type Client

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

func New

func New(cfg *grpcc_config.Cfg, log *logging.Logger, middlewares map[string]service.Middleware) *Client

func (*Client) Get

func (t *Client) Get() (r result.Result[grpc.ClientConnInterface])

Get new grpc Client

func (*Client) Healthy

func (t *Client) Healthy(ctx context.Context) error

func (*Client) Invoke

func (t *Client) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) (err error)

func (*Client) NewStream

func (t *Client) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)

type Interface

type Interface interface {
	grpc.ClientConnInterface
	Healthy(ctx context.Context) error
}

Interface grpc client interface