vald

package
v1.0.5 Latest Latest
Warning

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

 Go to latest Published: Apr 6, 2021 License: Apache-2.0 Imports: 11 Imported by: 6

Documentation

Overview

Package vald provides vald server interface

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterFilterServer 

func RegisterFilterServer(s *grpc.Server, srv FilterServer)

func RegisterInsertServer 

func RegisterInsertServer(s *grpc.Server, srv InsertServer)

func RegisterObjectServer 

func RegisterObjectServer(s *grpc.Server, srv ObjectServer)

func RegisterRemoveServer 

func RegisterRemoveServer(s *grpc.Server, srv RemoveServer)

func RegisterSearchServer 

func RegisterSearchServer(s *grpc.Server, srv SearchServer)

func RegisterUpdateServer 

func RegisterUpdateServer(s *grpc.Server, srv UpdateServer)

func RegisterUpsertServer 

func RegisterUpsertServer(s *grpc.Server, srv UpsertServer)

func RegisterValdServer 

func RegisterValdServer(s *grpc.Server, srv Server)

func RegisterValdServerWithFilter 

func RegisterValdServerWithFilter(s *grpc.Server, srv ServerWithFilter)

Types

type Client 

type Client interface {
	InsertClient
	UpdateClient
	UpsertClient
	SearchClient
	RemoveClient
	ObjectClient
}

func NewValdClient 

func NewValdClient(conn *grpc.ClientConn) Client

type ClientWithFilter 

type ClientWithFilter interface {
	Client
	FilterClient
}

type FilterClient 

type FilterClient interface {
	SearchObject(ctx context.Context, in *payload.Search_ObjectRequest, opts ...grpc.CallOption) (*payload.Search_Response, error)
	MultiSearchObject(ctx context.Context, in *payload.Search_MultiObjectRequest, opts ...grpc.CallOption) (*payload.Search_Responses, error)
	StreamSearchObject(ctx context.Context, opts ...grpc.CallOption) (Filter_StreamSearchObjectClient, error)
	InsertObject(ctx context.Context, in *payload.Insert_ObjectRequest, opts ...grpc.CallOption) (*payload.Object_Location, error)
	StreamInsertObject(ctx context.Context, opts ...grpc.CallOption) (Filter_StreamInsertObjectClient, error)
	MultiInsertObject(ctx context.Context, in *payload.Insert_MultiObjectRequest, opts ...grpc.CallOption) (*payload.Object_Locations, error)
	UpdateObject(ctx context.Context, in *payload.Update_ObjectRequest, opts ...grpc.CallOption) (*payload.Object_Location, error)
	StreamUpdateObject(ctx context.Context, opts ...grpc.CallOption) (Filter_StreamUpdateObjectClient, error)
	MultiUpdateObject(ctx context.Context, in *payload.Update_MultiObjectRequest, opts ...grpc.CallOption) (*payload.Object_Locations, error)
	UpsertObject(ctx context.Context, in *payload.Upsert_ObjectRequest, opts ...grpc.CallOption) (*payload.Object_Location, error)
	StreamUpsertObject(ctx context.Context, opts ...grpc.CallOption) (Filter_StreamUpsertObjectClient, error)
	MultiUpsertObject(ctx context.Context, in *payload.Upsert_MultiObjectRequest, opts ...grpc.CallOption) (*payload.Object_Locations, error)
}

FilterClient is the client API for Filter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFilterClient 

func NewFilterClient(cc *grpc.ClientConn) FilterClient

type FilterServer 

type FilterServer interface {
	SearchObject(context.Context, *payload.Search_ObjectRequest) (*payload.Search_Response, error)
	MultiSearchObject(context.Context, *payload.Search_MultiObjectRequest) (*payload.Search_Responses, error)
	StreamSearchObject(Filter_StreamSearchObjectServer) error
	InsertObject(context.Context, *payload.Insert_ObjectRequest) (*payload.Object_Location, error)
	StreamInsertObject(Filter_StreamInsertObjectServer) error
	MultiInsertObject(context.Context, *payload.Insert_MultiObjectRequest) (*payload.Object_Locations, error)
	UpdateObject(context.Context, *payload.Update_ObjectRequest) (*payload.Object_Location, error)
	StreamUpdateObject(Filter_StreamUpdateObjectServer) error
	MultiUpdateObject(context.Context, *payload.Update_MultiObjectRequest) (*payload.Object_Locations, error)
	UpsertObject(context.Context, *payload.Upsert_ObjectRequest) (*payload.Object_Location, error)
	StreamUpsertObject(Filter_StreamUpsertObjectServer) error
	MultiUpsertObject(context.Context, *payload.Upsert_MultiObjectRequest) (*payload.Object_Locations, error)
}

FilterServer is the server API for Filter service.

type Filter_StreamInsertObjectClient 

type Filter_StreamInsertObjectClient interface {
	Send(*payload.Insert_ObjectRequest) error
	Recv() (*payload.Object_StreamLocation, error)
	grpc.ClientStream
}

type Filter_StreamInsertObjectServer 

type Filter_StreamInsertObjectServer interface {
	Send(*payload.Object_StreamLocation) error
	Recv() (*payload.Insert_ObjectRequest, error)
	grpc.ServerStream
}

type Filter_StreamSearchObjectClient 

type Filter_StreamSearchObjectClient interface {
	Send(*payload.Search_ObjectRequest) error
	Recv() (*payload.Search_StreamResponse, error)
	grpc.ClientStream
}

type Filter_StreamSearchObjectServer 

type Filter_StreamSearchObjectServer interface {
	Send(*payload.Search_StreamResponse) error
	Recv() (*payload.Search_ObjectRequest, error)
	grpc.ServerStream
}

type Filter_StreamUpdateObjectClient 

type Filter_StreamUpdateObjectClient interface {
	Send(*payload.Update_ObjectRequest) error
	Recv() (*payload.Object_StreamLocation, error)
	grpc.ClientStream
}

type Filter_StreamUpdateObjectServer 

type Filter_StreamUpdateObjectServer interface {
	Send(*payload.Object_StreamLocation) error
	Recv() (*payload.Update_ObjectRequest, error)
	grpc.ServerStream
}

type Filter_StreamUpsertObjectClient 

type Filter_StreamUpsertObjectClient interface {
	Send(*payload.Upsert_ObjectRequest) error
	Recv() (*payload.Object_StreamLocation, error)
	grpc.ClientStream
}

type Filter_StreamUpsertObjectServer 

type Filter_StreamUpsertObjectServer interface {
	Send(*payload.Object_StreamLocation) error
	Recv() (*payload.Upsert_ObjectRequest, error)
	grpc.ServerStream
}

type InsertClient 

type InsertClient interface {
	Insert(ctx context.Context, in *payload.Insert_Request, opts ...grpc.CallOption) (*payload.Object_Location, error)
	StreamInsert(ctx context.Context, opts ...grpc.CallOption) (Insert_StreamInsertClient, error)
	MultiInsert(ctx context.Context, in *payload.Insert_MultiRequest, opts ...grpc.CallOption) (*payload.Object_Locations, error)
}

InsertClient is the client API for Insert service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewInsertClient 

func NewInsertClient(cc *grpc.ClientConn) InsertClient

type InsertServer 

type InsertServer interface {
	Insert(context.Context, *payload.Insert_Request) (*payload.Object_Location, error)
	StreamInsert(Insert_StreamInsertServer) error
	MultiInsert(context.Context, *payload.Insert_MultiRequest) (*payload.Object_Locations, error)
}

InsertServer is the server API for Insert service.

type Insert_StreamInsertClient 

type Insert_StreamInsertClient interface {
	Send(*payload.Insert_Request) error
	Recv() (*payload.Object_StreamLocation, error)
	grpc.ClientStream
}

type Insert_StreamInsertServer 

type Insert_StreamInsertServer interface {
	Send(*payload.Object_StreamLocation) error
	Recv() (*payload.Insert_Request, error)
	grpc.ServerStream
}

type ObjectClient 

type ObjectClient interface {
	Exists(ctx context.Context, in *payload.Object_ID, opts ...grpc.CallOption) (*payload.Object_ID, error)
	GetObject(ctx context.Context, in *payload.Object_VectorRequest, opts ...grpc.CallOption) (*payload.Object_Vector, error)
	StreamGetObject(ctx context.Context, opts ...grpc.CallOption) (Object_StreamGetObjectClient, error)
}

ObjectClient is the client API for Object service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewObjectClient 

func NewObjectClient(cc *grpc.ClientConn) ObjectClient

type ObjectServer 

type ObjectServer interface {
	Exists(context.Context, *payload.Object_ID) (*payload.Object_ID, error)
	GetObject(context.Context, *payload.Object_VectorRequest) (*payload.Object_Vector, error)
	StreamGetObject(Object_StreamGetObjectServer) error
}

ObjectServer is the server API for Object service.

type Object_StreamGetObjectClient 

type Object_StreamGetObjectClient interface {
	Send(*payload.Object_VectorRequest) error
	Recv() (*payload.Object_StreamVector, error)
	grpc.ClientStream
}

type Object_StreamGetObjectServer 

type Object_StreamGetObjectServer interface {
	Send(*payload.Object_StreamVector) error
	Recv() (*payload.Object_VectorRequest, error)
	grpc.ServerStream
}

type RemoveClient 

type RemoveClient interface {
	Remove(ctx context.Context, in *payload.Remove_Request, opts ...grpc.CallOption) (*payload.Object_Location, error)
	StreamRemove(ctx context.Context, opts ...grpc.CallOption) (Remove_StreamRemoveClient, error)
	MultiRemove(ctx context.Context, in *payload.Remove_MultiRequest, opts ...grpc.CallOption) (*payload.Object_Locations, error)
}

RemoveClient is the client API for Remove service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRemoveClient 

func NewRemoveClient(cc *grpc.ClientConn) RemoveClient

type RemoveServer 

type RemoveServer interface {
	Remove(context.Context, *payload.Remove_Request) (*payload.Object_Location, error)
	StreamRemove(Remove_StreamRemoveServer) error
	MultiRemove(context.Context, *payload.Remove_MultiRequest) (*payload.Object_Locations, error)
}

RemoveServer is the server API for Remove service.

type Remove_StreamRemoveClient 

type Remove_StreamRemoveClient interface {
	Send(*payload.Remove_Request) error
	Recv() (*payload.Object_StreamLocation, error)
	grpc.ClientStream
}

type Remove_StreamRemoveServer 

type Remove_StreamRemoveServer interface {
	Send(*payload.Object_StreamLocation) error
	Recv() (*payload.Remove_Request, error)
	grpc.ServerStream
}

type SearchClient 

type SearchClient interface {
	Search(ctx context.Context, in *payload.Search_Request, opts ...grpc.CallOption) (*payload.Search_Response, error)
	SearchByID(ctx context.Context, in *payload.Search_IDRequest, opts ...grpc.CallOption) (*payload.Search_Response, error)
	StreamSearch(ctx context.Context, opts ...grpc.CallOption) (Search_StreamSearchClient, error)
	StreamSearchByID(ctx context.Context, opts ...grpc.CallOption) (Search_StreamSearchByIDClient, error)
	MultiSearch(ctx context.Context, in *payload.Search_MultiRequest, opts ...grpc.CallOption) (*payload.Search_Responses, error)
	MultiSearchByID(ctx context.Context, in *payload.Search_MultiIDRequest, opts ...grpc.CallOption) (*payload.Search_Responses, error)
}

SearchClient is the client API for Search service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSearchClient 

func NewSearchClient(cc *grpc.ClientConn) SearchClient

type SearchServer 

type SearchServer interface {
	Search(context.Context, *payload.Search_Request) (*payload.Search_Response, error)
	SearchByID(context.Context, *payload.Search_IDRequest) (*payload.Search_Response, error)
	StreamSearch(Search_StreamSearchServer) error
	StreamSearchByID(Search_StreamSearchByIDServer) error
	MultiSearch(context.Context, *payload.Search_MultiRequest) (*payload.Search_Responses, error)
	MultiSearchByID(context.Context, *payload.Search_MultiIDRequest) (*payload.Search_Responses, error)
}

SearchServer is the server API for Search service.

type Search_StreamSearchByIDClient 

type Search_StreamSearchByIDClient interface {
	Send(*payload.Search_IDRequest) error
	Recv() (*payload.Search_StreamResponse, error)
	grpc.ClientStream
}

type Search_StreamSearchByIDServer 

type Search_StreamSearchByIDServer interface {
	Send(*payload.Search_StreamResponse) error
	Recv() (*payload.Search_IDRequest, error)
	grpc.ServerStream
}

type Search_StreamSearchClient 

type Search_StreamSearchClient interface {
	Send(*payload.Search_Request) error
	Recv() (*payload.Search_StreamResponse, error)
	grpc.ClientStream
}

type Search_StreamSearchServer 

type Search_StreamSearchServer interface {
	Send(*payload.Search_StreamResponse) error
	Recv() (*payload.Search_Request, error)
	grpc.ServerStream
}

type Server 

type Server interface {
	InsertServer
	UpdateServer
	UpsertServer
	SearchServer
	RemoveServer
	ObjectServer
}

type ServerWithFilter 

type ServerWithFilter interface {
	Server
	FilterServer
}

type UnimplementedFilterServer 

type UnimplementedFilterServer struct {
}

UnimplementedFilterServer can be embedded to have forward compatible implementations.

func (*UnimplementedFilterServer) InsertObject 

func (*UnimplementedFilterServer) InsertObject(ctx context.Context, req *payload.Insert_ObjectRequest) (*payload.Object_Location, error)

func (*UnimplementedFilterServer) MultiInsertObject 

func (*UnimplementedFilterServer) MultiInsertObject(ctx context.Context, req *payload.Insert_MultiObjectRequest) (*payload.Object_Locations, error)

func (*UnimplementedFilterServer) MultiSearchObject 

func (*UnimplementedFilterServer) MultiSearchObject(ctx context.Context, req *payload.Search_MultiObjectRequest) (*payload.Search_Responses, error)

func (*UnimplementedFilterServer) MultiUpdateObject 

func (*UnimplementedFilterServer) MultiUpdateObject(ctx context.Context, req *payload.Update_MultiObjectRequest) (*payload.Object_Locations, error)

func (*UnimplementedFilterServer) MultiUpsertObject 

func (*UnimplementedFilterServer) MultiUpsertObject(ctx context.Context, req *payload.Upsert_MultiObjectRequest) (*payload.Object_Locations, error)

func (*UnimplementedFilterServer) SearchObject 

func (*UnimplementedFilterServer) SearchObject(ctx context.Context, req *payload.Search_ObjectRequest) (*payload.Search_Response, error)

func (*UnimplementedFilterServer) StreamInsertObject 

func (*UnimplementedFilterServer) StreamInsertObject(srv Filter_StreamInsertObjectServer) error

func (*UnimplementedFilterServer) StreamSearchObject 

func (*UnimplementedFilterServer) StreamSearchObject(srv Filter_StreamSearchObjectServer) error

func (*UnimplementedFilterServer) StreamUpdateObject 

func (*UnimplementedFilterServer) StreamUpdateObject(srv Filter_StreamUpdateObjectServer) error

func (*UnimplementedFilterServer) StreamUpsertObject 

func (*UnimplementedFilterServer) StreamUpsertObject(srv Filter_StreamUpsertObjectServer) error

func (*UnimplementedFilterServer) UpdateObject 

func (*UnimplementedFilterServer) UpdateObject(ctx context.Context, req *payload.Update_ObjectRequest) (*payload.Object_Location, error)

func (*UnimplementedFilterServer) UpsertObject 

func (*UnimplementedFilterServer) UpsertObject(ctx context.Context, req *payload.Upsert_ObjectRequest) (*payload.Object_Location, error)

type UnimplementedInsertServer 

type UnimplementedInsertServer struct {
}

UnimplementedInsertServer can be embedded to have forward compatible implementations.

func (*UnimplementedInsertServer) Insert 

func (*UnimplementedInsertServer) Insert(ctx context.Context, req *payload.Insert_Request) (*payload.Object_Location, error)

func (*UnimplementedInsertServer) MultiInsert 

func (*UnimplementedInsertServer) MultiInsert(ctx context.Context, req *payload.Insert_MultiRequest) (*payload.Object_Locations, error)

func (*UnimplementedInsertServer) StreamInsert 

func (*UnimplementedInsertServer) StreamInsert(srv Insert_StreamInsertServer) error

type UnimplementedObjectServer 

type UnimplementedObjectServer struct {
}

UnimplementedObjectServer can be embedded to have forward compatible implementations.

func (*UnimplementedObjectServer) Exists 

func (*UnimplementedObjectServer) Exists(ctx context.Context, req *payload.Object_ID) (*payload.Object_ID, error)

func (*UnimplementedObjectServer) GetObject 

func (*UnimplementedObjectServer) GetObject(ctx context.Context, req *payload.Object_VectorRequest) (*payload.Object_Vector, error)

func (*UnimplementedObjectServer) StreamGetObject 

func (*UnimplementedObjectServer) StreamGetObject(srv Object_StreamGetObjectServer) error

type UnimplementedRemoveServer 

type UnimplementedRemoveServer struct {
}

UnimplementedRemoveServer can be embedded to have forward compatible implementations.

func (*UnimplementedRemoveServer) MultiRemove 

func (*UnimplementedRemoveServer) MultiRemove(ctx context.Context, req *payload.Remove_MultiRequest) (*payload.Object_Locations, error)

func (*UnimplementedRemoveServer) Remove 

func (*UnimplementedRemoveServer) Remove(ctx context.Context, req *payload.Remove_Request) (*payload.Object_Location, error)

func (*UnimplementedRemoveServer) StreamRemove 

func (*UnimplementedRemoveServer) StreamRemove(srv Remove_StreamRemoveServer) error

type UnimplementedSearchServer 

type UnimplementedSearchServer struct {
}

UnimplementedSearchServer can be embedded to have forward compatible implementations.

func (*UnimplementedSearchServer) MultiSearch 

func (*UnimplementedSearchServer) MultiSearch(ctx context.Context, req *payload.Search_MultiRequest) (*payload.Search_Responses, error)

func (*UnimplementedSearchServer) MultiSearchByID 

func (*UnimplementedSearchServer) MultiSearchByID(ctx context.Context, req *payload.Search_MultiIDRequest) (*payload.Search_Responses, error)

func (*UnimplementedSearchServer) Search 

func (*UnimplementedSearchServer) Search(ctx context.Context, req *payload.Search_Request) (*payload.Search_Response, error)

func (*UnimplementedSearchServer) SearchByID 

func (*UnimplementedSearchServer) SearchByID(ctx context.Context, req *payload.Search_IDRequest) (*payload.Search_Response, error)

func (*UnimplementedSearchServer) StreamSearch 

func (*UnimplementedSearchServer) StreamSearch(srv Search_StreamSearchServer) error

func (*UnimplementedSearchServer) StreamSearchByID 

func (*UnimplementedSearchServer) StreamSearchByID(srv Search_StreamSearchByIDServer) error

type UnimplementedUpdateServer 

type UnimplementedUpdateServer struct {
}

UnimplementedUpdateServer can be embedded to have forward compatible implementations.

func (*UnimplementedUpdateServer) MultiUpdate 

func (*UnimplementedUpdateServer) MultiUpdate(ctx context.Context, req *payload.Update_MultiRequest) (*payload.Object_Locations, error)

func (*UnimplementedUpdateServer) StreamUpdate 

func (*UnimplementedUpdateServer) StreamUpdate(srv Update_StreamUpdateServer) error

func (*UnimplementedUpdateServer) Update 

func (*UnimplementedUpdateServer) Update(ctx context.Context, req *payload.Update_Request) (*payload.Object_Location, error)

type UnimplementedUpsertServer 

type UnimplementedUpsertServer struct {
}

UnimplementedUpsertServer can be embedded to have forward compatible implementations.

func (*UnimplementedUpsertServer) MultiUpsert 

func (*UnimplementedUpsertServer) MultiUpsert(ctx context.Context, req *payload.Upsert_MultiRequest) (*payload.Object_Locations, error)

func (*UnimplementedUpsertServer) StreamUpsert 

func (*UnimplementedUpsertServer) StreamUpsert(srv Upsert_StreamUpsertServer) error

func (*UnimplementedUpsertServer) Upsert 

func (*UnimplementedUpsertServer) Upsert(ctx context.Context, req *payload.Upsert_Request) (*payload.Object_Location, error)

type UpdateClient 

type UpdateClient interface {
	Update(ctx context.Context, in *payload.Update_Request, opts ...grpc.CallOption) (*payload.Object_Location, error)
	StreamUpdate(ctx context.Context, opts ...grpc.CallOption) (Update_StreamUpdateClient, error)
	MultiUpdate(ctx context.Context, in *payload.Update_MultiRequest, opts ...grpc.CallOption) (*payload.Object_Locations, error)
}

UpdateClient is the client API for Update service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUpdateClient 

func NewUpdateClient(cc *grpc.ClientConn) UpdateClient

type UpdateServer 

type UpdateServer interface {
	Update(context.Context, *payload.Update_Request) (*payload.Object_Location, error)
	StreamUpdate(Update_StreamUpdateServer) error
	MultiUpdate(context.Context, *payload.Update_MultiRequest) (*payload.Object_Locations, error)
}

UpdateServer is the server API for Update service.

type Update_StreamUpdateClient 

type Update_StreamUpdateClient interface {
	Send(*payload.Update_Request) error
	Recv() (*payload.Object_StreamLocation, error)
	grpc.ClientStream
}

type Update_StreamUpdateServer 

type Update_StreamUpdateServer interface {
	Send(*payload.Object_StreamLocation) error
	Recv() (*payload.Update_Request, error)
	grpc.ServerStream
}

type UpsertClient 

type UpsertClient interface {
	Upsert(ctx context.Context, in *payload.Upsert_Request, opts ...grpc.CallOption) (*payload.Object_Location, error)
	StreamUpsert(ctx context.Context, opts ...grpc.CallOption) (Upsert_StreamUpsertClient, error)
	MultiUpsert(ctx context.Context, in *payload.Upsert_MultiRequest, opts ...grpc.CallOption) (*payload.Object_Locations, error)
}

UpsertClient is the client API for Upsert service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUpsertClient 

func NewUpsertClient(cc *grpc.ClientConn) UpsertClient

type UpsertServer 

type UpsertServer interface {
	Upsert(context.Context, *payload.Upsert_Request) (*payload.Object_Location, error)
	StreamUpsert(Upsert_StreamUpsertServer) error
	MultiUpsert(context.Context, *payload.Upsert_MultiRequest) (*payload.Object_Locations, error)
}

UpsertServer is the server API for Upsert service.

type Upsert_StreamUpsertClient 

type Upsert_StreamUpsertClient interface {
	Send(*payload.Upsert_Request) error
	Recv() (*payload.Object_StreamLocation, error)
	grpc.ClientStream
}

type Upsert_StreamUpsertServer 

type Upsert_StreamUpsertServer interface {
	Send(*payload.Object_StreamLocation) error
	Recv() (*payload.Upsert_Request, error)
	grpc.ServerStream
}

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.