grpc

package
v2.11.1 Latest Latest
Warning

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

 Go to latest Published: Aug 4, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Overview

+kubebuilder:validation:Optional

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ClientModule 

func ClientModule() fx.Option

ClientModule is an fx module that provides annotated grpc ClientConnectionBuilder.

func GMuxServerModule 

func GMuxServerModule() fx.Option

GMuxServerModule is an fx module that provides annotated gRPC Server using gmux provided listener and registers its metrics with the prometheus registry.

func RegisterGRPCServerMetrics 

func RegisterGRPCServerMetrics(metrics *grpc_prometheus.ServerMetrics, pr *prometheus.Registry) error

RegisterGRPCServerMetrics registers a collection of metrics provided by grpc_prometheus.ServerMetrics with a prometheus registry.

func RegisterInfoService 

func RegisterInfoService(server *grpc.Server)

RegisterInfoService registers the InfoService implementation with the provided grpc server.

func ServerModule 

func ServerModule() fx.Option

ServerModule is an fx module that provides annotated gRPC Server using the default listener and registers its metrics with the prometheus registry.

Types

type BackoffConfig 

type BackoffConfig struct {
	// Base Delay
	BaseDelay config.Duration `json:"base_delay" validate:"gte=0" default:"1s"`
	// Max Delay
	MaxDelay config.Duration `json:"max_delay" validate:"gte=0" default:"120s"`
	// Backoff multiplier
	Multiplier float64 `json:"multiplier" validate:"gte=0" default:"1.6"`
	// Jitter
	Jitter float64 `json:"jitter" validate:"gte=0" default:"0.2"`
}

BackoffConfig holds configuration for gRPC client backoff. swagger:model +kubebuilder:object:generate=true

func (*BackoffConfig) DeepCopy 

func (in *BackoffConfig) DeepCopy() *BackoffConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BackoffConfig.

func (*BackoffConfig) DeepCopyInto 

func (in *BackoffConfig) DeepCopyInto(out *BackoffConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClientConnectionBuilder 

type ClientConnectionBuilder interface {
	AddOptions(opts ...grpc.DialOption) ClientConnectionBuilder
	Build() ClientConnectionWrapper
}

ClientConnectionBuilder is a convenience builder to gather []grpc.DialOption.

type ClientConnectionWrapper 

type ClientConnectionWrapper interface {
	// Context can be nil
	Dial(ctx context.Context, target string, extraOptions ...grpc.DialOption) (*grpc.ClientConn, error)
}

ClientConnectionWrapper is a convenience wrapper to support predefined dial Options provided by ClientConnectionBuilder.

type ClientConstructor 

type ClientConstructor struct {
	Name          string
	ConfigKey     string
	DefaultConfig GRPCClientConfig
}

ClientConstructor holds fields to create an annotated instance of ClientConnectionBuilder.

func (ClientConstructor) Annotate 

func (c ClientConstructor) Annotate() fx.Option

Annotate creates an annotated instance of gRPC ClientConnectionBuilder.

type GRPCClientConfig 

type GRPCClientConfig struct {
	// Minimum connection timeout
	MinConnectionTimeout config.Duration `json:"min_connection_timeout" validate:"gte=0" default:"20s"`
	// Client TLS configuration
	ClientTLSConfig tlsconfig.ClientTLSConfig `json:"tls"`
	// Backoff configuration
	Backoff BackoffConfig `json:"backoff"`
	// Disable ClientTLS
	Insecure bool `json:"insecure" default:"false"`
	// Use HTTP CONNECT Proxy
	UseProxy bool `json:"use_proxy" default:"false"`
}

GRPCClientConfig holds configuration for gRPC Client. swagger:model +kubebuilder:object:generate=true

func (*GRPCClientConfig) DeepCopy 

func (in *GRPCClientConfig) DeepCopy() *GRPCClientConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GRPCClientConfig.

func (*GRPCClientConfig) DeepCopyInto 

func (in *GRPCClientConfig) DeepCopyInto(out *GRPCClientConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GRPCServerConfig 

type GRPCServerConfig struct {
	// Connection timeout
	ConnectionTimeout config.Duration `json:"connection_timeout" validate:"gte=0s" default:"120s"`
	// Buckets specification in latency histogram
	LatencyBucketsMS []float64 `json:"latency_buckets_ms" validate:"gte=0" default:"[10.0,25.0,100.0,250.0,1000.0]"`
	// Enable Reflection
	EnableReflection bool `json:"enable_reflection" default:"false"`
}

GRPCServerConfig holds configuration for gRPC Server. swagger:model +kubebuilder:object:generate=true

func (*GRPCServerConfig) DeepCopy 

func (in *GRPCServerConfig) DeepCopy() *GRPCServerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GRPCServerConfig.

func (*GRPCServerConfig) DeepCopyInto 

func (in *GRPCServerConfig) DeepCopyInto(out *GRPCServerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type InfoService 

type InfoService struct {
	infov1.UnimplementedInfoServiceServer
}

InfoService is the implementation of the infov1.InfoServiceServer interface.

func (*InfoService) Host 

func (vh *InfoService) Host(ctx context.Context, req *emptypb.Empty) (*infov1.HostInfo, error)

Host returns the hostname of the service.

func (*InfoService) Process 

func (vh *InfoService) Process(ctx context.Context, req *emptypb.Empty) (*infov1.ProcessInfo, error)

Process returns the process info of the service.

func (*InfoService) Version 

func (vh *InfoService) Version(ctx context.Context, req *emptypb.Empty) (*infov1.VersionInfo, error)

Version returns the version of the service.

type LogEvent 

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

LogEvent wraps *zerolog.Event, so that sending an event also returns an grpc error

LogEvent also forwards _some_ builder-functions (like Str()) to the underlying zerolog.Event. This is just a sugar, as you can always use WithEvent on the whole chain.

func Bug 

func Bug() LogEvent

Bug is equivalent to WithLogEvent(log.Bug()).Code(codes.Internal)

Example: return nil, grpc.Bug().Msg("impossible happened").

func BugWithLogger 

func BugWithLogger(lg *log.Logger) LogEvent

BugWithLogger is equivalent to WithLogEvent(logger.Bug()).Code(codes.Internal).

func LoggedError 

func LoggedError(e *zerolog.Event) LogEvent

LoggedError wraps zerolog.Event so that sending an event will also return a grpc error.

GRPC error code should be provided using Code(), otherwise, the error will use codes.Unknown.

Example: 

return nil, grpc.LoggedError(log.Autosample().Warn()).
    Code(codes.InvalidArgument).
    Msg("missing frobnicator")

func (LogEvent) Bool 

func (e LogEvent) Bool(key string, b bool) LogEvent

Bool adds the field key with val as a bool to the *Event context.

func (LogEvent) Code 

func (e LogEvent) Code(code codes.Code) LogEvent

Code sets the gRPC code to be used in error returned via Msg() or Send()

Additionally, it adds the code field to the event.

func (LogEvent) Err 

func (e LogEvent) Err(err error) LogEvent

Err adds the field "error" with serialized err to the *Event context. If err is nil, no field is added.

To customize the key name, change zerolog.ErrorFieldName.

If Stack() has been called before and zerolog.ErrorStackMarshaler is defined, the err is passed to ErrorStackMarshaler and the result is appended to the zerolog.ErrorStackFieldName.

func (LogEvent) Float32 

func (e LogEvent) Float32(key string, f float32) LogEvent

Float32 adds the field key with f as a float32 to the *Event context.

func (LogEvent) Float64 

func (e LogEvent) Float64(key string, f float64) LogEvent

Float64 adds the field key with f as a float64 to the *Event context.

func (LogEvent) Int 

func (e LogEvent) Int(key string, i int) LogEvent

Int adds the field key with i as a int to the *Event context.

func (LogEvent) Interface 

func (e LogEvent) Interface(key string, i interface{}) LogEvent

Interface adds the field key with i marshaled using reflection.

func (LogEvent) Msg 

func (e LogEvent) Msg(msg string) error

Msg sends the *Event with msg added as the message field if not empty.

Msg returns grpc error using given msg as message and code previously set with Code

NOTICE: once this method is called, the LogEvent should be disposed. Calling Msg twice can have unexpected result.

func (LogEvent) Send 

func (e LogEvent) Send() error

Send is equivalent to calling Msg("").

func (LogEvent) Str 

func (e LogEvent) Str(key, val string) LogEvent

Str adds the field key with val as a string to the *Event context.

func (LogEvent) Stringer 

func (e LogEvent) Stringer(key string, val fmt.Stringer) LogEvent

Stringer adds the field key with val.String() (or null if val is nil) to the *Event context.

type ServerConstructor 

type ServerConstructor struct {
	// Name of grpc server instance -- empty for main server
	Name string
	// Name of listener instance
	ListenerName string
	// Viper config key/server name
	ConfigKey string
	// Additional server Options
	ServerOptions []grpc.ServerOption
	// UnaryServerInterceptors add after all built-in unary interceptors
	UnaryServerInterceptors []grpc.UnaryServerInterceptor
	// StreamServerInterceptors add after all built-in stream interceptors
	StreamServerInterceptors []grpc.StreamServerInterceptor
	// Default Server Config
	DefaultConfig GRPCServerConfig
}

ServerConstructor holds fields to create an annotated gRPC Server.

func (ServerConstructor) Annotate 

func (constructor ServerConstructor) Annotate() fx.Option

Annotate creates an annotated instance of gRPC Server.

Source Files

View all Source files

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.