proto

package
v1.2.1 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package proto is the protobuf definition for the StorageProtocol

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_storage_plugins_proto_storage_protocol_proto protoreflect.FileDescriptor
View Source 
var StorageProtocol_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.StorageProtocol",
	HandlerType: (*StorageProtocolServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "EnsureIndex",
			Handler:    _StorageProtocol_EnsureIndex_Handler,
		},
		{
			MethodName: "Aggregate",
			Handler:    _StorageProtocol_Aggregate_Handler,
		},
		{
			MethodName: "Count",
			Handler:    _StorageProtocol_Count_Handler,
		},
		{
			MethodName: "Find",
			Handler:    _StorageProtocol_Find_Handler,
		},
		{
			MethodName: "Insert",
			Handler:    _StorageProtocol_Insert_Handler,
		},
		{
			MethodName: "Patch",
			Handler:    _StorageProtocol_Patch_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _StorageProtocol_Remove_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _StorageProtocol_Update_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/storage/plugins/proto/storage_protocol.proto",
}

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

Functions

func RegisterStorageProtocolServer 

func RegisterStorageProtocolServer(s grpc.ServiceRegistrar, srv StorageProtocolServer)

Types

type AggregateRequest 

type AggregateRequest struct {
	Collection string   `protobuf:"bytes,1,opt,name=Collection,proto3" json:"Collection,omitempty"`
	Pipeline   []*Stage `protobuf:"bytes,2,rep,name=Pipeline,proto3" json:"Pipeline,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregateRequest) Descriptor deprecated 

func (*AggregateRequest) Descriptor() ([]byte, []int)

Deprecated: Use AggregateRequest.ProtoReflect.Descriptor instead.

func (*AggregateRequest) GetCollection 

func (x *AggregateRequest) GetCollection() string

func (*AggregateRequest) GetPipeline 

func (x *AggregateRequest) GetPipeline() []*Stage

func (*AggregateRequest) ProtoMessage 

func (*AggregateRequest) ProtoMessage()

func (*AggregateRequest) ProtoReflect 

func (x *AggregateRequest) ProtoReflect() protoreflect.Message

func (*AggregateRequest) Reset 

func (x *AggregateRequest) Reset()

func (*AggregateRequest) String 

func (x *AggregateRequest) String() string

type AggregateResponse 

type AggregateResponse struct {
	Results [][]byte `protobuf:"bytes,1,rep,name=Results,proto3" json:"Results,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregateResponse) Descriptor deprecated 

func (*AggregateResponse) Descriptor() ([]byte, []int)

Deprecated: Use AggregateResponse.ProtoReflect.Descriptor instead.

func (*AggregateResponse) GetResults 

func (x *AggregateResponse) GetResults() [][]byte

func (*AggregateResponse) ProtoMessage 

func (*AggregateResponse) ProtoMessage()

func (*AggregateResponse) ProtoReflect 

func (x *AggregateResponse) ProtoReflect() protoreflect.Message

func (*AggregateResponse) Reset 

func (x *AggregateResponse) Reset()

func (*AggregateResponse) String 

func (x *AggregateResponse) String() string

type CountRequest 

type CountRequest struct {
	Collection string           `protobuf:"bytes,1,opt,name=Collection,proto3" json:"Collection,omitempty"`
	Filter     *structpb.Struct `protobuf:"bytes,2,opt,name=Filter,proto3" json:"Filter,omitempty"`
	// contains filtered or unexported fields
}

func (*CountRequest) Descriptor deprecated 

func (*CountRequest) Descriptor() ([]byte, []int)

Deprecated: Use CountRequest.ProtoReflect.Descriptor instead.

func (*CountRequest) GetCollection 

func (x *CountRequest) GetCollection() string

func (*CountRequest) GetFilter 

func (x *CountRequest) GetFilter() *structpb.Struct

func (*CountRequest) ProtoMessage 

func (*CountRequest) ProtoMessage()

func (*CountRequest) ProtoReflect 

func (x *CountRequest) ProtoReflect() protoreflect.Message

func (*CountRequest) Reset 

func (x *CountRequest) Reset()

func (*CountRequest) String 

func (x *CountRequest) String() string

type CountResponse 

type CountResponse struct {
	Count int64 `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
	// contains filtered or unexported fields
}

func (*CountResponse) Descriptor deprecated 

func (*CountResponse) Descriptor() ([]byte, []int)

Deprecated: Use CountResponse.ProtoReflect.Descriptor instead.

func (*CountResponse) GetCount 

func (x *CountResponse) GetCount() int64

func (*CountResponse) ProtoMessage 

func (*CountResponse) ProtoMessage()

func (*CountResponse) ProtoReflect 

func (x *CountResponse) ProtoReflect() protoreflect.Message

func (*CountResponse) Reset 

func (x *CountResponse) Reset()

func (*CountResponse) String 

func (x *CountResponse) String() string

type EnsureIndexRequest 

type EnsureIndexRequest struct {
	Indices []*Index `protobuf:"bytes,1,rep,name=Indices,proto3" json:"Indices,omitempty"`
	// contains filtered or unexported fields
}

func (*EnsureIndexRequest) Descriptor deprecated 

func (*EnsureIndexRequest) Descriptor() ([]byte, []int)

Deprecated: Use EnsureIndexRequest.ProtoReflect.Descriptor instead.

func (*EnsureIndexRequest) GetIndices 

func (x *EnsureIndexRequest) GetIndices() []*Index

func (*EnsureIndexRequest) ProtoMessage 

func (*EnsureIndexRequest) ProtoMessage()

func (*EnsureIndexRequest) ProtoReflect 

func (x *EnsureIndexRequest) ProtoReflect() protoreflect.Message

func (*EnsureIndexRequest) Reset 

func (x *EnsureIndexRequest) Reset()

func (*EnsureIndexRequest) String 

func (x *EnsureIndexRequest) String() string

type EnsureIndexResponse 

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

func (*EnsureIndexResponse) Descriptor deprecated 

func (*EnsureIndexResponse) Descriptor() ([]byte, []int)

Deprecated: Use EnsureIndexResponse.ProtoReflect.Descriptor instead.

func (*EnsureIndexResponse) ProtoMessage 

func (*EnsureIndexResponse) ProtoMessage()

func (*EnsureIndexResponse) ProtoReflect 

func (x *EnsureIndexResponse) ProtoReflect() protoreflect.Message

func (*EnsureIndexResponse) Reset 

func (x *EnsureIndexResponse) Reset()

func (*EnsureIndexResponse) String 

func (x *EnsureIndexResponse) String() string

type FindRequest 

type FindRequest struct {
	Collection string             `protobuf:"bytes,1,opt,name=Collection,proto3" json:"Collection,omitempty"`
	Sort       []*structpb.Struct `protobuf:"bytes,2,rep,name=Sort,proto3" json:"Sort,omitempty"`
	Skip       int64              `protobuf:"varint,3,opt,name=Skip,proto3" json:"Skip,omitempty"`
	Limit      int64              `protobuf:"varint,4,opt,name=Limit,proto3" json:"Limit,omitempty"`
	Select     []*structpb.Struct `protobuf:"bytes,5,rep,name=Select,proto3" json:"Select,omitempty"`
	Filter     *structpb.Struct   `protobuf:"bytes,6,opt,name=Filter,proto3" json:"Filter,omitempty"`
	// contains filtered or unexported fields
}

func (*FindRequest) Descriptor deprecated 

func (*FindRequest) Descriptor() ([]byte, []int)

Deprecated: Use FindRequest.ProtoReflect.Descriptor instead.

func (*FindRequest) GetCollection 

func (x *FindRequest) GetCollection() string

func (*FindRequest) GetFilter 

func (x *FindRequest) GetFilter() *structpb.Struct

func (*FindRequest) GetLimit 

func (x *FindRequest) GetLimit() int64

func (*FindRequest) GetSelect 

func (x *FindRequest) GetSelect() []*structpb.Struct

func (*FindRequest) GetSkip 

func (x *FindRequest) GetSkip() int64

func (*FindRequest) GetSort 

func (x *FindRequest) GetSort() []*structpb.Struct

func (*FindRequest) ProtoMessage 

func (*FindRequest) ProtoMessage()

func (*FindRequest) ProtoReflect 

func (x *FindRequest) ProtoReflect() protoreflect.Message

func (*FindRequest) Reset 

func (x *FindRequest) Reset()

func (*FindRequest) String 

func (x *FindRequest) String() string

type FindResponse 

type FindResponse struct {
	Results [][]byte `protobuf:"bytes,1,rep,name=Results,proto3" json:"Results,omitempty"`
	// contains filtered or unexported fields
}

func (*FindResponse) Descriptor deprecated 

func (*FindResponse) Descriptor() ([]byte, []int)

Deprecated: Use FindResponse.ProtoReflect.Descriptor instead.

func (*FindResponse) GetResults 

func (x *FindResponse) GetResults() [][]byte

func (*FindResponse) ProtoMessage 

func (*FindResponse) ProtoMessage()

func (*FindResponse) ProtoReflect 

func (x *FindResponse) ProtoReflect() protoreflect.Message

func (*FindResponse) Reset 

func (x *FindResponse) Reset()

func (*FindResponse) String 

func (x *FindResponse) String() string

type Index 

type Index struct {
	Collection string             `protobuf:"bytes,1,opt,name=Collection,proto3" json:"Collection,omitempty"`
	Keys       []*structpb.Struct `protobuf:"bytes,2,rep,name=Keys,proto3" json:"Keys,omitempty"`
	Unique     bool               `protobuf:"varint,3,opt,name=Unique,proto3" json:"Unique,omitempty"`
	// contains filtered or unexported fields
}

func (*Index) Descriptor deprecated 

func (*Index) Descriptor() ([]byte, []int)

Deprecated: Use Index.ProtoReflect.Descriptor instead.

func (*Index) GetCollection 

func (x *Index) GetCollection() string

func (*Index) GetKeys 

func (x *Index) GetKeys() []*structpb.Struct

func (*Index) GetUnique 

func (x *Index) GetUnique() bool

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) ProtoReflect 

func (x *Index) ProtoReflect() protoreflect.Message

func (*Index) Reset 

func (x *Index) Reset()

func (*Index) String 

func (x *Index) String() string

type InsertRequest 

type InsertRequest struct {
	Collection string             `protobuf:"bytes,1,opt,name=Collection,proto3" json:"Collection,omitempty"`
	Documents  []*structpb.Struct `protobuf:"bytes,2,rep,name=Documents,proto3" json:"Documents,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertRequest) Descriptor deprecated 

func (*InsertRequest) Descriptor() ([]byte, []int)

Deprecated: Use InsertRequest.ProtoReflect.Descriptor instead.

func (*InsertRequest) GetCollection 

func (x *InsertRequest) GetCollection() string

func (*InsertRequest) GetDocuments 

func (x *InsertRequest) GetDocuments() []*structpb.Struct

func (*InsertRequest) ProtoMessage 

func (*InsertRequest) ProtoMessage()

func (*InsertRequest) ProtoReflect 

func (x *InsertRequest) ProtoReflect() protoreflect.Message

func (*InsertRequest) Reset 

func (x *InsertRequest) Reset()

func (*InsertRequest) String 

func (x *InsertRequest) String() string

type InsertResponse 

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

func (*InsertResponse) Descriptor deprecated 

func (*InsertResponse) Descriptor() ([]byte, []int)

Deprecated: Use InsertResponse.ProtoReflect.Descriptor instead.

func (*InsertResponse) ProtoMessage 

func (*InsertResponse) ProtoMessage()

func (*InsertResponse) ProtoReflect 

func (x *InsertResponse) ProtoReflect() protoreflect.Message

func (*InsertResponse) Reset 

func (x *InsertResponse) Reset()

func (*InsertResponse) String 

func (x *InsertResponse) String() string

type PatchRequest 

type PatchRequest struct {
	Collection     string             `protobuf:"bytes,1,opt,name=Collection,proto3" json:"Collection,omitempty"`
	QueryDocument  *structpb.Struct   `protobuf:"bytes,2,opt,name=QueryDocument,proto3" json:"QueryDocument,omitempty"`
	Transformation []*structpb.Struct `protobuf:"bytes,3,rep,name=Transformation,proto3" json:"Transformation,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchRequest) Descriptor deprecated 

func (*PatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use PatchRequest.ProtoReflect.Descriptor instead.

func (*PatchRequest) GetCollection 

func (x *PatchRequest) GetCollection() string

func (*PatchRequest) GetQueryDocument 

func (x *PatchRequest) GetQueryDocument() *structpb.Struct

func (*PatchRequest) GetTransformation 

func (x *PatchRequest) GetTransformation() []*structpb.Struct

func (*PatchRequest) ProtoMessage 

func (*PatchRequest) ProtoMessage()

func (*PatchRequest) ProtoReflect 

func (x *PatchRequest) ProtoReflect() protoreflect.Message

func (*PatchRequest) Reset 

func (x *PatchRequest) Reset()

func (*PatchRequest) String 

func (x *PatchRequest) String() string

type PatchResponse 

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

func (*PatchResponse) Descriptor deprecated 

func (*PatchResponse) Descriptor() ([]byte, []int)

Deprecated: Use PatchResponse.ProtoReflect.Descriptor instead.

func (*PatchResponse) ProtoMessage 

func (*PatchResponse) ProtoMessage()

func (*PatchResponse) ProtoReflect 

func (x *PatchResponse) ProtoReflect() protoreflect.Message

func (*PatchResponse) Reset 

func (x *PatchResponse) Reset()

func (*PatchResponse) String 

func (x *PatchResponse) String() string

type RemoveRequest 

type RemoveRequest struct {
	Collection string           `protobuf:"bytes,1,opt,name=Collection,proto3" json:"Collection,omitempty"`
	Filter     *structpb.Struct `protobuf:"bytes,2,opt,name=Filter,proto3" json:"Filter,omitempty"`
	All        bool             `protobuf:"varint,3,opt,name=All,proto3" json:"All,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRequest) Descriptor deprecated 

func (*RemoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetAll 

func (x *RemoveRequest) GetAll() bool

func (*RemoveRequest) GetCollection 

func (x *RemoveRequest) GetCollection() string

func (*RemoveRequest) GetFilter 

func (x *RemoveRequest) GetFilter() *structpb.Struct

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect 

func (x *RemoveRequest) ProtoReflect() protoreflect.Message

func (*RemoveRequest) Reset 

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (x *RemoveRequest) String() string

type RemoveResponse 

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

func (*RemoveResponse) Descriptor deprecated 

func (*RemoveResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.

func (*RemoveResponse) ProtoMessage 

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) ProtoReflect 

func (x *RemoveResponse) ProtoReflect() protoreflect.Message

func (*RemoveResponse) Reset 

func (x *RemoveResponse) Reset()

func (*RemoveResponse) String 

func (x *RemoveResponse) String() string

type Stage 

type Stage struct {
	Steps []*structpb.Struct `protobuf:"bytes,1,rep,name=Steps,proto3" json:"Steps,omitempty"`
	// contains filtered or unexported fields
}

func (*Stage) Descriptor deprecated 

func (*Stage) Descriptor() ([]byte, []int)

Deprecated: Use Stage.ProtoReflect.Descriptor instead.

func (*Stage) GetSteps 

func (x *Stage) GetSteps() []*structpb.Struct

func (*Stage) ProtoMessage 

func (*Stage) ProtoMessage()

func (*Stage) ProtoReflect 

func (x *Stage) ProtoReflect() protoreflect.Message

func (*Stage) Reset 

func (x *Stage) Reset()

func (*Stage) String 

func (x *Stage) String() string

type StorageProtocolClient 

type StorageProtocolClient interface {
	EnsureIndex(ctx context.Context, in *EnsureIndexRequest, opts ...grpc.CallOption) (*EnsureIndexResponse, error)
	Aggregate(ctx context.Context, in *AggregateRequest, opts ...grpc.CallOption) (*AggregateResponse, error)
	Count(ctx context.Context, in *CountRequest, opts ...grpc.CallOption) (*CountResponse, error)
	Find(ctx context.Context, in *FindRequest, opts ...grpc.CallOption) (*FindResponse, error)
	Insert(ctx context.Context, in *InsertRequest, opts ...grpc.CallOption) (*InsertResponse, error)
	Patch(ctx context.Context, in *PatchRequest, opts ...grpc.CallOption) (*PatchResponse, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
}

StorageProtocolClient is the client API for StorageProtocol 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 NewStorageProtocolClient 

func NewStorageProtocolClient(cc grpc.ClientConnInterface) StorageProtocolClient

type StorageProtocolServer 

type StorageProtocolServer interface {
	EnsureIndex(context.Context, *EnsureIndexRequest) (*EnsureIndexResponse, error)
	Aggregate(context.Context, *AggregateRequest) (*AggregateResponse, error)
	Count(context.Context, *CountRequest) (*CountResponse, error)
	Find(context.Context, *FindRequest) (*FindResponse, error)
	Insert(context.Context, *InsertRequest) (*InsertResponse, error)
	Patch(context.Context, *PatchRequest) (*PatchResponse, error)
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	// contains filtered or unexported methods
}

StorageProtocolServer is the server API for StorageProtocol service. All implementations must embed UnimplementedStorageProtocolServer for forward compatibility

type UnimplementedStorageProtocolServer 

type UnimplementedStorageProtocolServer struct {
}

UnimplementedStorageProtocolServer must be embedded to have forward compatible implementations.

func (UnimplementedStorageProtocolServer) Aggregate 

func (UnimplementedStorageProtocolServer) Aggregate(context.Context, *AggregateRequest) (*AggregateResponse, error)

func (UnimplementedStorageProtocolServer) Count 

func (UnimplementedStorageProtocolServer) Count(context.Context, *CountRequest) (*CountResponse, error)

func (UnimplementedStorageProtocolServer) EnsureIndex 

func (UnimplementedStorageProtocolServer) EnsureIndex(context.Context, *EnsureIndexRequest) (*EnsureIndexResponse, error)

func (UnimplementedStorageProtocolServer) Find 

func (UnimplementedStorageProtocolServer) Find(context.Context, *FindRequest) (*FindResponse, error)

func (UnimplementedStorageProtocolServer) Insert 

func (UnimplementedStorageProtocolServer) Insert(context.Context, *InsertRequest) (*InsertResponse, error)

func (UnimplementedStorageProtocolServer) Patch 

func (UnimplementedStorageProtocolServer) Patch(context.Context, *PatchRequest) (*PatchResponse, error)

func (UnimplementedStorageProtocolServer) Remove 

func (UnimplementedStorageProtocolServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)

func (UnimplementedStorageProtocolServer) Update 

func (UnimplementedStorageProtocolServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)

type UnsafeStorageProtocolServer 

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

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

type UpdateRequest 

type UpdateRequest struct {
	Collection string           `protobuf:"bytes,1,opt,name=Collection,proto3" json:"Collection,omitempty"`
	Filter     *structpb.Struct `protobuf:"bytes,2,opt,name=Filter,proto3" json:"Filter,omitempty"`
	Upsert     bool             `protobuf:"varint,3,opt,name=Upsert,proto3" json:"Upsert,omitempty"`
	Document   *structpb.Struct `protobuf:"bytes,4,opt,name=Document,proto3" json:"Document,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated 

func (*UpdateRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetCollection 

func (x *UpdateRequest) GetCollection() string

func (*UpdateRequest) GetDocument 

func (x *UpdateRequest) GetDocument() *structpb.Struct

func (*UpdateRequest) GetFilter 

func (x *UpdateRequest) GetFilter() *structpb.Struct

func (*UpdateRequest) GetUpsert 

func (x *UpdateRequest) GetUpsert() bool

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect 

func (x *UpdateRequest) ProtoReflect() protoreflect.Message

func (*UpdateRequest) Reset 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (x *UpdateRequest) String() string

type UpdateResponse 

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

func (*UpdateResponse) Descriptor deprecated 

func (*UpdateResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect 

func (x *UpdateResponse) ProtoReflect() protoreflect.Message

func (*UpdateResponse) Reset 

func (x *UpdateResponse) Reset()

func (*UpdateResponse) String 

func (x *UpdateResponse) String() string

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.