grpc

Documentation

Index

• type ClientConfig
• type ClientInterface
  • func NewClient(c *ClientConfig) (ClientInterface, error)
• type Config

Types

type ClientConfig

type ClientConfig struct {
	RequestTimeout time.Duration `mapstructure:"requestTimeout" validate:"gt=100ms"`
	Config         *Config       `mapstructure:"client" validate:"required"`
}

type ClientInterface

type ClientInterface interface {
	Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
	NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
	Close() error
}

func NewClient

func NewClient(c *ClientConfig) (ClientInterface, error)

type Config

type Config struct {
	TargetAddr     string        `mapstructure:"targetAddr" validate:"required"`
	RequestTimeout time.Duration `mapstructure:"requestTimeout" validate:"gt=100ms"`
	TLS            bool          `mapstructure:"tls"`
	TLSSkipVerify  bool          `mapstructure:"tlsSkipverify"`
}