grpc

Documentation

Index

• func NewServer(options ...Option) tfx.Server
• type Config
• type Option
  • func Address(addr string) Option
  • func EnableHealthCheck() Option
  • func EnableRecovery() Option
  • func EnableValidate() Option
  • func FromConfig(c *Config) Option
  • func MaxConcurrentStreams(maxConcurrentStreams uint32) Option
  • func Metrics(port int) Option
• type Server
  • func (app *Server) Provide() fx.Option
  • func (app *Server) RegisterService(constructors ...any)
• type Service

Functions

func NewServer

func NewServer(options ...Option) tfx.Server

Types

type Config

type Config struct {
	Port                 int
	EnableHealthCheck    bool
	EnableValidate       bool
	EnableRecovery       bool
	MaxConcurrentStreams uint32
	Metrics              *struct {
		Port int
	}
}

type Option

type Option func(o *grpcOptions)

func Address

func Address(addr string) Option

func EnableHealthCheck

func EnableHealthCheck() Option

func EnableRecovery

func EnableRecovery() Option

func EnableValidate

func EnableValidate() Option

func FromConfig

func FromConfig(c *Config) Option

func MaxConcurrentStreams

func MaxConcurrentStreams(maxConcurrentStreams uint32) Option

func Metrics

func Metrics(port int) Option

type Server

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

func (*Server) Provide

func (app *Server) Provide() fx.Option

func (*Server) RegisterService

func (app *Server) RegisterService(constructors ...any)

type Service

type Service interface {
	Register(srv *grpc.Server)
}