rpc

Documentation

Index

• type Server
  • func New(tlsConfig *tls.Config, logger logger.Logger) Server
  • func NewFromConfig(config *config.Grpc, tlsConfig *tls.Config, logger logger.Logger) Server
  • func NewWithOverrides(network, address string, enforcement *keepalive.EnforcementPolicy, ...) Server

Types

type Server

type Server interface {
	grpc.ServiceRegistrar

	Address() string

	OnStart(callback func())
	OnStop(callback func())
	OnError(callback func(err error))

	Start(ctx context.Context, wg *sync.WaitGroup)
	Stop()
	Shutdown()
}

func New

func New(tlsConfig *tls.Config, logger logger.Logger) Server

func NewFromConfig

func NewFromConfig(config *config.Grpc, tlsConfig *tls.Config, logger logger.Logger) Server

func NewWithOverrides

func NewWithOverrides(network, address string,
	enforcement *keepalive.EnforcementPolicy,
	keepAliveTimeouts *keepalive.ServerParameters,
	tlsConfig *tls.Config,
	logger logger.Logger) Server