grpcc

Documentation

Index

• func HealthCheck(srv string, conn grpc.ClientConnInterface) error
• func WithDial(fn func(srv string, cfg grpcc_config.Cfg) (grpc.ClientConnInterface, error)) func(cli *Client)
• type Client
  • func NewClient(srv string, opts ...Option) *Client
  • func (t *Client) Get() (_ grpc.ClientConnInterface, gErr error)
  • func (t *Client) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error
  • func (t *Client) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
• type Option

Functions

func HealthCheck

func HealthCheck(srv string, conn grpc.ClientConnInterface) error

func WithDial

func WithDial(fn func(srv string, cfg grpcc_config.Cfg) (grpc.ClientConnInterface, error)) func(cli *Client)

Types

type Client

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

func NewClient

func NewClient(srv string, opts ...Option) *Client

func (*Client) Get

func (t *Client) Get() (_ grpc.ClientConnInterface, gErr error)

Get new grpc Client

func (*Client) Invoke

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

func (*Client) NewStream

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

type Option

type Option func(cli *Client)