recordpb

type AttributeEntry struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type BinEntry struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type BinGetRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	BinName    string `protobuf:"bytes,3,opt,name=bin_name,json=binName,proto3" json:"bin_name,omitempty"`
	// contains filtered or unexported fields
}

type BinPutRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	BinName    string `protobuf:"bytes,3,opt,name=bin_name,json=binName,proto3" json:"bin_name,omitempty"`
	Value      []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type BinRemoveRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	BinName    string `protobuf:"bytes,3,opt,name=bin_name,json=binName,proto3" json:"bin_name,omitempty"`
	// contains filtered or unexported fields
}

type Command struct {
	Operation     CommandOperation   `protobuf:"varint,1,opt,name=operation,proto3,enum=recordbase.CommandOperation" json:"operation,omitempty"`
	CreateReq     *CreateRequest     `protobuf:"bytes,2,opt,name=create_req,json=createReq,proto3" json:"create_req,omitempty"`
	UpdateReq     *UpdateRequest     `protobuf:"bytes,3,opt,name=update_req,json=updateReq,proto3" json:"update_req,omitempty"`
	DeleteReq     *DeleteRequest     `protobuf:"bytes,4,opt,name=delete_req,json=deleteReq,proto3" json:"delete_req,omitempty"`
	UploadFileReq *UploadFileRequest `protobuf:"bytes,5,opt,name=upload_file_req,json=uploadFileReq,proto3" json:"upload_file_req,omitempty"`
	DeleteFileReq *DeleteFileRequest `protobuf:"bytes,6,opt,name=delete_file_req,json=deleteFileReq,proto3" json:"delete_file_req,omitempty"`
	KeyRange      *KeyRange          `protobuf:"bytes,7,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
	MapPutReq     *MapPutRequest     `protobuf:"bytes,8,opt,name=map_put_req,json=mapPutReq,proto3" json:"map_put_req,omitempty"`
	MapRemoveReq  *MapRemoveRequest  `protobuf:"bytes,9,opt,name=map_remove_req,json=mapRemoveReq,proto3" json:"map_remove_req,omitempty"`
	BinPutReq     *BinPutRequest     `protobuf:"bytes,10,opt,name=bin_put_req,json=binPutReq,proto3" json:"bin_put_req,omitempty"`
	BinRemoveReq  *BinRemoveRequest  `protobuf:"bytes,11,opt,name=bin_remove_req,json=binRemoveReq,proto3" json:"bin_remove_req,omitempty"`
	// contains filtered or unexported fields
}

type CommandOperation int32

type CountEntry struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Count int64  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type CreateRequest struct {
	Tenant     string            `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Attributes []*AttributeEntry `protobuf:"bytes,5,rep,name=attributes,proto3" json:"attributes,omitempty"`
	Tags       []string          `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
	Bins       []*BinEntry       `protobuf:"bytes,7,rep,name=bins,proto3" json:"bins,omitempty"`
	// contains filtered or unexported fields
}

type CreateResponse struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// contains filtered or unexported fields
}

type DeleteFileRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	FileName   string `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"` // could be a path
	// contains filtered or unexported fields
}

type DeleteRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// contains filtered or unexported fields
}

type DownloadFileRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	FileName   string `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"` // could be a path
	// contains filtered or unexported fields
}

type FileContent struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type FileEntry struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // could be a path
	Data      []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Size      int32  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	CreatedAt int64  `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt int64  `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	DeletedAt int64  `protobuf:"varint,6,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	// contains filtered or unexported fields
}

type GetRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// contains filtered or unexported fields
}

type Info struct {
	Tenant     string        `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Attributes []*CountEntry `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty"`
	Tags       []*CountEntry `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Bins       []*CountEntry `protobuf:"bytes,4,rep,name=bins,proto3" json:"bins,omitempty"`
	// contains filtered or unexported fields
}

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

type KeyRange struct {
	Tenant   string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	FirstKey int64  `protobuf:"varint,2,opt,name=first_key,json=firstKey,proto3" json:"first_key,omitempty"`
	LastKey  int64  `protobuf:"varint,3,opt,name=last_key,json=lastKey,proto3" json:"last_key,omitempty"`
	// contains filtered or unexported fields
}

type KeyRangeEntry struct {
	Tenant string      `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Ranges []*KeyRange `protobuf:"bytes,2,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// contains filtered or unexported fields
}

type LookupRequest struct {
	Tenant     string     `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	LookupType LookupType `protobuf:"varint,2,opt,name=lookup_type,json=lookupType,proto3,enum=recordbase.LookupType" json:"lookup_type,omitempty"`
	Name       string     `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Key        string     `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type LookupType int32

type MapEntry struct {
	MapKey string `protobuf:"bytes,1,opt,name=map_key,json=mapKey,proto3" json:"map_key,omitempty"`
	Value  []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Ttl    int32  `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

type MapGetRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	MapKey     string `protobuf:"bytes,3,opt,name=map_key,json=mapKey,proto3" json:"map_key,omitempty"`
	// contains filtered or unexported fields
}

type MapPutRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	MapKey     string `protobuf:"bytes,3,opt,name=map_key,json=mapKey,proto3" json:"map_key,omitempty"`
	Value      []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Ttl        int32  `protobuf:"varint,5,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

type MapRangeRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// contains filtered or unexported fields
}

type MapRemoveRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	MapKey     string `protobuf:"bytes,3,opt,name=map_key,json=mapKey,proto3" json:"map_key,omitempty"`
	// contains filtered or unexported fields
}

type RecordEntry struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	Version    int64  `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	CreatedAt  int64  `protobuf:"varint,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt  int64  `protobuf:"varint,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	DeletedAt  int64  `protobuf:"varint,7,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	// all records are indexed by hash256(name:value)
	Attributes []*AttributeEntry `protobuf:"bytes,10,rep,name=attributes,proto3" json:"attributes,omitempty"`
	// all records are indexed by tag
	Tags []string `protobuf:"bytes,11,rep,name=tags,proto3" json:"tags,omitempty"`
	// values stored inside the record
	Bins []*BinEntry `protobuf:"bytes,12,rep,name=bins,proto3" json:"bins,omitempty"`
	// files stored outside of the record
	Files []*FileEntry `protobuf:"bytes,13,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

type RecordServiceClient interface {
	//
	// Gets attributes, tags, columns information
	//
	GetInfo(ctx context.Context, in *TenantRequest, opts ...grpc.CallOption) (*Info, error)
	//
	// Quick record lookup request
	//
	Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*RecordEntry, error)
	//
	// Search records by indexed attributes
	//
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (RecordService_SearchClient, error)
	//
	// Get record with all attributes
	//
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*RecordEntry, error)
	//
	// Create record with new primary_key
	//
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	//
	// Delete record
	//
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	//
	// Update record and re-index if needed
	//
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	//
	// Upload File
	//
	UploadFile(ctx context.Context, opts ...grpc.CallOption) (RecordService_UploadFileClient, error)
	//
	// Download File
	//
	DownloadFile(ctx context.Context, in *DownloadFileRequest, opts ...grpc.CallOption) (RecordService_DownloadFileClient, error)
	//
	// Delete File
	//
	DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	//
	// Scan records
	//
	Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (RecordService_ScanClient, error)
	//
	// Allocate primary key range
	//
	AddKeyRange(ctx context.Context, in *KeyRange, opts ...grpc.CallOption) (*emptypb.Empty, error)
	//
	// Gets primary keys capacity
	//
	GetKeyCapacity(ctx context.Context, in *TenantRequest, opts ...grpc.CallOption) (*KeyCapacity, error)
	//
	// Get map value associated with the record
	//
	MapGet(ctx context.Context, in *MapGetRequest, opts ...grpc.CallOption) (*MapEntry, error)
	//
	// Put map value associated with the record
	//
	MapPut(ctx context.Context, in *MapPutRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	//
	// Remove map value associated with the record
	//
	MapRemove(ctx context.Context, in *MapRemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	//
	// Scan all map key-value pairs
	//
	MapRange(ctx context.Context, in *MapRangeRequest, opts ...grpc.CallOption) (RecordService_MapRangeClient, error)
	//
	// Get bin value from the record
	//
	BinGet(ctx context.Context, in *BinGetRequest, opts ...grpc.CallOption) (*BinEntry, error)
	//
	// Put bin value to the record
	//
	BinPut(ctx context.Context, in *BinPutRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	//
	// Remove bin value from the record
	//
	BinRemove(ctx context.Context, in *BinRemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type RecordServiceServer interface {
	//
	// Gets attributes, tags, columns information
	//
	GetInfo(context.Context, *TenantRequest) (*Info, error)
	//
	// Quick record lookup request
	//
	Lookup(context.Context, *LookupRequest) (*RecordEntry, error)
	//
	// Search records by indexed attributes
	//
	Search(*SearchRequest, RecordService_SearchServer) error
	//
	// Get record with all attributes
	//
	Get(context.Context, *GetRequest) (*RecordEntry, error)
	//
	// Create record with new primary_key
	//
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	//
	// Delete record
	//
	Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
	//
	// Update record and re-index if needed
	//
	Update(context.Context, *UpdateRequest) (*emptypb.Empty, error)
	//
	// Upload File
	//
	UploadFile(RecordService_UploadFileServer) error
	//
	// Download File
	//
	DownloadFile(*DownloadFileRequest, RecordService_DownloadFileServer) error
	//
	// Delete File
	//
	DeleteFile(context.Context, *DeleteFileRequest) (*emptypb.Empty, error)
	//
	// Scan records
	//
	Scan(*ScanRequest, RecordService_ScanServer) error
	//
	// Allocate primary key range
	//
	AddKeyRange(context.Context, *KeyRange) (*emptypb.Empty, error)
	//
	// Gets primary keys capacity
	//
	GetKeyCapacity(context.Context, *TenantRequest) (*KeyCapacity, error)
	//
	// Get map value associated with the record
	//
	MapGet(context.Context, *MapGetRequest) (*MapEntry, error)
	//
	// Put map value associated with the record
	//
	MapPut(context.Context, *MapPutRequest) (*emptypb.Empty, error)
	//
	// Remove map value associated with the record
	//
	MapRemove(context.Context, *MapRemoveRequest) (*emptypb.Empty, error)
	//
	// Scan all map key-value pairs
	//
	MapRange(*MapRangeRequest, RecordService_MapRangeServer) error
	//
	// Get bin value from the record
	//
	BinGet(context.Context, *BinGetRequest) (*BinEntry, error)
	//
	// Put bin value to the record
	//
	BinPut(context.Context, *BinPutRequest) (*emptypb.Empty, error)
	//
	// Remove bin value from the record
	//
	BinRemove(context.Context, *BinRemoveRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type RecordService_DownloadFileClient interface {
	Recv() (*FileContent, error)
	grpc.ClientStream
}

type RecordService_DownloadFileServer interface {
	Send(*FileContent) error
	grpc.ServerStream
}

type RecordService_MapRangeClient interface {
	Recv() (*MapEntry, error)
	grpc.ClientStream
}

type RecordService_MapRangeServer interface {
	Send(*MapEntry) error
	grpc.ServerStream
}

type RecordService_ScanClient interface {
	Recv() (*RecordEntry, error)
	grpc.ClientStream
}

type RecordService_ScanServer interface {
	Send(*RecordEntry) error
	grpc.ServerStream
}

type RecordService_SearchClient interface {
	Recv() (*RecordEntry, error)
	grpc.ClientStream
}

type RecordService_SearchServer interface {
	Send(*RecordEntry) error
	grpc.ServerStream
}

type RecordService_UploadFileClient interface {
	Send(*UploadFileContent) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type RecordService_UploadFileServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*UploadFileContent, error)
	grpc.ServerStream
}

type ScanRequest struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Offset int32  `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit  int32  `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type SearchRequest struct {
	Tenant     string     `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	LookupType LookupType `protobuf:"varint,2,opt,name=lookup_type,json=lookupType,proto3,enum=recordbase.LookupType" json:"lookup_type,omitempty"`
	Name       string     `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Key        string     `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type TagEntry struct {
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

type TenantRequest struct {
	Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedRecordServiceServer struct {
}

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

type UpdateRequest struct {
	Tenant     string            `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string            `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	UpdateType UpdateType        `protobuf:"varint,3,opt,name=update_type,json=updateType,proto3,enum=recordbase.UpdateType" json:"update_type,omitempty"`
	Attributes []*AttributeEntry `protobuf:"bytes,5,rep,name=attributes,proto3" json:"attributes,omitempty"`
	Tags       []string          `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
	Bins       []*BinEntry       `protobuf:"bytes,7,rep,name=bins,proto3" json:"bins,omitempty"`
	// contains filtered or unexported fields
}

type UpdateType int32

type UploadFileContent struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	FileName   string `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"` // could be a path
	Data       []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type UploadFileRequest struct {
	Tenant     string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	PrimaryKey string `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	FileName   string `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"` // could be a path
	Data       []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Chunk      int32  `protobuf:"varint,5,opt,name=chunk,proto3" json:"chunk,omitempty"` // 0, 1, 2, etc - chunk number
	Last       bool   `protobuf:"varint,6,opt,name=last,proto3" json:"last,omitempty"`   // last chunk always empty
	// contains filtered or unexported fields
}