Documentation
¶
Index ¶
- type Client
- func (t *Client) Get() (r result.Result[grpc.ClientConnInterface])
- func (t *Client) Healthy(ctx context.Context) error
- func (t *Client) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) (err error)
- func (t *Client) Middleware(mm ...service.Middleware)
- func (t *Client) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
- type Interface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) Get ¶
func (t *Client) Get() (r result.Result[grpc.ClientConnInterface])
Get new grpc Client
func (*Client) Middleware ¶
func (t *Client) Middleware(mm ...service.Middleware)
func (*Client) NewStream ¶
func (t *Client) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type Interface ¶
type Interface interface {
grpc.ClientConnInterface
Healthy(ctx context.Context) error
Middleware(mm ...service.Middleware)
}
Interface grpc client interface
Click to show internal directories.
Click to hide internal directories.