grpc

package

v4.4.0 Latest Latest Go to latest Published: Apr 3, 2024 License: AGPL-3.0 Imports: 34 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/pydio/cells

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func DialOptionsForRegistry(reg registry.Registry, options ...grpc.DialOption) []grpc.DialOption
func ErrorFormatStreamClientInterceptor() grpc.StreamClientInterceptor
func ErrorFormatUnaryClientInterceptor() grpc.UnaryClientInterceptor
func GetClientConnFromCtx(ctx context.Context, serviceName string, opt ...Option) grpc.ClientConnInterface
func MetaStreamClientInterceptor() grpc.StreamClientInterceptor
func MetaUnaryClientInterceptor() grpc.UnaryClientInterceptor
func NewBuilder(reg registry.Registry, oo ...client.BalancerOption) resolver.Builder
func NewClientConn(serviceName string, opt ...Option) grpc.ClientConnInterface
func RegisterMock(serviceName string, mock grpc.ClientConnInterface)
type HealthMonitor
- func NewHealthChecker(c context.Context) HealthMonitor
type Option
type Options

Constants ¶

View Source

const BalancerRoundRobin = "cells-robin-"

Variables ¶

View Source

var (
	CallTimeoutShort         = 1 * time.Second
	WarnMissingConnInContext = false
)

Functions ¶

func DialOptionsForRegistry ¶

func DialOptionsForRegistry(reg registry.Registry, options ...grpc.DialOption) []grpc.DialOption

func ErrorFormatStreamClientInterceptor ¶ added in v4.0.7

func ErrorFormatStreamClientInterceptor() grpc.StreamClientInterceptor

func ErrorFormatUnaryClientInterceptor ¶ added in v4.0.7

func ErrorFormatUnaryClientInterceptor() grpc.UnaryClientInterceptor

func GetClientConnFromCtx ¶

func GetClientConnFromCtx(ctx context.Context, serviceName string, opt ...Option) grpc.ClientConnInterface

func MetaStreamClientInterceptor ¶

func MetaStreamClientInterceptor() grpc.StreamClientInterceptor

func MetaUnaryClientInterceptor ¶

func MetaUnaryClientInterceptor() grpc.UnaryClientInterceptor

func NewBuilder ¶

func NewBuilder(reg registry.Registry, oo ...client.BalancerOption) resolver.Builder

func NewClientConn ¶

func NewClientConn(serviceName string, opt ...Option) grpc.ClientConnInterface

NewClientConn returns a client attached to the defaults.

func RegisterMock ¶

func RegisterMock(serviceName string, mock grpc.ClientConnInterface)

RegisterMock registers a stubbed ClientConnInterface for a given service

Types ¶

type HealthMonitor ¶ added in v4.0.1

type HealthMonitor interface {
	Monitor(string)
	Up() bool
	Stop()
}

HealthMonitor blocks a connection to a specific service health

func NewHealthChecker ¶ added in v4.0.1

func NewHealthChecker(c context.Context) HealthMonitor

type Option ¶

type Option func(*Options)

func WithCallTimeout ¶

func WithCallTimeout(c time.Duration) Option

func WithClientConn ¶

func WithClientConn(c grpc.ClientConnInterface) Option

func WithDialOptions ¶

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

func WithPeerSelector ¶

func WithPeerSelector(host string) Option

func WithRegistry ¶

func WithRegistry(r registry.Registry) Option

type Options ¶

type Options struct {
	ClientConn     grpc.ClientConnInterface
	Registry       registry.Registry
	CallTimeout    time.Duration
	DialOptions    []grpc.DialOption
	BalancerFilter client.BalancerTargetFilter
}

Source Files ¶

View all Source files

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