grpc

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 9, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package grpc provides grpc client functions

Package grpc provides grpc client functions

Package grpc provides grpc client functions

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client interface {
	client.Client
	client.ObjectReader
	client.Indexer
}

func New 

func New(ctx context.Context, opts ...Option) (Client, error)

type Option 

type Option func(*ngtdClient)

func WithAddr 

func WithAddr(addr string) Option

func WithGRPCClientOption 

func WithGRPCClientOption(opts ...grpc.Option) Option

type StreamInsert added in v1.0.0 

type StreamInsert vald.Insert_StreamInsertClient

func NewStreamInsertClient added in v1.0.0 

func NewStreamInsertClient(ngtd proto.NGTD_StreamInsertClient) StreamInsert

type StreamObject added in v1.0.0 

type StreamObject vald.Object_StreamGetObjectClient

func NewStreamObjectClient added in v1.0.0 

func NewStreamObjectClient(ngtd proto.NGTD_StreamGetObjectClient) StreamObject

type StreamRemove added in v1.0.0 

type StreamRemove vald.Remove_StreamRemoveClient

func NewStreamRemoveClient added in v1.0.0 

func NewStreamRemoveClient(ngtd proto.NGTD_StreamRemoveClient) StreamRemove

type StreamSearch added in v1.0.0 

type StreamSearch vald.Search_StreamSearchClient

func NewStreamSearchClient added in v1.0.0 

func NewStreamSearchClient(ngtd proto.NGTD_StreamSearchClient) StreamSearch

type StreamSearchByID added in v1.0.0 

type StreamSearchByID vald.Search_StreamSearchByIDClient

func NewStreamSearchByIDClient added in v1.0.0 

func NewStreamSearchByIDClient(ngtd proto.NGTD_StreamSearchByIDClient) StreamSearchByID

type StreamUpdate added in v1.0.0 

type StreamUpdate vald.Update_StreamUpdateClient

func NewStreamUpdateClient added in v1.0.0 

func NewStreamUpdateClient(ic proto.NGTD_StreamInsertClient, rc proto.NGTD_StreamRemoveClient) StreamUpdate

type StreamUpsert added in v1.0.0 

type StreamUpsert vald.Upsert_StreamUpsertClient

func NewStreamUpsertClient added in v1.0.0 

func NewStreamUpsertClient(c Client, ic proto.NGTD_StreamInsertClient) StreamUpsert

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.