grpcserver

Documentation

Index

• func New(opts ...ServerOption) (server.IServer, error)
• type Server
  • func (s *Server) Run() error
• type ServerOption
  • func WithServerHealthServer(healthServer grpc_health_v1.HealthServer) ServerOption
  • func WithServerOptionOnStart(onStart func()) ServerOption
  • func WithServerOptionOnStop(onStop func()) ServerOption
  • func WithServerOptionPost(post int) ServerOption
  • func WithServerOptionSignal(signals []os.Signal) ServerOption
  • func WithServerOptionTimeout(timeout time.Duration) ServerOption
  • func WithServerRegisterServer(registerServer func(server *grpc.Server)) ServerOption
  • func WithServerServerOptions(serverOptions []grpc.ServerOption) ServerOption
  • func WithServerStreamServerInterceptors(streamServerInterceptors []grpc.StreamServerInterceptor) ServerOption
  • func WithServerUnaryServerInterceptors(unaryServerInterceptors []grpc.UnaryServerInterceptor) ServerOption

Functions

func New

func New(opts ...ServerOption) (server.IServer, error)

Types

type Server

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

func (*Server) Run

func (s *Server) Run() error

type ServerOption

type ServerOption func(s *Server)

func WithServerHealthServer

func WithServerHealthServer(healthServer grpc_health_v1.HealthServer) ServerOption

func WithServerOptionOnStart

func WithServerOptionOnStart(onStart func()) ServerOption

func WithServerOptionOnStop

func WithServerOptionOnStop(onStop func()) ServerOption

func WithServerOptionPost

func WithServerOptionPost(post int) ServerOption

func WithServerOptionSignal

func WithServerOptionSignal(signals []os.Signal) ServerOption

func WithServerOptionTimeout

func WithServerOptionTimeout(timeout time.Duration) ServerOption

func WithServerRegisterServer

func WithServerRegisterServer(registerServer func(server *grpc.Server)) ServerOption

func WithServerServerOptions

func WithServerServerOptions(serverOptions []grpc.ServerOption) ServerOption

func WithServerStreamServerInterceptors

func WithServerStreamServerInterceptors(streamServerInterceptors []grpc.StreamServerInterceptor) ServerOption

func WithServerUnaryServerInterceptors

func WithServerUnaryServerInterceptors(unaryServerInterceptors []grpc.UnaryServerInterceptor) ServerOption