grpcx

Documentation

Index

• func StreamServerCommonOpts(ctx context.Context, statsTagsFns ...TagsFunc) []grpc.ServerOption
• func UnaryServerCommonOpts(ctx context.Context, statsTagsFns ...TagsFunc) []grpc.ServerOption
• func WithHandlers(handlers ...grpcstats.Handler) grpcstats.Handler
• func WithRPCStats(stats stats.Stats, tagsFns ...TagsFunc) grpcstats.Handler
• type Server
  • func NewServer(listener net.Listener, srv *grpc.Server) *Server
  • func (s *Server) Close() error
  • func (s *Server) Serve() error
• type TagsFunc

Functions

func StreamServerCommonOpts

func StreamServerCommonOpts(ctx context.Context, statsTagsFns ...TagsFunc) []grpc.ServerOption

StreamServerCommonOpts returns commonly options for a stream server.

func UnaryServerCommonOpts

func UnaryServerCommonOpts(ctx context.Context, statsTagsFns ...TagsFunc) []grpc.ServerOption

UnaryServerCommonOpts returns commonly options for an unary server.

func WithHandlers

func WithHandlers(handlers ...grpcstats.Handler) grpcstats.Handler

WithHandlers returns an aggregated stats handler. All inner handlers are called in order.

func WithRPCStats

func WithRPCStats(stats stats.Stats, tagsFns ...TagsFunc) grpcstats.Handler

WithRPCStats returns a handler that collects and tags RPC stats.

Types

type Server

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

Server represents a GRPC server.

func NewServer

func NewServer(listener net.Listener, srv *grpc.Server) *Server

NewServer creates a new Server instance.

func (*Server) Close

func (s *Server) Close() error

Close closes the listener and frees occupied port.

func (*Server) Serve

func (s *Server) Serve() error

Serve listens for incoming connections and serves RPC responses.

type TagsFunc

type TagsFunc func(ctx context.Context, payload interface{}) stats.Tags

TagsFunc represents a function that returns a set of tags for the stats. The payload is the incoming message object.