grpcsrv

README

GRPC Server

The package core/workers/grpcsrv provides a default set of configuration for hosting a grpc server in a service.

Configuration

The GRPC server can be configured through these environment variables:

• GRPC_ADDR the gRPC server listener's network address (default: 0.0.0.0:50051)

Examples

Starting server and exposing the service

srv := grpcsrv.New(&grpcsrv.Config{
    Addr: ":8080",
},
    grpc.StreamInterceptor(paginationmw.StreamServerInterceptor),
    grpc.UnaryInterceptor(paginationmw.UnaryServerInterceptor),
)
srv.Run(ctx)

Documentation

Overview

Package grpcsrv provides a default set of configuration for hosting a grpc server in a service.

Index

• Constants
• type Config
• type Server
  • func New(config *Config, options ...grpc.ServerOption) *Server
  • func (gs *Server) Addr() *net.TCPAddr
  • func (gs *Server) Halt(ctx context.Context) error
  • func (gs *Server) Run(ctx context.Context) error

Constants

const (
	// Port is the default gRPC port used in examples.
	Port = 50051
)

Types

type Config

type Config struct {
	Addr string
}

Config represents configuration for the GRPC server.

type Server

type Server struct {
	Connection *grpc.Server
	Now        func() time.Time
	// contains filtered or unexported fields
}

Server represents a collection of functions for starting and running an RPC server.

func New

func New(config *Config, options ...grpc.ServerOption) *Server

New sets up a new grpc server.

func (*Server) Addr

func (gs *Server) Addr() *net.TCPAddr

Addr will block until you have received an address for your server.

func (*Server) Halt

func (gs *Server) Halt(ctx context.Context) error

Halt will attempt to gracefully shut down the server.

func (*Server) Run

func (gs *Server) Run(ctx context.Context) error

Run will start the gRPC server and listen for requests.