grpc

Dec 2, 2022

Changes in this version

type Client

+ func (c *Client) CloseStream()

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

+ func (c *Client) GetSentCounter() uint

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

Nov 16, 2022

Changes in this version

+ type Client struct

+ func New(ctx context.Context, cfg *entity.GrpcConfig) *Client

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

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

+ func (c *Client) CancelQuery()

+ func (c *Client) Close()

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

+ 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{}, requestMetadata []string) (qResp *entity.QueryResponse, err error)

+ type ClientOpt func(options *ClientOptions)

+ func WithClientCertificate(cert string) ClientOpt

+ func WithClientKey(key string) ClientOpt

+ func WithInsecure() ClientOpt

+ func WithNoTLS() ClientOpt

+ func WithRootCertificate(cert string) ClientOpt

+ type ClientOptions struct