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 ColumnEntry 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 Command struct {
	Operation    CommandOperation  `protobuf:"varint,1,opt,name=operation,proto3,enum=record.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"`
	KeyRange     *KeyRange         `protobuf:"bytes,5,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
	MapPutReq    *MapPutRequest    `protobuf:"bytes,6,opt,name=map_put_req,json=mapPutReq,proto3" json:"map_put_req,omitempty"`
	MapRemoveReq *MapRemoveRequest `protobuf:"bytes,7,opt,name=map_remove_req,json=mapRemoveReq,proto3" json:"map_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 Counts 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"`
	Columns    []*CountEntry `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,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"`
	Columns    []*ColumnEntry    `protobuf:"bytes,7,rep,name=columns,proto3" json:"columns,omitempty"`
	Files      []*FileEntry      `protobuf:"bytes,8,rep,name=files,proto3" json:"files,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 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 FileEntry struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	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"`
	// 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"`
	FileContents bool   `protobuf:"varint,4,opt,name=file_contents,json=fileContents,proto3" json:"file_contents,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=record.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"`
	FileContents bool       `protobuf:"varint,5,opt,name=file_contents,json=fileContents,proto3" json:"file_contents,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"`
	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 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 MapValue struct {
	Value   []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Updated bool   `protobuf:"varint,3,opt,name=updated,proto3" json:"updated,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
	Columns []*ColumnEntry `protobuf:"bytes,12,rep,name=columns,proto3" json:"columns,omitempty"`
	// values stored outside of record
	Files []*FileEntry `protobuf:"bytes,13,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

type RecordServiceClient interface {
	//
	// Gets attributes counts
	//
	GetCounts(ctx context.Context, in *TenantRequest, opts ...grpc.CallOption) (*Counts, 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 attributes
	//
	Update(ctx context.Context, in *UpdateRequest, 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. Returns old value.
	//
	MapPut(ctx context.Context, in *MapPutRequest, opts ...grpc.CallOption) (*MapValue, error)
	//
	// Remove map value associated with the record. Returns old value.
	//
	MapRemove(ctx context.Context, in *MapRemoveRequest, opts ...grpc.CallOption) (*MapValue, error)
	//
	// Scan all map key-value pairs
	//
	MapRange(ctx context.Context, in *MapRangeRequest, opts ...grpc.CallOption) (RecordService_MapRangeClient, error)
}

type RecordServiceServer interface {
	//
	// Gets attributes counts
	//
	GetCounts(context.Context, *TenantRequest) (*Counts, 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 attributes
	//
	Update(context.Context, *UpdateRequest) (*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. Returns old value.
	//
	MapPut(context.Context, *MapPutRequest) (*MapValue, error)
	//
	// Remove map value associated with the record. Returns old value.
	//
	MapRemove(context.Context, *MapRemoveRequest) (*MapValue, error)
	//
	// Scan all map key-value pairs
	//
	MapRange(*MapRangeRequest, RecordService_MapRangeServer) error
	// contains filtered or unexported methods
}

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 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=record.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=record.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"`
	Columns    []*ColumnEntry    `protobuf:"bytes,7,rep,name=columns,proto3" json:"columns,omitempty"`
	Files      []*FileEntry      `protobuf:"bytes,8,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

type UpdateType int32