grpc

Documentation

Index

• func NewClient(client v1.ServiceClient, cfg *client.Config, tracer opentracing.Tracer, ...) task.Task
• func NewClientConn(lc fx.Lifecycle, params ClientConnParams) (*grpc.ClientConn, error)
• func Register(lc fx.Lifecycle, params RegisterParams)
• type Client
  • func (c *Client) Perform(ctx context.Context) error
• type ClientConnParams
• type RegisterParams

Functions

func NewClient

func NewClient(client v1.ServiceClient, cfg *client.Config, tracer opentracing.Tracer, logger *zap.Logger) task.Task

NewClient for gRPC.

func NewClientConn

func NewClientConn(lc fx.Lifecycle, params ClientConnParams) (*grpc.ClientConn, error)

NewClientConn for gRPC.

func Register

func Register(lc fx.Lifecycle, params RegisterParams)

Register client.

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client for v1.

func (*Client) Perform

func (c *Client) Perform(ctx context.Context) error

Perform getting config.

type ClientConnParams

type ClientConnParams struct {
	fx.In

	Config *sgrpc.Config
	Logger *zap.Logger
	Tracer opentracing.Tracer
	Client *client.Config
}

ClientConnParams for gRPC.

type RegisterParams

type RegisterParams struct {
	fx.In

	Conn   *grpc.ClientConn
	Logger *zap.Logger
	Tracer opentracing.Tracer
	Client *client.Config
}

RegisterParams for gRPC.