grpcServer

Documentation

Index

• type GRPCServer
  • func Start(cfgFile string, ctx context.Context) (*GRPCServer, error)
  • func (r *GRPCServer) Stop()
  • func (r *GRPCServer) StreamServerInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (r *GRPCServer) UnaryServerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

Types

type GRPCServer

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

func Start

func Start(cfgFile string, ctx context.Context) (*GRPCServer, error)

func (*GRPCServer) Stop

func (r *GRPCServer) Stop()

func (*GRPCServer) StreamServerInterceptor

func (r *GRPCServer) StreamServerInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

StreamServerInterceptor is a gRPC server-side interceptor that provides Prometheus monitoring for Streaming RPCs.

func (*GRPCServer) UnaryServerInterceptor

func (r *GRPCServer) UnaryServerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)