rpc

Documentation

Index

• func InitClient(ctx context.Context, log logger.Logger, tracer trace.TracerProvider, ...) (*grpc.ClientConn, func(), error)
• type Client
  • func SetClientConfig(tracer trace.TracerProvider, monitor *monitoring.Monitoring, log logger.Logger) (*Client, error)
  • func (c *Client) GetOptions() []grpc.DialOption
  • func (c *Client) GetURI() string
• type Server
  • func InitServer(ctx context.Context, log logger.Logger, tracer trace.TracerProvider, ...) (*Server, error)

Functions

func InitClient

func InitClient(ctx context.Context, log logger.Logger, tracer trace.TracerProvider, monitor *monitoring.Monitoring) (*grpc.ClientConn, func(), error)

InitClient - set up a connection to the server.

Types

type Client

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

func SetClientConfig

func SetClientConfig(tracer trace.TracerProvider, monitor *monitoring.Monitoring, log logger.Logger) (*Client, error)

setConfig - set configuration

func (*Client) GetOptions

func (c *Client) GetOptions() []grpc.DialOption

GetOptions - return options for gRPC Client.

func (*Client) GetURI

func (c *Client) GetURI() string

type Server

type Server struct {
	Run      func()
	Server   *grpc.Server
	Endpoint string
}

func InitServer

func InitServer(ctx context.Context, log logger.Logger, tracer trace.TracerProvider, monitor *monitoring.Monitoring) (*Server, error)

InitServer - initialize gRPC server