rpc

Documentation

Index

• Variables
• func AuthUnaryServerInterceptor(verifier token.Verifier) grpc.UnaryServerInterceptor
• func GetAccessToken(ctx context.Context) (*token.AccessToken, bool)
• func LogUnaryServerInterceptor(logger *zap.Logger) grpc.UnaryServerInterceptor
• func MetricsUnaryServerInterceptor() grpc.UnaryServerInterceptor
• type Option
  • func WithHandler(path string, handler http.Handler) Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithMetrics(registerer metrics.Registerer) Option
  • func WithPort(port int) Option
  • func WithService(service Service) Option
  • func WithVerifier(verifier token.Verifier) Option
• type Server
  • func NewServer(service Service, certPath, keyPath, serverName string, opt ...Option) *Server
  • func (s *Server) Run()
  • func (s *Server) Stop(timeout time.Duration)
• type Service

Variables

var Key = tokenKey{}

Functions

func AuthUnaryServerInterceptor

func AuthUnaryServerInterceptor(verifier token.Verifier) grpc.UnaryServerInterceptor

func GetAccessToken

func GetAccessToken(ctx context.Context) (*token.AccessToken, bool)

func LogUnaryServerInterceptor

func LogUnaryServerInterceptor(logger *zap.Logger) grpc.UnaryServerInterceptor

func MetricsUnaryServerInterceptor

func MetricsUnaryServerInterceptor() grpc.UnaryServerInterceptor

Types

type Option

type Option func(*Server)

func WithHandler

func WithHandler(path string, handler http.Handler) Option

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithMetrics

func WithMetrics(registerer metrics.Registerer) Option

func WithPort

func WithPort(port int) Option

func WithService

func WithService(service Service) Option

func WithVerifier

func WithVerifier(verifier token.Verifier) Option

type Server

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

func NewServer

func NewServer(service Service, certPath, keyPath, serverName string, opt ...Option) *Server

func (*Server) Run

func (s *Server) Run()

func (*Server) Stop

func (s *Server) Stop(timeout time.Duration)

type Service

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