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
Constants ¶
This section is empty.
Variables ¶
View Source
var ClientKeepalive = keepalive.ClientParameters{ Time: 10 * time.Second, Timeout: time.Second, PermitWithoutStream: true, }
View Source
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"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.