clienttoolset

Documentation

Index

• func DialGRPC(cfg *GRPCClientConfig, opts []grpc.DialOption) (*grpc.ClientConn, error)
• func DialGRPCEx(ctx context.Context, cfg *GRPCClientConfig, opts []grpc.DialOption) (*grpc.ClientConn, error)
• func DialGRpcServerByName(schema, serverName string, cfg *GRPCClientConfig, opts []grpc.DialOption) (*grpc.ClientConn, error)
• func RegisterSchemas(_ context.Context, cfg *RegisterSchemasConfig, logger l.Wrapper) error
• type GRPCClientConfig
• type RegisterSchemasConfig

Functions

func DialGRPC

func DialGRPC(cfg *GRPCClientConfig, opts []grpc.DialOption) (*grpc.ClientConn, error)

func DialGRPCEx

func DialGRPCEx(ctx context.Context, cfg *GRPCClientConfig, opts []grpc.DialOption) (*grpc.ClientConn, error)

func DialGRpcServerByName

func DialGRpcServerByName(schema, serverName string, cfg *GRPCClientConfig, opts []grpc.DialOption) (*grpc.ClientConn, error)

func RegisterSchemas

func RegisterSchemas(_ context.Context, cfg *RegisterSchemasConfig, logger l.Wrapper) error

Types

type GRPCClientConfig

type GRPCClientConfig struct {
	Target        string                        `yaml:"target" json:"target"`
	TLSConfig     *servicetoolset.GRPCTlsConfig `yaml:"tls_config" json:"tls_config"`
	MetaTransKeys []string                      `json:"-" yaml:"-" ignored:"true"`

	KeepAliveTime    time.Duration `json:"keep_alive_time" yaml:"keep_alive_time"`
	KeepAliveTimeout time.Duration `json:"keep_alive_timeout" yaml:"keep_alive_timeout"`
}

type RegisterSchemasConfig

type RegisterSchemasConfig struct {
	Getter  discovery.Getter `json:"-" yaml:"-" ignored:"true"`
	Schemas []string         `yaml:"schemas" json:"schemas"`
}