grpc

Documentation

Overview

Package grpc provides basic gRPC functions.

Package grpc provides basic gRPC functions.

Package grpc provides basic gRPC functions.

Package grpc provides basic gRPC functions.

Package grpc provides basic gRPC functions.

Index

• type Client
  • func New(ctx context.Context, log *logger.Zerolog) *Client
  • func (c *Client) AddImport(path ...string)
  • func (c *Client) AddProtobuf(path ...string)
  • func (c *Client) CancelQuery()
  • func (c *Client) Close()
  • func (c *Client) CloseStream()
  • func (c *Client) Connect(addr string, opts ...ClientOpt) error
  • func (c *Client) GetResponseChannel() chan *entity.QueryResponse
  • func (c *Client) GetSentCounter() uint
  • func (c *Client) LoadFromProtobuf() ([]*entity.Service, []*entity.ProtobufError, *entity.ProtobufError)
  • func (c *Client) LoadFromReflection() ([]*entity.Service, error)
  • func (c *Client) Query(method *entity.Method, data map[string]interface{}, metadata []string)
  • func (c *Client) SetSettings(cfg *entity.Settings)
• type ClientOpt
  • func WithClientCertificate(cert string) ClientOpt
  • func WithClientKey(key string) ClientOpt
  • func WithInsecure() ClientOpt
  • func WithNoTLS() ClientOpt
  • func WithRootCertificate(cert string) ClientOpt
• type ClientOptions

Types

type Client

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

Client object capable of interacting with Client

func New

func New(ctx context.Context, log *logger.Zerolog) *Client

New creates a new Client

func (*Client) AddImport

func (c *Client) AddImport(path ...string)

AddImport adds import paths

func (*Client) AddProtobuf

func (c *Client) AddProtobuf(path ...string)

AddProtobuf adds protobuf files

func (*Client) CancelQuery

func (c *Client) CancelQuery()

CancelQuery aborting a running gRPC request

func (*Client) Close

func (c *Client) Close()

Close closes connection to gRPC server

func (*Client) CloseStream

func (c *Client) CloseStream()

CloseStream stops a running gRPC stream

func (*Client) Connect

func (c *Client) Connect(addr string, opts ...ClientOpt) error

Connect connecting to gRPC server

func (*Client) GetResponseChannel

func (c *Client) GetResponseChannel() chan *entity.QueryResponse

GetResponseChannel returns response channel

func (*Client) GetSentCounter

func (c *Client) GetSentCounter() uint

GetSentCounter returns sent messages counter

func (*Client) LoadFromProtobuf

func (c *Client) LoadFromProtobuf() ([]*entity.Service, []*entity.ProtobufError, *entity.ProtobufError)

LoadFromProtobuf loads services from protobuf

func (*Client) LoadFromReflection

func (c *Client) LoadFromReflection() ([]*entity.Service, error)

LoadFromReflection loads services using reflection

func (*Client) Query

func (c *Client) Query(method *entity.Method, data map[string]interface{}, metadata []string)

Query executes a gRPC request

func (*Client) SetSettings

func (c *Client) SetSettings(cfg *entity.Settings)

SetSettings sets application settings

type ClientOpt

type ClientOpt func(options *ClientOptions)

func WithClientCertificate

func WithClientCertificate(cert string) ClientOpt

WithClientCertificate returns ClientOpt which sets client certificate

func WithClientKey

func WithClientKey(key string) ClientOpt

WithClientKey returns ClientOpt which sets client certificate private key

func WithInsecure

func WithInsecure() ClientOpt

WithInsecure returns ClientOpt which disables server certificate chain verification and hostname

func WithNoTLS

func WithNoTLS() ClientOpt

WithNoTLS returns ClientOpt which disables transport security

func WithRootCertificate

func WithRootCertificate(cert string) ClientOpt

WithRootCertificate returns ClientOpt which sets server CA certificate

type ClientOptions

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

ClientOptions represents Client options