ingress

Documentation

Index

• Variables
• func RegisterFilterServer(s grpc.ServiceRegistrar, srv FilterServer)
• type FilterClient
  • func NewFilterClient(cc grpc.ClientConnInterface) FilterClient
• type FilterServer
• type UnimplementedFilterServer
  • func (UnimplementedFilterServer) FilterVector(context.Context, *payload.Object_Vector) (*payload.Object_Vector, error)
  • func (UnimplementedFilterServer) GenVector(context.Context, *payload.Object_Blob) (*payload.Object_Vector, error)
• type UnsafeFilterServer

Variables

var File_v1_filter_ingress_ingress_filter_proto protoreflect.FileDescriptor

var Filter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "filter.ingress.v1.Filter",
	HandlerType: (*FilterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GenVector",
			Handler:    _Filter_GenVector_Handler,
		},
		{
			MethodName: "FilterVector",
			Handler:    _Filter_FilterVector_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1/filter/ingress/ingress_filter.proto",
}

Filter_ServiceDesc is the grpc.ServiceDesc for Filter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFilterServer

func RegisterFilterServer(s grpc.ServiceRegistrar, srv FilterServer)

Types

type FilterClient

type FilterClient interface {
	// Represent the RPC to generate the vector.
	GenVector(ctx context.Context, in *payload.Object_Blob, opts ...grpc.CallOption) (*payload.Object_Vector, error)
	// Represent the RPC to filter the vector.
	FilterVector(ctx context.Context, in *payload.Object_Vector, opts ...grpc.CallOption) (*payload.Object_Vector, error)
}

FilterClient is the client API for Filter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFilterClient

func NewFilterClient(cc grpc.ClientConnInterface) FilterClient

type FilterServer

type FilterServer interface {
	// Represent the RPC to generate the vector.
	GenVector(context.Context, *payload.Object_Blob) (*payload.Object_Vector, error)
	// Represent the RPC to filter the vector.
	FilterVector(context.Context, *payload.Object_Vector) (*payload.Object_Vector, error)
	// contains filtered or unexported methods
}

FilterServer is the server API for Filter service. All implementations must embed UnimplementedFilterServer for forward compatibility

type UnimplementedFilterServer

type UnimplementedFilterServer struct{}

UnimplementedFilterServer must be embedded to have forward compatible implementations.

func (UnimplementedFilterServer) FilterVector

func (UnimplementedFilterServer) FilterVector(
	context.Context, *payload.Object_Vector,
) (*payload.Object_Vector, error)

func (UnimplementedFilterServer) GenVector

func (UnimplementedFilterServer) GenVector(
	context.Context, *payload.Object_Blob,
) (*payload.Object_Vector, error)

type UnsafeFilterServer

type UnsafeFilterServer interface {
	// contains filtered or unexported methods
}

UnsafeFilterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FilterServer will result in compilation errors.