grpc

Documentation

Index

• Variables
• func NewClient(context context.Context, host string, logger *zap.Logger, ...) (*grpc.ClientConn, error)
• func NewServer(lc fx.Lifecycle, s fx.Shutdowner, cfg *config.Config, logger *zap.Logger, ...) *grpc.Server
• func StreamDialOption(logger *zap.Logger, interceptors ...grpc.StreamClientInterceptor) grpc.DialOption
• func StreamServerOption(logger *zap.Logger, interceptors ...grpc.StreamServerInterceptor) grpc.ServerOption
• func UnaryDialOption(logger *zap.Logger, interceptors ...grpc.UnaryClientInterceptor) grpc.DialOption
• func UnaryServerOption(logger *zap.Logger, interceptors ...grpc.UnaryServerInterceptor) grpc.ServerOption

Variables

var (
	// ServerModule for fx.
	ServerModule = fx.Provide(NewServer)

	// Module for fx.
	Module = fx.Options(ServerModule)
)

Functions

func NewClient

func NewClient(context context.Context, host string, logger *zap.Logger, opts ...grpc.DialOption) (*grpc.ClientConn, error)

NewClient to host for gRPC.

func NewServer

func NewServer(lc fx.Lifecycle, s fx.Shutdowner, cfg *config.Config, logger *zap.Logger, opts ...grpc.ServerOption) *grpc.Server

NewServer for gRPC.

func StreamDialOption

func StreamDialOption(logger *zap.Logger, interceptors ...grpc.StreamClientInterceptor) grpc.DialOption

StreamDialOption for gRPC.

func StreamServerOption

func StreamServerOption(logger *zap.Logger, interceptors ...grpc.StreamServerInterceptor) grpc.ServerOption

StreamServerOption for gRPC.

func UnaryDialOption

func UnaryDialOption(logger *zap.Logger, interceptors ...grpc.UnaryClientInterceptor) grpc.DialOption

UnaryDialOption for gRPC.

func UnaryServerOption

func UnaryServerOption(logger *zap.Logger, interceptors ...grpc.UnaryServerInterceptor) grpc.ServerOption

UnaryServerOption for gRPC.