recordpb

package module
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2023 License: Apache-2.0 Imports: 18 Imported by: 2

README

recordpb

Record Service API Protobuf

Interface

Public interface based on gRPC to communicate with RecordBase on any program language.

The main service called recordbase.RecordService and it is available on each data node in API endpoint host:port.

Golang

Build

make

Python

Install python3 on local machine and them required libraries. Requirements:

pip install grpcio-tools

Build

make python

Documentation

Overview

Package recordpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	RecordService_GetInfo_FullMethodName        = "/recordbase.RecordService/GetInfo"
	RecordService_Lookup_FullMethodName         = "/recordbase.RecordService/Lookup"
	RecordService_Search_FullMethodName         = "/recordbase.RecordService/Search"
	RecordService_Get_FullMethodName            = "/recordbase.RecordService/Get"
	RecordService_Create_FullMethodName         = "/recordbase.RecordService/Create"
	RecordService_Delete_FullMethodName         = "/recordbase.RecordService/Delete"
	RecordService_Update_FullMethodName         = "/recordbase.RecordService/Update"
	RecordService_UploadFile_FullMethodName     = "/recordbase.RecordService/UploadFile"
	RecordService_DownloadFile_FullMethodName   = "/recordbase.RecordService/DownloadFile"
	RecordService_DeleteFile_FullMethodName     = "/recordbase.RecordService/DeleteFile"
	RecordService_Scan_FullMethodName           = "/recordbase.RecordService/Scan"
	RecordService_AddKeyRange_FullMethodName    = "/recordbase.RecordService/AddKeyRange"
	RecordService_GetKeyCapacity_FullMethodName = "/recordbase.RecordService/GetKeyCapacity"
	RecordService_MapGet_FullMethodName         = "/recordbase.RecordService/MapGet"
	RecordService_MapPut_FullMethodName         = "/recordbase.RecordService/MapPut"
	RecordService_MapRemove_FullMethodName      = "/recordbase.RecordService/MapRemove"
	RecordService_MapRange_FullMethodName       = "/recordbase.RecordService/MapRange"
	RecordService_BinGet_FullMethodName         = "/recordbase.RecordService/BinGet"
	RecordService_BinPut_FullMethodName         = "/recordbase.RecordService/BinPut"
	RecordService_BinRemove_FullMethodName      = "/recordbase.RecordService/BinRemove"
)

Variables

View Source 
var (
	LookupType_name = map[int32]string{
		0: "UNKNOWN_LOOKUP",
		1: "BY_PRIMARY_KEY",
		2: "BY_ATTRIBUTE",
		3: "BY_TAG",
	}
	LookupType_value = map[string]int32{
		"UNKNOWN_LOOKUP": 0,
		"BY_PRIMARY_KEY": 1,
		"BY_ATTRIBUTE":   2,
		"BY_TAG":         3,
	}
)

Enum value maps for LookupType.

View Source 
var (
	UpdateType_name = map[int32]string{
		0: "UNKNOWN_TYPE",
		1: "MERGE",
		2: "REPLACE",
	}
	UpdateType_value = map[string]int32{
		"UNKNOWN_TYPE": 0,
		"MERGE":        1,
		"REPLACE":      2,
	}
)

Enum value maps for UpdateType.

View Source 
var (
	CommandOperation_name = map[int32]string{
		0:  "UNKNOWN_OP",
		2:  "CREATE_OP",
		3:  "UPDATE_OP",
		4:  "DELETE_OP",
		5:  "UPLOAD_FILE_OP",
		6:  "DELETE_FILE_OP",
		7:  "KEY_RANGE_OP",
		8:  "MAP_PUT",
		9:  "MAP_REMOVE",
		10: "BIN_PUT",
		11: "BIN_REMOVE",
	}
	CommandOperation_value = map[string]int32{
		"UNKNOWN_OP":     0,
		"CREATE_OP":      2,
		"UPDATE_OP":      3,
		"DELETE_OP":      4,
		"UPLOAD_FILE_OP": 5,
		"DELETE_FILE_OP": 6,
		"KEY_RANGE_OP":   7,
		"MAP_PUT":        8,
		"MAP_REMOVE":     9,
		"BIN_PUT":        10,
		"BIN_REMOVE":     11,
	}
)

Enum value maps for CommandOperation.

View Source 
var File_proto_record_service_proto protoreflect.FileDescriptor
View Source 
var RecordService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "recordbase.RecordService",
	HandlerType: (*RecordServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetInfo",
			Handler:    _RecordService_GetInfo_Handler,
		},
		{
			MethodName: "Lookup",
			Handler:    _RecordService_Lookup_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _RecordService_Get_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _RecordService_Create_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _RecordService_Delete_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _RecordService_Update_Handler,
		},
		{
			MethodName: "DeleteFile",
			Handler:    _RecordService_DeleteFile_Handler,
		},
		{
			MethodName: "AddKeyRange",
			Handler:    _RecordService_AddKeyRange_Handler,
		},
		{
			MethodName: "GetKeyCapacity",
			Handler:    _RecordService_GetKeyCapacity_Handler,
		},
		{
			MethodName: "MapGet",
			Handler:    _RecordService_MapGet_Handler,
		},
		{
			MethodName: "MapPut",
			Handler:    _RecordService_MapPut_Handler,
		},
		{
			MethodName: "MapRemove",
			Handler:    _RecordService_MapRemove_Handler,
		},
		{
			MethodName: "BinGet",
			Handler:    _RecordService_BinGet_Handler,
		},
		{
			MethodName: "BinPut",
			Handler:    _RecordService_BinPut_Handler,
		},
		{
			MethodName: "BinRemove",
			Handler:    _RecordService_BinRemove_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Search",
			Handler:       _RecordService_Search_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "UploadFile",
			Handler:       _RecordService_UploadFile_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "DownloadFile",
			Handler:       _RecordService_DownloadFile_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Scan",
			Handler:       _RecordService_Scan_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "MapRange",
			Handler:       _RecordService_MapRange_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/record_service.proto",
}

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

Functions

func RegisterRecordServiceHandler 

func RegisterRecordServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRecordServiceHandler registers the http handlers for service RecordService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRecordServiceHandlerClient 

func RegisterRecordServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RecordServiceClient) error

RegisterRecordServiceHandlerClient registers the http handlers for service RecordService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RecordServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RecordServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RecordServiceClient" to call the correct interceptors.

func RegisterRecordServiceHandlerFromEndpoint 

func RegisterRecordServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRecordServiceHandlerFromEndpoint is same as RegisterRecordServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRecordServiceHandlerServer 

func RegisterRecordServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RecordServiceServer) error

RegisterRecordServiceHandlerServer registers the http handlers for service RecordService to "mux". UnaryRPC :call RecordServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRecordServiceHandlerFromEndpoint instead.

func RegisterRecordServiceServer 

func RegisterRecordServiceServer(s grpc.ServiceRegistrar, srv RecordServiceServer)

Types

type AttributeEntry 

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
}

all attributes are indexed in the form of 'name:value' -> record, list<record> attribute could be an unique index of records or not index located in tenant:attr:sha265("name:value"):primary_key

func (*AttributeEntry) Descriptor deprecated 

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

Deprecated: Use AttributeEntry.ProtoReflect.Descriptor instead.

func (*AttributeEntry) GetName 

func (x *AttributeEntry) GetName() string

func (*AttributeEntry) GetValue 

func (x *AttributeEntry) GetValue() string

func (*AttributeEntry) ProtoMessage 

func (*AttributeEntry) ProtoMessage()

func (*AttributeEntry) ProtoReflect 

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

func (*AttributeEntry) Reset 

func (x *AttributeEntry) Reset()

func (*AttributeEntry) String 

func (x *AttributeEntry) String() string

type BinEntry added in v1.1.1 

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
}

keys stored inside the record, values stored inside the record preferred format for the value is msgpack or json

func (*BinEntry) Descriptor deprecated added in v1.1.1 

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

Deprecated: Use BinEntry.ProtoReflect.Descriptor instead.

func (*BinEntry) GetName added in v1.1.1 

func (x *BinEntry) GetName() string

func (*BinEntry) GetValue added in v1.1.1 

func (x *BinEntry) GetValue() []byte

func (*BinEntry) ProtoMessage added in v1.1.1 

func (*BinEntry) ProtoMessage()

func (*BinEntry) ProtoReflect added in v1.1.1 

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

func (*BinEntry) Reset added in v1.1.1 

func (x *BinEntry) Reset()

func (*BinEntry) String added in v1.1.1 

func (x *BinEntry) String() string

type BinGetRequest added in v1.1.1 

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
}

func (*BinGetRequest) Descriptor deprecated added in v1.1.1 

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

Deprecated: Use BinGetRequest.ProtoReflect.Descriptor instead.

func (*BinGetRequest) GetBinName added in v1.1.1 

func (x *BinGetRequest) GetBinName() string

func (*BinGetRequest) GetPrimaryKey added in v1.1.1 

func (x *BinGetRequest) GetPrimaryKey() string

func (*BinGetRequest) GetTenant added in v1.1.1 

func (x *BinGetRequest) GetTenant() string

func (*BinGetRequest) ProtoMessage added in v1.1.1 

func (*BinGetRequest) ProtoMessage()

func (*BinGetRequest) ProtoReflect added in v1.1.1 

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

func (*BinGetRequest) Reset added in v1.1.1 

func (x *BinGetRequest) Reset()

func (*BinGetRequest) String added in v1.1.1 

func (x *BinGetRequest) String() string

type BinPutRequest added in v1.1.1 

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
}

func (*BinPutRequest) Descriptor deprecated added in v1.1.1 

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

Deprecated: Use BinPutRequest.ProtoReflect.Descriptor instead.

func (*BinPutRequest) GetBinName added in v1.1.1 

func (x *BinPutRequest) GetBinName() string

func (*BinPutRequest) GetPrimaryKey added in v1.1.1 

func (x *BinPutRequest) GetPrimaryKey() string

func (*BinPutRequest) GetTenant added in v1.1.1 

func (x *BinPutRequest) GetTenant() string

func (*BinPutRequest) GetValue added in v1.1.1 

func (x *BinPutRequest) GetValue() []byte

func (*BinPutRequest) ProtoMessage added in v1.1.1 

func (*BinPutRequest) ProtoMessage()

func (*BinPutRequest) ProtoReflect added in v1.1.1 

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

func (*BinPutRequest) Reset added in v1.1.1 

func (x *BinPutRequest) Reset()

func (*BinPutRequest) String added in v1.1.1 

func (x *BinPutRequest) String() string

type BinRemoveRequest added in v1.1.1 

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
}

func (*BinRemoveRequest) Descriptor deprecated added in v1.1.1 

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

Deprecated: Use BinRemoveRequest.ProtoReflect.Descriptor instead.

func (*BinRemoveRequest) GetBinName added in v1.1.1 

func (x *BinRemoveRequest) GetBinName() string

func (*BinRemoveRequest) GetPrimaryKey added in v1.1.1 

func (x *BinRemoveRequest) GetPrimaryKey() string

func (*BinRemoveRequest) GetTenant added in v1.1.1 

func (x *BinRemoveRequest) GetTenant() string

func (*BinRemoveRequest) ProtoMessage added in v1.1.1 

func (*BinRemoveRequest) ProtoMessage()

func (*BinRemoveRequest) ProtoReflect added in v1.1.1 

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

func (*BinRemoveRequest) Reset added in v1.1.1 

func (x *BinRemoveRequest) Reset()

func (*BinRemoveRequest) String added in v1.1.1 

func (x *BinRemoveRequest) String() string

type Command 

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
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetBinPutReq added in v1.1.1 

func (x *Command) GetBinPutReq() *BinPutRequest

func (*Command) GetBinRemoveReq added in v1.1.1 

func (x *Command) GetBinRemoveReq() *BinRemoveRequest

func (*Command) GetCreateReq 

func (x *Command) GetCreateReq() *CreateRequest

func (*Command) GetDeleteFileReq added in v1.0.6 

func (x *Command) GetDeleteFileReq() *DeleteFileRequest

func (*Command) GetDeleteReq 

func (x *Command) GetDeleteReq() *DeleteRequest

func (*Command) GetKeyRange 

func (x *Command) GetKeyRange() *KeyRange

func (*Command) GetMapPutReq 

func (x *Command) GetMapPutReq() *MapPutRequest

func (*Command) GetMapRemoveReq 

func (x *Command) GetMapRemoveReq() *MapRemoveRequest

func (*Command) GetOperation 

func (x *Command) GetOperation() CommandOperation

func (*Command) GetUpdateReq 

func (x *Command) GetUpdateReq() *UpdateRequest

func (*Command) GetUploadFileReq added in v1.0.6 

func (x *Command) GetUploadFileReq() *UploadFileRequest

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

type CommandOperation 

type CommandOperation int32
const (
	CommandOperation_UNKNOWN_OP     CommandOperation = 0
	CommandOperation_CREATE_OP      CommandOperation = 2
	CommandOperation_UPDATE_OP      CommandOperation = 3
	CommandOperation_DELETE_OP      CommandOperation = 4
	CommandOperation_UPLOAD_FILE_OP CommandOperation = 5
	CommandOperation_DELETE_FILE_OP CommandOperation = 6
	CommandOperation_KEY_RANGE_OP   CommandOperation = 7
	CommandOperation_MAP_PUT        CommandOperation = 8
	CommandOperation_MAP_REMOVE     CommandOperation = 9
	CommandOperation_BIN_PUT        CommandOperation = 10
	CommandOperation_BIN_REMOVE     CommandOperation = 11
)

func (CommandOperation) Descriptor 

func (CommandOperation) Descriptor() protoreflect.EnumDescriptor

func (CommandOperation) Enum 

func (x CommandOperation) Enum() *CommandOperation

func (CommandOperation) EnumDescriptor deprecated 

func (CommandOperation) EnumDescriptor() ([]byte, []int)

Deprecated: Use CommandOperation.Descriptor instead.

func (CommandOperation) Number 

func (x CommandOperation) Number() protoreflect.EnumNumber

func (CommandOperation) String 

func (x CommandOperation) String() string

func (CommandOperation) Type 

func (CommandOperation) Type() protoreflect.EnumType

type CountEntry 

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
}

func (*CountEntry) Descriptor deprecated 

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

Deprecated: Use CountEntry.ProtoReflect.Descriptor instead.

func (*CountEntry) GetCount 

func (x *CountEntry) GetCount() int64

func (*CountEntry) GetName 

func (x *CountEntry) GetName() string

func (*CountEntry) ProtoMessage 

func (*CountEntry) ProtoMessage()

func (*CountEntry) ProtoReflect 

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

func (*CountEntry) Reset 

func (x *CountEntry) Reset()

func (*CountEntry) String 

func (x *CountEntry) String() string

type CreateRequest 

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
}

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetAttributes 

func (x *CreateRequest) GetAttributes() []*AttributeEntry

func (*CreateRequest) GetBins added in v1.1.1 

func (x *CreateRequest) GetBins() []*BinEntry

func (*CreateRequest) GetTags 

func (x *CreateRequest) GetTags() []string

func (*CreateRequest) GetTenant 

func (x *CreateRequest) GetTenant() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

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
}

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetPrimaryKey 

func (x *CreateResponse) GetPrimaryKey() string

func (*CreateResponse) GetTenant 

func (x *CreateResponse) GetTenant() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

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

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type DeleteFileRequest added in v1.0.5 

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
}

func (*DeleteFileRequest) Descriptor deprecated added in v1.0.5 

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

Deprecated: Use DeleteFileRequest.ProtoReflect.Descriptor instead.

func (*DeleteFileRequest) GetFileName added in v1.0.5 

func (x *DeleteFileRequest) GetFileName() string

func (*DeleteFileRequest) GetPrimaryKey added in v1.0.5 

func (x *DeleteFileRequest) GetPrimaryKey() string

func (*DeleteFileRequest) GetTenant added in v1.0.5 

func (x *DeleteFileRequest) GetTenant() string

func (*DeleteFileRequest) ProtoMessage added in v1.0.5 

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) ProtoReflect added in v1.0.5 

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

func (*DeleteFileRequest) Reset added in v1.0.5 

func (x *DeleteFileRequest) Reset()

func (*DeleteFileRequest) String added in v1.0.5 

func (x *DeleteFileRequest) String() string

type DeleteRequest 

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
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetPrimaryKey 

func (x *DeleteRequest) GetPrimaryKey() string

func (*DeleteRequest) GetTenant 

func (x *DeleteRequest) GetTenant() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DownloadFileRequest added in v1.0.3 

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
}

func (*DownloadFileRequest) Descriptor deprecated added in v1.0.3 

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

Deprecated: Use DownloadFileRequest.ProtoReflect.Descriptor instead.

func (*DownloadFileRequest) GetFileName added in v1.0.3 

func (x *DownloadFileRequest) GetFileName() string

func (*DownloadFileRequest) GetPrimaryKey added in v1.0.3 

func (x *DownloadFileRequest) GetPrimaryKey() string

func (*DownloadFileRequest) GetTenant added in v1.0.3 

func (x *DownloadFileRequest) GetTenant() string

func (*DownloadFileRequest) ProtoMessage added in v1.0.3 

func (*DownloadFileRequest) ProtoMessage()

func (*DownloadFileRequest) ProtoReflect added in v1.0.3 

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

func (*DownloadFileRequest) Reset added in v1.0.3 

func (x *DownloadFileRequest) Reset()

func (*DownloadFileRequest) String added in v1.0.3 

func (x *DownloadFileRequest) String() string

type FileContent added in v1.0.3 

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

func (*FileContent) Descriptor deprecated added in v1.0.3 

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

Deprecated: Use FileContent.ProtoReflect.Descriptor instead.

func (*FileContent) GetData added in v1.0.3 

func (x *FileContent) GetData() []byte

func (*FileContent) ProtoMessage added in v1.0.3 

func (*FileContent) ProtoMessage()

func (*FileContent) ProtoReflect added in v1.0.3 

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

func (*FileContent) Reset added in v1.0.3 

func (x *FileContent) Reset()

func (*FileContent) String added in v1.0.3 

func (x *FileContent) String() string

type FileEntry 

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
}

keys stored inside the record, values stored outside of the record file content located in tenant:file:primary_key:sha256(file_name):chunk_num

func (*FileEntry) Descriptor deprecated 

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

Deprecated: Use FileEntry.ProtoReflect.Descriptor instead.

func (*FileEntry) GetCreatedAt 

func (x *FileEntry) GetCreatedAt() int64

func (*FileEntry) GetData 

func (x *FileEntry) GetData() []byte

func (*FileEntry) GetDeletedAt added in v1.0.5 

func (x *FileEntry) GetDeletedAt() int64

func (*FileEntry) GetName 

func (x *FileEntry) GetName() string

func (*FileEntry) GetSize 

func (x *FileEntry) GetSize() int32

func (*FileEntry) GetUpdatedAt added in v1.0.5 

func (x *FileEntry) GetUpdatedAt() int64

func (*FileEntry) ProtoMessage 

func (*FileEntry) ProtoMessage()

func (*FileEntry) ProtoReflect 

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

func (*FileEntry) Reset 

func (x *FileEntry) Reset()

func (*FileEntry) String 

func (x *FileEntry) String() string

type GetRequest 

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
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetPrimaryKey 

func (x *GetRequest) GetPrimaryKey() string

func (*GetRequest) GetTenant 

func (x *GetRequest) GetTenant() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type Info added in v1.1.1 

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
}

func (*Info) Descriptor deprecated added in v1.1.1 

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

Deprecated: Use Info.ProtoReflect.Descriptor instead.

func (*Info) GetAttributes added in v1.1.1 

func (x *Info) GetAttributes() []*CountEntry

func (*Info) GetBins added in v1.1.1 

func (x *Info) GetBins() []*CountEntry

func (*Info) GetTags added in v1.1.1 

func (x *Info) GetTags() []*CountEntry

func (*Info) GetTenant added in v1.1.1 

func (x *Info) GetTenant() string

func (*Info) ProtoMessage added in v1.1.1 

func (*Info) ProtoMessage()

func (*Info) ProtoReflect added in v1.1.1 

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

func (*Info) Reset added in v1.1.1 

func (x *Info) Reset()

func (*Info) String added in v1.1.1 

func (x *Info) String() string

type KeyCapacity 

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

func (*KeyCapacity) Descriptor deprecated 

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

Deprecated: Use KeyCapacity.ProtoReflect.Descriptor instead.

func (*KeyCapacity) GetPendingKeys 

func (x *KeyCapacity) GetPendingKeys() int64

func (*KeyCapacity) ProtoMessage 

func (*KeyCapacity) ProtoMessage()

func (*KeyCapacity) ProtoReflect 

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

func (*KeyCapacity) Reset 

func (x *KeyCapacity) Reset()

func (*KeyCapacity) String 

func (x *KeyCapacity) String() string

type KeyRange 

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
}

func (*KeyRange) Descriptor deprecated 

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

Deprecated: Use KeyRange.ProtoReflect.Descriptor instead.

func (*KeyRange) GetFirstKey 

func (x *KeyRange) GetFirstKey() int64

func (*KeyRange) GetLastKey 

func (x *KeyRange) GetLastKey() int64

func (*KeyRange) GetTenant 

func (x *KeyRange) GetTenant() string

func (*KeyRange) ProtoMessage 

func (*KeyRange) ProtoMessage()

func (*KeyRange) ProtoReflect 

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

func (*KeyRange) Reset 

func (x *KeyRange) Reset()

func (*KeyRange) String 

func (x *KeyRange) String() string

type KeyRangeEntry 

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
}

located in range

func (*KeyRangeEntry) Descriptor deprecated 

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

Deprecated: Use KeyRangeEntry.ProtoReflect.Descriptor instead.

func (*KeyRangeEntry) GetRanges 

func (x *KeyRangeEntry) GetRanges() []*KeyRange

func (*KeyRangeEntry) GetTenant 

func (x *KeyRangeEntry) GetTenant() string

func (*KeyRangeEntry) ProtoMessage 

func (*KeyRangeEntry) ProtoMessage()

func (*KeyRangeEntry) ProtoReflect 

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

func (*KeyRangeEntry) Reset 

func (x *KeyRangeEntry) Reset()

func (*KeyRangeEntry) String 

func (x *KeyRangeEntry) String() string

type LookupRequest 

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
}

func (*LookupRequest) Descriptor deprecated 

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

Deprecated: Use LookupRequest.ProtoReflect.Descriptor instead.

func (*LookupRequest) GetKey 

func (x *LookupRequest) GetKey() string

func (*LookupRequest) GetLookupType 

func (x *LookupRequest) GetLookupType() LookupType

func (*LookupRequest) GetName 

func (x *LookupRequest) GetName() string

func (*LookupRequest) GetTenant 

func (x *LookupRequest) GetTenant() string

func (*LookupRequest) ProtoMessage 

func (*LookupRequest) ProtoMessage()

func (*LookupRequest) ProtoReflect 

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

func (*LookupRequest) Reset 

func (x *LookupRequest) Reset()

func (*LookupRequest) String 

func (x *LookupRequest) String() string

type LookupType 

type LookupType int32
const (
	LookupType_UNKNOWN_LOOKUP LookupType = 0
	LookupType_BY_PRIMARY_KEY LookupType = 1
	LookupType_BY_ATTRIBUTE   LookupType = 2
	LookupType_BY_TAG         LookupType = 3
)

func (LookupType) Descriptor 

func (LookupType) Descriptor() protoreflect.EnumDescriptor

func (LookupType) Enum 

func (x LookupType) Enum() *LookupType

func (LookupType) EnumDescriptor deprecated 

func (LookupType) EnumDescriptor() ([]byte, []int)

Deprecated: Use LookupType.Descriptor instead.

func (LookupType) Number 

func (x LookupType) Number() protoreflect.EnumNumber

func (LookupType) String 

func (x LookupType) String() string

func (LookupType) Type 

func (LookupType) Type() protoreflect.EnumType

type MapEntry 

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
}

keys stored outside of the record, values stored outside of the record located in tenant:map:primary_key:map_key

func (*MapEntry) Descriptor deprecated 

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

Deprecated: Use MapEntry.ProtoReflect.Descriptor instead.

func (*MapEntry) GetMapKey 

func (x *MapEntry) GetMapKey() string

func (*MapEntry) GetTtl 

func (x *MapEntry) GetTtl() int32

func (*MapEntry) GetValue 

func (x *MapEntry) GetValue() []byte

func (*MapEntry) ProtoMessage 

func (*MapEntry) ProtoMessage()

func (*MapEntry) ProtoReflect 

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

func (*MapEntry) Reset 

func (x *MapEntry) Reset()

func (*MapEntry) String 

func (x *MapEntry) String() string

type MapGetRequest 

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
}

func (*MapGetRequest) Descriptor deprecated 

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

Deprecated: Use MapGetRequest.ProtoReflect.Descriptor instead.

func (*MapGetRequest) GetMapKey 

func (x *MapGetRequest) GetMapKey() string

func (*MapGetRequest) GetPrimaryKey 

func (x *MapGetRequest) GetPrimaryKey() string

func (*MapGetRequest) GetTenant 

func (x *MapGetRequest) GetTenant() string

func (*MapGetRequest) ProtoMessage 

func (*MapGetRequest) ProtoMessage()

func (*MapGetRequest) ProtoReflect 

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

func (*MapGetRequest) Reset 

func (x *MapGetRequest) Reset()

func (*MapGetRequest) String 

func (x *MapGetRequest) String() string

type MapPutRequest 

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
}

func (*MapPutRequest) Descriptor deprecated 

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

Deprecated: Use MapPutRequest.ProtoReflect.Descriptor instead.

func (*MapPutRequest) GetMapKey 

func (x *MapPutRequest) GetMapKey() string

func (*MapPutRequest) GetPrimaryKey 

func (x *MapPutRequest) GetPrimaryKey() string

func (*MapPutRequest) GetTenant 

func (x *MapPutRequest) GetTenant() string

func (*MapPutRequest) GetTtl 

func (x *MapPutRequest) GetTtl() int32

func (*MapPutRequest) GetValue 

func (x *MapPutRequest) GetValue() []byte

func (*MapPutRequest) ProtoMessage 

func (*MapPutRequest) ProtoMessage()

func (*MapPutRequest) ProtoReflect 

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

func (*MapPutRequest) Reset 

func (x *MapPutRequest) Reset()

func (*MapPutRequest) String 

func (x *MapPutRequest) String() string

type MapRangeRequest 

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
}

func (*MapRangeRequest) Descriptor deprecated 

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

Deprecated: Use MapRangeRequest.ProtoReflect.Descriptor instead.

func (*MapRangeRequest) GetPrimaryKey added in v1.0.10 

func (x *MapRangeRequest) GetPrimaryKey() string

func (*MapRangeRequest) GetTenant 

func (x *MapRangeRequest) GetTenant() string

func (*MapRangeRequest) ProtoMessage 

func (*MapRangeRequest) ProtoMessage()

func (*MapRangeRequest) ProtoReflect 

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

func (*MapRangeRequest) Reset 

func (x *MapRangeRequest) Reset()

func (*MapRangeRequest) String 

func (x *MapRangeRequest) String() string

type MapRemoveRequest 

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
}

func (*MapRemoveRequest) Descriptor deprecated 

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

Deprecated: Use MapRemoveRequest.ProtoReflect.Descriptor instead.

func (*MapRemoveRequest) GetMapKey 

func (x *MapRemoveRequest) GetMapKey() string

func (*MapRemoveRequest) GetPrimaryKey 

func (x *MapRemoveRequest) GetPrimaryKey() string

func (*MapRemoveRequest) GetTenant 

func (x *MapRemoveRequest) GetTenant() string

func (*MapRemoveRequest) ProtoMessage 

func (*MapRemoveRequest) ProtoMessage()

func (*MapRemoveRequest) ProtoReflect 

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

func (*MapRemoveRequest) Reset 

func (x *MapRemoveRequest) Reset()

func (*MapRemoveRequest) String 

func (x *MapRemoveRequest) String() string

type RecordEntry 

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
}

located in tenant:rec:primary_key

func (*RecordEntry) Descriptor deprecated 

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

Deprecated: Use RecordEntry.ProtoReflect.Descriptor instead.

func (*RecordEntry) GetAttributes 

func (x *RecordEntry) GetAttributes() []*AttributeEntry

func (*RecordEntry) GetBins added in v1.1.1 

func (x *RecordEntry) GetBins() []*BinEntry

func (*RecordEntry) GetCreatedAt 

func (x *RecordEntry) GetCreatedAt() int64

func (*RecordEntry) GetDeletedAt 

func (x *RecordEntry) GetDeletedAt() int64

func (*RecordEntry) GetFiles 

func (x *RecordEntry) GetFiles() []*FileEntry

func (*RecordEntry) GetPrimaryKey 

func (x *RecordEntry) GetPrimaryKey() string

func (*RecordEntry) GetTags 

func (x *RecordEntry) GetTags() []string

func (*RecordEntry) GetTenant 

func (x *RecordEntry) GetTenant() string

func (*RecordEntry) GetUpdatedAt 

func (x *RecordEntry) GetUpdatedAt() int64

func (*RecordEntry) GetVersion 

func (x *RecordEntry) GetVersion() int64

func (*RecordEntry) ProtoMessage 

func (*RecordEntry) ProtoMessage()

func (*RecordEntry) ProtoReflect 

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

func (*RecordEntry) Reset 

func (x *RecordEntry) Reset()

func (*RecordEntry) String 

func (x *RecordEntry) String() string

type RecordServiceClient 

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

RecordServiceClient is the client API for RecordService 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 NewRecordServiceClient 

func NewRecordServiceClient(cc grpc.ClientConnInterface) RecordServiceClient

type RecordServiceServer 

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
}

RecordServiceServer is the server API for RecordService service. All implementations must embed UnimplementedRecordServiceServer for forward compatibility

type RecordService_DownloadFileClient added in v1.0.3 

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

type RecordService_DownloadFileServer added in v1.0.3 

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

type RecordService_MapRangeClient 

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

type RecordService_MapRangeServer 

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

type RecordService_ScanClient 

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

type RecordService_ScanServer 

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

type RecordService_SearchClient 

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

type RecordService_SearchServer 

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

type RecordService_UploadFileClient added in v1.0.3 

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

type RecordService_UploadFileServer added in v1.0.3 

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

type ScanRequest 

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
}

func (*ScanRequest) Descriptor deprecated 

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

Deprecated: Use ScanRequest.ProtoReflect.Descriptor instead.

func (*ScanRequest) GetLimit 

func (x *ScanRequest) GetLimit() int32

func (*ScanRequest) GetOffset 

func (x *ScanRequest) GetOffset() int32

func (*ScanRequest) GetPrefix 

func (x *ScanRequest) GetPrefix() string

func (*ScanRequest) GetTenant 

func (x *ScanRequest) GetTenant() string

func (*ScanRequest) ProtoMessage 

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) ProtoReflect 

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

func (*ScanRequest) Reset 

func (x *ScanRequest) Reset()

func (*ScanRequest) String 

func (x *ScanRequest) String() string

type SearchRequest 

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
}

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetKey 

func (x *SearchRequest) GetKey() string

func (*SearchRequest) GetLookupType 

func (x *SearchRequest) GetLookupType() LookupType

func (*SearchRequest) GetName 

func (x *SearchRequest) GetName() string

func (*SearchRequest) GetTenant 

func (x *SearchRequest) GetTenant() string

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type TagEntry 

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

all tags are indexed in the form of 'tag' -> list<record> tag is not unique index of records index located in tenant:tag:sha256("tag"):primary_key

func (*TagEntry) Descriptor deprecated 

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

Deprecated: Use TagEntry.ProtoReflect.Descriptor instead.

func (*TagEntry) GetTag 

func (x *TagEntry) GetTag() string

func (*TagEntry) ProtoMessage 

func (*TagEntry) ProtoMessage()

func (*TagEntry) ProtoReflect 

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

func (*TagEntry) Reset 

func (x *TagEntry) Reset()

func (*TagEntry) String 

func (x *TagEntry) String() string

type TenantRequest 

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

func (*TenantRequest) Descriptor deprecated 

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

Deprecated: Use TenantRequest.ProtoReflect.Descriptor instead.

func (*TenantRequest) GetTenant 

func (x *TenantRequest) GetTenant() string

func (*TenantRequest) ProtoMessage 

func (*TenantRequest) ProtoMessage()

func (*TenantRequest) ProtoReflect 

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

func (*TenantRequest) Reset 

func (x *TenantRequest) Reset()

func (*TenantRequest) String 

func (x *TenantRequest) String() string

type UnimplementedRecordServiceServer 

type UnimplementedRecordServiceServer struct {
}

UnimplementedRecordServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRecordServiceServer) AddKeyRange 

func (UnimplementedRecordServiceServer) AddKeyRange(context.Context, *KeyRange) (*emptypb.Empty, error)

func (UnimplementedRecordServiceServer) BinGet added in v1.1.1 

func (UnimplementedRecordServiceServer) BinGet(context.Context, *BinGetRequest) (*BinEntry, error)

func (UnimplementedRecordServiceServer) BinPut added in v1.1.1 

func (UnimplementedRecordServiceServer) BinPut(context.Context, *BinPutRequest) (*emptypb.Empty, error)

func (UnimplementedRecordServiceServer) BinRemove added in v1.1.1 

func (UnimplementedRecordServiceServer) BinRemove(context.Context, *BinRemoveRequest) (*emptypb.Empty, error)

func (UnimplementedRecordServiceServer) Create 

func (UnimplementedRecordServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedRecordServiceServer) Delete 

func (UnimplementedRecordServiceServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)

func (UnimplementedRecordServiceServer) DeleteFile added in v1.0.5 

func (UnimplementedRecordServiceServer) DeleteFile(context.Context, *DeleteFileRequest) (*emptypb.Empty, error)

func (UnimplementedRecordServiceServer) DownloadFile added in v1.0.3 

func (UnimplementedRecordServiceServer) DownloadFile(*DownloadFileRequest, RecordService_DownloadFileServer) error

func (UnimplementedRecordServiceServer) Get 

func (UnimplementedRecordServiceServer) Get(context.Context, *GetRequest) (*RecordEntry, error)

func (UnimplementedRecordServiceServer) GetInfo added in v1.1.1 

func (UnimplementedRecordServiceServer) GetInfo(context.Context, *TenantRequest) (*Info, error)

func (UnimplementedRecordServiceServer) GetKeyCapacity 

func (UnimplementedRecordServiceServer) GetKeyCapacity(context.Context, *TenantRequest) (*KeyCapacity, error)

func (UnimplementedRecordServiceServer) Lookup 

func (UnimplementedRecordServiceServer) Lookup(context.Context, *LookupRequest) (*RecordEntry, error)

func (UnimplementedRecordServiceServer) MapGet 

func (UnimplementedRecordServiceServer) MapGet(context.Context, *MapGetRequest) (*MapEntry, error)

func (UnimplementedRecordServiceServer) MapPut 

func (UnimplementedRecordServiceServer) MapPut(context.Context, *MapPutRequest) (*emptypb.Empty, error)

func (UnimplementedRecordServiceServer) MapRange 

func (UnimplementedRecordServiceServer) MapRange(*MapRangeRequest, RecordService_MapRangeServer) error

func (UnimplementedRecordServiceServer) MapRemove 

func (UnimplementedRecordServiceServer) MapRemove(context.Context, *MapRemoveRequest) (*emptypb.Empty, error)

func (UnimplementedRecordServiceServer) Scan 

func (UnimplementedRecordServiceServer) Scan(*ScanRequest, RecordService_ScanServer) error

func (UnimplementedRecordServiceServer) Search 

func (UnimplementedRecordServiceServer) Search(*SearchRequest, RecordService_SearchServer) error

func (UnimplementedRecordServiceServer) Update 

func (UnimplementedRecordServiceServer) Update(context.Context, *UpdateRequest) (*emptypb.Empty, error)

func (UnimplementedRecordServiceServer) UploadFile added in v1.0.3 

func (UnimplementedRecordServiceServer) UploadFile(RecordService_UploadFileServer) error

type UnsafeRecordServiceServer 

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

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

type UpdateRequest 

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
}

func (*UpdateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetAttributes 

func (x *UpdateRequest) GetAttributes() []*AttributeEntry

func (*UpdateRequest) GetBins added in v1.1.1 

func (x *UpdateRequest) GetBins() []*BinEntry

func (*UpdateRequest) GetPrimaryKey 

func (x *UpdateRequest) GetPrimaryKey() string

func (*UpdateRequest) GetTags 

func (x *UpdateRequest) GetTags() []string

func (*UpdateRequest) GetTenant 

func (x *UpdateRequest) GetTenant() string

func (*UpdateRequest) GetUpdateType 

func (x *UpdateRequest) GetUpdateType() UpdateType

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 UpdateType 

type UpdateType int32
const (
	UpdateType_UNKNOWN_TYPE UpdateType = 0
	UpdateType_MERGE        UpdateType = 1
	UpdateType_REPLACE      UpdateType = 2
)

func (UpdateType) Descriptor 

func (UpdateType) Descriptor() protoreflect.EnumDescriptor

func (UpdateType) Enum 

func (x UpdateType) Enum() *UpdateType

func (UpdateType) EnumDescriptor deprecated 

func (UpdateType) EnumDescriptor() ([]byte, []int)

Deprecated: Use UpdateType.Descriptor instead.

func (UpdateType) Number 

func (x UpdateType) Number() protoreflect.EnumNumber

func (UpdateType) String 

func (x UpdateType) String() string

func (UpdateType) Type 

func (UpdateType) Type() protoreflect.EnumType

type UploadFileContent added in v1.0.3 

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
}

func (*UploadFileContent) Descriptor deprecated added in v1.0.3 

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

Deprecated: Use UploadFileContent.ProtoReflect.Descriptor instead.

func (*UploadFileContent) GetData added in v1.0.3 

func (x *UploadFileContent) GetData() []byte

func (*UploadFileContent) GetFileName added in v1.0.3 

func (x *UploadFileContent) GetFileName() string

func (*UploadFileContent) GetPrimaryKey added in v1.0.3 

func (x *UploadFileContent) GetPrimaryKey() string

func (*UploadFileContent) GetTenant added in v1.0.3 

func (x *UploadFileContent) GetTenant() string

func (*UploadFileContent) ProtoMessage added in v1.0.3 

func (*UploadFileContent) ProtoMessage()

func (*UploadFileContent) ProtoReflect added in v1.0.3 

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

func (*UploadFileContent) Reset added in v1.0.3 

func (x *UploadFileContent) Reset()

func (*UploadFileContent) String added in v1.0.3 

func (x *UploadFileContent) String() string

type UploadFileRequest added in v1.0.6 

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
}

func (*UploadFileRequest) Descriptor deprecated added in v1.0.6 

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

Deprecated: Use UploadFileRequest.ProtoReflect.Descriptor instead.

func (*UploadFileRequest) GetChunk added in v1.0.9 

func (x *UploadFileRequest) GetChunk() int32

func (*UploadFileRequest) GetData added in v1.0.6 

func (x *UploadFileRequest) GetData() []byte

func (*UploadFileRequest) GetFileName added in v1.0.6 

func (x *UploadFileRequest) GetFileName() string

func (*UploadFileRequest) GetLast added in v1.0.9 

func (x *UploadFileRequest) GetLast() bool

func (*UploadFileRequest) GetPrimaryKey added in v1.0.6 

func (x *UploadFileRequest) GetPrimaryKey() string

func (*UploadFileRequest) GetTenant added in v1.0.6 

func (x *UploadFileRequest) GetTenant() string

func (*UploadFileRequest) ProtoMessage added in v1.0.6 

func (*UploadFileRequest) ProtoMessage()

func (*UploadFileRequest) ProtoReflect added in v1.0.6 

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

func (*UploadFileRequest) Reset added in v1.0.6 

func (x *UploadFileRequest) Reset()

func (*UploadFileRequest) String added in v1.0.6 

func (x *UploadFileRequest) String() string

Source Files

View all Source files

Directories

Path Synopsis
third_party
protoc-gen-openapiv2/options

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.