grpc

Documentation

Index

• func GRPCContext(ctx context.Context) context.Context
• func InitClient(ctx context.Context, efs embed.FS, conf config.Conn) (conn *grpc.ClientConn, err error)
• func LogStreamClientInterceptor() grpc.StreamClientInterceptor
• func LogStreamServiceInterceptor() grpc.StreamServerInterceptor
• func LogUnaryClientInterceptor() grpc.UnaryClientInterceptor
• func LogUnaryServiceInterceptor() grpc.UnaryServerInterceptor
• func NewClient(ctx context.Context, conf config.GRPC, efs embed.FS) (conn *grpc.ClientConn, err error)
• func RegisterDNS(addr map[string][]string) (err error)
• type Server
  • func NewServer(ctx context.Context, conf config.GRPC, efs embed.FS) (svc *Server, err error)
  • func (s *Server) GracefulStop()
  • func (s *Server) Run(ctx context.Context, cancel func()) (err error)

Functions

func GRPCContext

func GRPCContext(ctx context.Context) context.Context

func InitClient

func InitClient(ctx context.Context, efs embed.FS, conf config.Conn) (conn *grpc.ClientConn, err error)

func LogStreamClientInterceptor

func LogStreamClientInterceptor() grpc.StreamClientInterceptor

func LogStreamServiceInterceptor

func LogStreamServiceInterceptor() grpc.StreamServerInterceptor

func LogUnaryClientInterceptor

func LogUnaryClientInterceptor() grpc.UnaryClientInterceptor

func LogUnaryServiceInterceptor

func LogUnaryServiceInterceptor() grpc.UnaryServerInterceptor

func NewClient

func NewClient(ctx context.Context, conf config.GRPC, efs embed.FS) (conn *grpc.ClientConn, err error)

func RegisterDNS

func RegisterDNS(addr map[string][]string) (err error)

Types

type Server

type Server struct {
	GRPC *grpc.Server
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context, conf config.GRPC, efs embed.FS) (svc *Server, err error)

func (*Server) GracefulStop

func (s *Server) GracefulStop()

func (*Server) Run

func (s *Server) Run(ctx context.Context, cancel func()) (err error)