grpc

package

v0.0.16 Latest Latest Go to latest Published: Feb 26, 2020 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/vdaas/vald

Links

Open Source Insights

Documentation ¶

Overview ¶

Package grpc provides generic functionality for grpc

Package grpc provides generic functionality for grpc ¶

Package grpc provides generic functionality for grpc

Index ¶

func BidirectionalStream(stream grpc.ServerStream, concurrency int, newData func() interface{}, ...) (err error)
type CallOption
type Client
- func New(opts ...Option) (c Client)
type ClientConn
type ClientConnPool
- func NewPool(ctx context.Context, addr string, size uint64, dopts ...DialOption) (*ClientConnPool, error)
type DialOption
type Option
type Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BidirectionalStream ¶

func BidirectionalStream(stream grpc.ServerStream,
	concurrency int,
	newData func() interface{},
	f func(context.Context, interface{}) (interface{}, error)) (err error)

Types ¶

type CallOption ¶

type CallOption = grpc.CallOption

type Client ¶

type Client interface {
	StartConnectionMonitor(ctx context.Context) (<-chan error, error)
	Connect(ctx context.Context, addr string, dopts ...DialOption) error
	Disconnect(addr string) error
	Range(ctx context.Context,
		f func(ctx context.Context,
			addr string,
			conn *ClientConn,
			copts ...CallOption) error) error
	RangeConcurrent(ctx context.Context,
		concurrency int,
		f func(ctx context.Context,
			addr string,
			conn *ClientConn,
			copts ...CallOption) error) error
	OrderedRange(ctx context.Context,
		order []string,
		f func(ctx context.Context,
			addr string,
			conn *ClientConn,
			copts ...CallOption) error) error
	OrderedRangeConcurrent(ctx context.Context,
		order []string,
		concurrency int,
		f func(ctx context.Context,
			addr string,
			conn *ClientConn,
			copts ...CallOption) error) error
	Do(ctx context.Context, addr string,
		f func(ctx context.Context,
			conn *ClientConn,
			copts ...CallOption) (interface{}, error)) (interface{}, error)
	GetAddrs() ([]string, []string)
	GetDialOption() []DialOption
	GetCallOption() []CallOption
	Close() error
}

func New ¶

func New(opts ...Option) (c Client)

type ClientConn ¶

type ClientConn = grpc.ClientConn

type ClientConnPool ¶ added in v0.0.5

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

func NewPool ¶ added in v0.0.5

func NewPool(ctx context.Context, addr string, size uint64, dopts ...DialOption) (*ClientConnPool, error)

func (*ClientConnPool) Connect ¶ added in v0.0.5

func (c *ClientConnPool) Connect(ctx context.Context) (cp *ClientConnPool, err error)

func (*ClientConnPool) Disconnect ¶ added in v0.0.5

func (c *ClientConnPool) Disconnect() (rerr error)

func (*ClientConnPool) Do ¶ added in v0.0.5

func (c *ClientConnPool) Do(f func(conn *ClientConn) error) (err error)

func (*ClientConnPool) Get ¶ added in v0.0.5

func (c *ClientConnPool) Get() (*ClientConn, bool)

func (*ClientConnPool) IsHealthy ¶ added in v0.0.5

func (c *ClientConnPool) IsHealthy() bool

func (*ClientConnPool) Len ¶ added in v0.0.5

func (c *ClientConnPool) Len() uint64

func (*ClientConnPool) Put ¶ added in v0.0.5

func (c *ClientConnPool) Put(conn *ClientConn) error

type DialOption ¶

type DialOption = grpc.DialOption

type Option ¶

type Option func(*gRPCClient)

func WithAddrs ¶

func WithAddrs(addrs ...string) Option

func WithBackoff ¶

func WithBackoff(bo backoff.Backoff) Option

func WithCallOptions ¶

func WithCallOptions(opts ...grpc.CallOption) Option

func WithConnectionPool ¶ added in v0.0.5

func WithConnectionPool(size int) Option

func WithDialOptions ¶

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

func WithDialTimeout ¶

func WithDialTimeout(dur string) Option

func WithDialer ¶

func WithDialer(der tcp.Dialer) Option

func WithErrGroup ¶

func WithErrGroup(eg errgroup.Group) Option

func WithHealthCheckDuration ¶

func WithHealthCheckDuration(dur string) Option

func WithInitialConnectionWindowSize ¶

func WithInitialConnectionWindowSize(size int) Option

func WithInitialWindowSize ¶

func WithInitialWindowSize(size int) Option

func WithInsecure ¶

func WithInsecure(flg bool) Option

func WithKeepaliveParams ¶

func WithKeepaliveParams(t, to string, permitWithoutStream bool) Option

func WithMaxBackoffDelay ¶

func WithMaxBackoffDelay(dur string) Option

func WithMaxMsgSize ¶

func WithMaxMsgSize(size int) Option

func WithMaxRecvMsgSize ¶

func WithMaxRecvMsgSize(size int) Option

func WithMaxRetryRPCBufferSize ¶

func WithMaxRetryRPCBufferSize(size int) Option

func WithMaxSendMsgSize ¶

func WithMaxSendMsgSize(size int) Option

func WithReadBufferSize ¶

func WithReadBufferSize(size int) Option

func WithTLSConfig ¶

func WithTLSConfig(cfg *tls.Config) Option

func WithWaitForReady ¶

func WithWaitForReady(flg bool) Option

func WithWriteBufferSize ¶

func WithWriteBufferSize(size int) Option

type Server ¶

type Server = grpc.Server

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
status Package status provides statuses and errors returned by grpc handler functions	Package status provides statuses and errors returned by grpc handler functions

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL