grpc

Documentation

Index

• func NewClient(context context.Context, host string, params *ClientParams, ...) (*grpc.ClientConn, error)
• func NewServer(lc fx.Lifecycle, s fx.Shutdowner, params ServerParams, ...) *grpc.Server
• func StreamServerInterceptor() []grpc.StreamServerInterceptor
• func UnaryServerInterceptor() []grpc.UnaryServerInterceptor
• type ClientParams
• type Config
  • func NewConfig() (*Config, error)
• type ServerParams

Functions

func NewClient

func NewClient(context context.Context, host string, params *ClientParams, opts ...grpc.DialOption) (*grpc.ClientConn, error)

NewClient to host for gRPC.

func NewServer

func NewServer(lc fx.Lifecycle, s fx.Shutdowner, params ServerParams, opts ...grpc.ServerOption) *grpc.Server

NewServer for gRPC.

func StreamServerInterceptor

func StreamServerInterceptor() []grpc.StreamServerInterceptor

StreamServerInterceptor for gRPC.

func UnaryServerInterceptor

func UnaryServerInterceptor() []grpc.UnaryServerInterceptor

UnaryServerInterceptor for gRPC.

Types

type ClientParams

type ClientParams struct {
	Logger *zap.Logger
	Unary  []grpc.UnaryClientInterceptor
	Stream []grpc.StreamClientInterceptor
}

ClientParams for gRPC.

type Config

type Config struct {
	Port string `envconfig:"GRPC_PORT" required:"true" default:"9090"`
}

Config for gRPC.

func NewConfig

func NewConfig() (*Config, error)

NewConfig for gRPC.

type ServerParams

type ServerParams struct {
	fx.In

	Config *Config
	Logger *zap.Logger
	Unary  []grpc.UnaryServerInterceptor
	Stream []grpc.StreamServerInterceptor
}

ServerParams for gRPC.