grpcsrv

package
v0.1.16 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 27, 2024 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ListenAndServe

func ListenAndServe(s *grpc.Server, bind string) error

func NewGrpcServer

func NewGrpcServer(excludePath []string, auth grpcauth.AuthFunc) *grpc.Server

func StdRegister

func StdRegister(s *grpc.Server)

StdRegister registers reflection and prometheus services.

func StdStreamMiddleware

func StdStreamMiddleware(interceptors ...grpc.StreamServerInterceptor) grpc.ServerOption

func StdUnaryMiddleware

func StdUnaryMiddleware(interceptors ...grpc.UnaryServerInterceptor) grpc.ServerOption

func StreamReflectionFilter

func StreamReflectionFilter(exclude []string, in grpc.StreamServerInterceptor) grpc.StreamServerInterceptor

func UnaryReflectionFilter

func UnaryReflectionFilter(exclude []string, in grpc.UnaryServerInterceptor) grpc.UnaryServerInterceptor

Types

type Auth

type Auth struct {
}

func NewAuthInterceptor

func NewAuthInterceptor() *Auth

func (*Auth) AuthAndIdentifyTickerFunc

func (a *Auth) AuthAndIdentifyTickerFunc(ctx context.Context) (context.Context, error)

todo: implement auth here

type GrpcServerWorker

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

func NewGrpcServerWorker

func NewGrpcServerWorker(name string, grpcServer *grpc.Server, bind string) *GrpcServerWorker

func (*GrpcServerWorker) Start

func (g *GrpcServerWorker) Start() error

func (*GrpcServerWorker) Stop

func (g *GrpcServerWorker) Stop() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL