grpc

Documentation

Index

• type Client
  • func (c *Client) Call(ctx context.Context, path string, args, reply interface{}, ...) error
  • func (c *Client) Stream(ctx context.Context, path string, opts ...grpc.CallOption) (grpc.ClientStream, error)
• type Option
  • func Address(address string) Option
  • func GrpcDialOptions(opts ...grpc.DialOption) Option
• type Options
  • func NewOptions(opts ...Option) *Options
  • func (opt *Options) Build() *Client

Types

type Client

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

func (*Client) Call

func (c *Client) Call(ctx context.Context, path string, args, reply interface{}, opts ...grpc.CallOption) error

path:/service.Struct/Method

func (*Client) Stream

func (c *Client) Stream(ctx context.Context, path string, opts ...grpc.CallOption) (grpc.ClientStream, error)

type Option

type Option func(*Options)

func Address

func Address(address string) Option

func GrpcDialOptions

func GrpcDialOptions(opts ...grpc.DialOption) Option

type Options

type Options struct {
	PoolSize       int
	PoolTTL        time.Duration
	PoolMaxIdle    int
	PoolMaxStreams int
	// contains filtered or unexported fields
}

func NewOptions

func NewOptions(opts ...Option) *Options

func (*Options) Build

func (opt *Options) Build() *Client