factory

Documentation

Index

• func ListenAndServe(r Registrator, setters ...Option) (err error)
• func NewListener(setters ...Option) (net.Listener, error)
• func NewServer(r Registrator, setters ...Option) *grpc.Server
• type Option
  • func Config(o *tls.Config) Option
  • func Network(o string) Option
  • func Port(o int) Option
  • func ServerOptions(o ...grpc.ServerOption) Option
  • func SocketPath(o string) Option
  • func WithDefaultLog() Option
  • func WithLog(prefix string, w io.Writer) Option
  • func WithReflection() Option
  • func WithStreamInterceptor(i grpc.StreamServerInterceptor) Option
  • func WithUnaryInterceptor(i grpc.UnaryServerInterceptor) Option
• type Options
  • func NewDefaultOptions(setters ...Option) *Options
• type Registrator

Functions

func ListenAndServe

func ListenAndServe(r Registrator, setters ...Option) (err error)

ListenAndServe configures TLS for mutual authentication by loading the CA into a CertPool and configuring the server's policy for TLS Client Authentication. Once TLS is configured, the gRPC options are built to make use of the TLS configuration and the receiver (Server) is registered to the gRPC server. Finally the gRPC server is started.

func NewListener

func NewListener(setters ...Option) (net.Listener, error)

NewListener builds listener for grpc server.

func NewServer

func NewServer(r Registrator, setters ...Option) *grpc.Server

NewServer builds grpc server and binds it to the Registrator.

Types

type Option

type Option func(*Options)

Option is the functional option func.

func Config

func Config(o *tls.Config) Option

Config sets the listen port of the server.

func Network

func Network(o string) Option

Network sets the network type of the listener.

func Port

func Port(o int) Option

Port sets the listen port of the server.

func ServerOptions

func ServerOptions(o ...grpc.ServerOption) Option

ServerOptions appends to the gRPC server options of the server.

func SocketPath

func SocketPath(o string) Option

SocketPath sets the listen unix file socket path of the server.

func WithDefaultLog

func WithDefaultLog() Option

WithDefaultLog sets up request logging to default destination.

func WithLog

func WithLog(prefix string, w io.Writer) Option

WithLog sets up request logging to specified destination.

func WithReflection

func WithReflection() Option

WithReflection enables gRPC reflection APIs: https://github.com/grpc/grpc/blob/master/doc/server-reflection.md

func WithStreamInterceptor

func WithStreamInterceptor(i grpc.StreamServerInterceptor) Option

WithStreamInterceptor appends to the list of gRPC server stream interceptors.

func WithUnaryInterceptor

func WithUnaryInterceptor(i grpc.UnaryServerInterceptor) Option

WithUnaryInterceptor appends to the list of gRPC server unary interceptors.

type Options

type Options struct {
	Port               int
	SocketPath         string
	Network            string
	Config             *tls.Config
	ServerOptions      []grpc.ServerOption
	UnaryInterceptors  []grpc.UnaryServerInterceptor
	StreamInterceptors []grpc.StreamServerInterceptor
	LogPrefix          string
	LogDestination     io.Writer
	Reflection         bool
}

Options is the functional options struct.

func NewDefaultOptions

func NewDefaultOptions(setters ...Option) *Options

NewDefaultOptions initializes the Options struct with default values.

type Registrator

type Registrator interface {
	Register(*grpc.Server)
}

Registrator describes the set of methods required in order for a concrete type to be used with the Listen function.