grpcc

Apr 29, 2024

Changes in this version

type Client

+ Healthy func(ctx context.Context) error

+ type Config = grpcc_config.Cfg

+ type Params struct

+ Log log.Logger

+ Metric metrics.Metric

+ Resolvers []resolver.Builder

May 1, 2022

Changes in this version

+ func WithDial(fn func(srv string, cfg grpcc_config.Cfg) (grpc.ClientConnInterface, error)) func(cli *Client)

+ type Option func(cli *Client)

Apr 3, 2022

Changes in this version

type Cfg

+ Addr string

+ Name string

Mar 31, 2022

Changes in this version

+ func InitClient(srv string, opts ...func(cfg *Cfg))

+ func WithAfterDial(fn func()) func(cfg *Cfg)

+ func WithBeforeDial(fn func()) func(cfg *Cfg)

+ func WithClientType(typ interface{}) func(cfg *Cfg)

+ func WithDirect() func(cfg *Cfg)

+ func WithDiscov() func(cfg *Cfg)

+ func WithDns() func(cfg *Cfg)

+ func WithK8s() func(cfg *Cfg)

+ func WithNewClientFunc(fn func(cc grpc.ClientConnInterface) interface{}) func(cfg *Cfg)

+ func WithRegistry(name string) func(cfg *Cfg)

type Cfg

+ Group string

+ Service string

+ func (t Cfg) Check() error

+ func (t Cfg) GetReg() string

type Client

+ func New(service string, opts ...func(cfg *Cfg)) *Client

+ func NewClient(service string, cfg Cfg) *Client

Nov 14, 2021

Changes in this version

+ const DefaultTimeout

+ const Name

+ func HealthCheck(srv string, conn *grpc.ClientConn) error

+ func NewDirect(addr string, opts ...func(cfg *Cfg)) (*grpc.ClientConn, error)

+ type Cfg struct

+ Authority string

+ BackoffMaxDelay time.Duration

+ Balancer string

+ BalancerName string

+ Block bool

+ Call callParameters

+ ChannelzParentID int64

+ ClientParameters clientParameters

+ Codec string

+ Compressor string

+ ConnWindowSize int32

+ ConnectParams connectParams

+ Decompressor string

+ DefaultServiceConfig string

+ DialOptions []grpc.DialOption

+ DialTimeout time.Duration

+ DisableHealthCheck bool

+ DisableRetry bool

+ DisableServiceConfig bool

+ IdleNum uint32

+ Insecure bool

+ MaxDelay time.Duration

+ MaxHeaderListSize uint32

+ MaxMsgSize int

+ MaxRecvMsgSize int

+ Middlewares []string

+ NoProxy bool

+ Proxy bool

+ ReadBuffer int

+ Registry string

+ StreamInterceptors []grpc.StreamClientInterceptor

+ Timeout time.Duration

+ UnaryInterceptors []grpc.UnaryClientInterceptor

+ UserAgent string

+ WindowSize int32

+ WriteBuffer int

+ func DefaultCfg(opts ...func(cfg *Cfg)) *Cfg

+ func (t Cfg) Build(target string) (conn *grpc.ClientConn, gErr error)

+ func (t Cfg) BuildDirect(target string) (conn *grpc.ClientConn, gErr error)

+ func (t Cfg) ToOpts() []grpc.DialOption

+ type Client struct

+ func GetClient(service string, opts ...func(cfg *Cfg)) *Client

+ func (t *Client) CheckHealth(opts ...grpc.CallOption) (*grpc_health_v1.HealthCheckResponse, error)

+ func (t *Client) Close() error

+ func (t *Client) Get() (_ grpc.ClientConnInterface, err error)

+ func (t *Client) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error

+ func (t *Client) Kind() string

+ func (t *Client) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)

+ func (t *Client) UpdateResObj(val interface{})

+ func (t *Client) Watch(ctx context.Context, in *grpc_health_v1.HealthCheckRequest, ...) (grpc_health_v1.Health_WatchClient, error)