proto

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
}

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

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
}

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

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

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

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
}

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

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
}

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
}

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

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
}

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

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
}

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

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

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)
}

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
}

type UnimplementedStorageProtocolServer struct {
}

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

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
}

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