grpcx

Documentation

Index

• Variables
• func DialogOptions(opts ...grpc.DialOption) []grpc.DialOption
• func ServerOptions(opts ...grpc.ServerOption) []grpc.ServerOption
• func StreamClientInterceptor(mdw ...grpc.StreamClientInterceptor) grpc.DialOption
• func StreamServerInterceptor(mdw ...grpc.StreamServerInterceptor) grpc.ServerOption
• func UnaryClientInterceptor(mdw ...grpc.UnaryClientInterceptor) grpc.DialOption
• func UnaryServerInterceptor(mdw ...grpc.UnaryServerInterceptor) grpc.ServerOption
• type ClientConfigs
• type ConsumerConfig
• type ServerConfig

Variables

var Provider = wire.NewSet()

Functions

func DialogOptions

func DialogOptions(opts ...grpc.DialOption) []grpc.DialOption

func ServerOptions

func ServerOptions(opts ...grpc.ServerOption) []grpc.ServerOption

func StreamClientInterceptor

func StreamClientInterceptor(mdw ...grpc.StreamClientInterceptor) grpc.DialOption

func StreamServerInterceptor

func StreamServerInterceptor(mdw ...grpc.StreamServerInterceptor) grpc.ServerOption

func UnaryClientInterceptor

func UnaryClientInterceptor(mdw ...grpc.UnaryClientInterceptor) grpc.DialOption

func UnaryServerInterceptor

func UnaryServerInterceptor(mdw ...grpc.UnaryServerInterceptor) grpc.ServerOption

Types

type ClientConfigs

type ClientConfigs map[string]*ConsumerConfig

type ConsumerConfig

type ConsumerConfig struct {
	Target string `mapstructure:"target" json:"target" yaml:"target"`
}

type ServerConfig

type ServerConfig struct {
	Port int `mapstructure:"port" json:"port" yaml:"port"`
}