servers

Documentation

Overview

Package servers contains helper functions and types for dealing with gRPC servers and streams.

Index

• func Dial(ctx context.Context, target string, opts ...grpcOption) (*grpc.ClientConn, error)
• func NewServer(ctx context.Context, opts ...grpcOption) *grpc.Server
• func StartSpanFromServer(clientCtx context.Context, operationName string) (opentracing.Span, context.Context, error)
• func WithDialOpts(dialOptions ...grpc.DialOption) grpcOption
• func WithServerOpts(serverOptions ...grpc.ServerOption) grpcOption
• func WithTLS(tls bool) grpcOption
• type GRPCOptions
  • func (o *GRPCOptions) Apply(opts ...grpcOption)

Functions

func Dial

func Dial(
	ctx context.Context,
	target string,
	opts ...grpcOption,
) (*grpc.ClientConn, error)

func NewServer

func NewServer(ctx context.Context, opts ...grpcOption) *grpc.Server

func StartSpanFromServer

func StartSpanFromServer(
	clientCtx context.Context,
	operationName string,
) (opentracing.Span, context.Context, error)

func WithDialOpts

func WithDialOpts(dialOptions ...grpc.DialOption) grpcOption

func WithServerOpts

func WithServerOpts(serverOptions ...grpc.ServerOption) grpcOption

func WithTLS

func WithTLS(tls bool) grpcOption

Types

type GRPCOptions

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

func (*GRPCOptions) Apply

func (o *GRPCOptions) Apply(opts ...grpcOption)