grpc

package
v0.0.37 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 18, 2020 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package grpc provides generic functionality for grpc

Package grpc provides generic functionality for grpc

Package grpc provides generic functionality for grpc

Package grpc provides generic functionality for grpc

Package grpc provides generic functionality for grpc

Index

Constants

This section is empty.

Variables

View Source 
var (
	StatsHandler     = grpc.StatsHandler
	WithStatsHandler = grpc.WithStatsHandler
)

Functions

func BidirectionalStream 

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

BidirectionalStream represents gRPC bidirectional stream server handler.

func BidirectionalStreamClient added in v0.0.25 

func BidirectionalStreamClient(stream grpc.ClientStream,
	dataProvider func() interface{},
	newData func() interface{},
	f func(interface{}, error)) (err error)

BidirectionalStreamClient is gRPC client stream.

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)
	GetDialOption() []DialOption
	GetCallOption() []CallOption
	Close() error
}

func New 

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

type ClientConn 

type ClientConn = pool.ClientConn

type ClientStream added in v0.0.27 

type ClientStream = grpc.ClientStream

type DialOption 

type DialOption = pool.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 WithConnectionPoolRebalanceDuration added in v0.0.27 

func WithConnectionPoolRebalanceDuration(dur string) Option

func WithConnectionPoolSize added in v0.0.27 

func WithConnectionPoolSize(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 WithEnableConnectionPoolRebalance added in v0.0.27 

func WithEnableConnectionPoolRebalance(flg bool) 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 WithOldConnCloseDuration added in v0.0.29 

func WithOldConnCloseDuration(dur string) 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

type ServerOption added in v0.0.27 

type ServerOption = grpc.ServerOption

Source Files

View all Source files

Directories

Path Synopsis
Package metric provides metrics functions for grpc Package metric provides metrics functions for grpc Package metric provides metrics functions for grpc Package metric provides metrics functions for grpc
 Package metric provides metrics functions for grpc Package metric provides metrics functions for grpc Package metric provides metrics functions for grpc Package metric provides metrics functions for grpc
Package pool provides grpc connection pool client Package pool provides grpc connection pool client
 Package pool provides grpc connection pool client Package pool provides grpc connection pool client
Package proto provides proto file logic
 Package proto provides proto file logic
Package status provides statuses and errors returned by grpc handler functions
 Package status provides statuses and errors returned by grpc handler functions

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.