recordpb

package module
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

README

recordpb

Record Service API Protobuf

Documentation

Overview

Package recordpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

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",
		1: "CREATE_OP",
		2: "UPDATE_OP",
		3: "DELETE_OP",
		4: "ADD_RANGE_OP",
		5: "MAP_PUT",
		6: "MAP_REMOVE",
	}
	CommandOperation_value = map[string]int32{
		"UNKNOWN_OP":   0,
		"CREATE_OP":    1,
		"UPDATE_OP":    2,
		"DELETE_OP":    3,
		"ADD_RANGE_OP": 4,
		"MAP_PUT":      5,
		"MAP_REMOVE":   6,
	}
)

Enum value maps for CommandOperation.

View Source 
var File_record_service_proto protoreflect.FileDescriptor
View Source 
var RecordService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "record.RecordService",
	HandlerType: (*RecordServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetCounts",
			Handler:    _RecordService_GetCounts_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: "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,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Search",
			Handler:       _RecordService_Search_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Scan",
			Handler:       _RecordService_Scan_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "MapRange",
			Handler:       _RecordService_MapRange_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "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

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 ColumnEntry 

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
}

keys stored inside the record, values stored inside the record

func (*ColumnEntry) Descriptor deprecated 

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

Deprecated: Use ColumnEntry.ProtoReflect.Descriptor instead.

func (*ColumnEntry) GetName 

func (x *ColumnEntry) GetName() string

func (*ColumnEntry) GetValue 

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

func (*ColumnEntry) ProtoMessage 

func (*ColumnEntry) ProtoMessage()

func (*ColumnEntry) ProtoReflect 

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

func (*ColumnEntry) Reset 

func (x *ColumnEntry) Reset()

func (*ColumnEntry) String 

func (x *ColumnEntry) String() string

type Command 

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
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetCreateReq 

func (x *Command) GetCreateReq() *CreateRequest

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) 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 = 1
	CommandOperation_UPDATE_OP    CommandOperation = 2
	CommandOperation_DELETE_OP    CommandOperation = 3
	CommandOperation_ADD_RANGE_OP CommandOperation = 4
	CommandOperation_MAP_PUT      CommandOperation = 5
	CommandOperation_MAP_REMOVE   CommandOperation = 6
)

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 Counts 

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
}

func (*Counts) Descriptor deprecated 

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

Deprecated: Use Counts.ProtoReflect.Descriptor instead.

func (*Counts) GetAttributes 

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

func (*Counts) GetColumns 

func (x *Counts) GetColumns() []*CountEntry

func (*Counts) GetTags 

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

func (*Counts) GetTenant 

func (x *Counts) GetTenant() string

func (*Counts) ProtoMessage 

func (*Counts) ProtoMessage()

func (*Counts) ProtoReflect 

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

func (*Counts) Reset 

func (x *Counts) Reset()

func (*Counts) String 

func (x *Counts) 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"`
	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
}

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

func (x *CreateRequest) GetColumns() []*ColumnEntry

func (*CreateRequest) GetFiles 

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

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 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 FileEntry 

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
}

keys stored inside the record, values stored outside of the record

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

func (x *FileEntry) GetName() string

func (*FileEntry) GetSize 

func (x *FileEntry) GetSize() int32

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"`
	FileContents bool   `protobuf:"varint,4,opt,name=file_contents,json=fileContents,proto3" json:"file_contents,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetFileContents 

func (x *GetRequest) GetFileContents() bool

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

func (*LookupRequest) Descriptor deprecated 

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

Deprecated: Use LookupRequest.ProtoReflect.Descriptor instead.

func (*LookupRequest) GetFileContents 

func (x *LookupRequest) GetFileContents() bool

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

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"`
	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 (*MapRangeRequest) Descriptor deprecated 

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

Deprecated: Use MapRangeRequest.ProtoReflect.Descriptor instead.

func (*MapRangeRequest) GetLimit 

func (x *MapRangeRequest) GetLimit() int32

func (*MapRangeRequest) GetOffset 

func (x *MapRangeRequest) GetOffset() int32

func (*MapRangeRequest) GetPrefix 

func (x *MapRangeRequest) GetPrefix() 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 MapValue 

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
}

func (*MapValue) Descriptor deprecated 

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

Deprecated: Use MapValue.ProtoReflect.Descriptor instead.

func (*MapValue) GetUpdated 

func (x *MapValue) GetUpdated() bool

func (*MapValue) GetValue 

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

func (*MapValue) ProtoMessage 

func (*MapValue) ProtoMessage()

func (*MapValue) ProtoReflect 

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

func (*MapValue) Reset 

func (x *MapValue) Reset()

func (*MapValue) String 

func (x *MapValue) 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
	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
}

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

func (x *RecordEntry) GetColumns() []*ColumnEntry

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 counts
	//
	GetCounts(ctx context.Context, in *emptypb.Empty, 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 *emptypb.Empty, 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)
}

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 counts
	//
	GetCounts(context.Context, *emptypb.Empty) (*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, *emptypb.Empty) (*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
}

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

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

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

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

func (UnimplementedRecordServiceServer) Delete 

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

func (UnimplementedRecordServiceServer) Get 

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

func (UnimplementedRecordServiceServer) GetCounts 

func (UnimplementedRecordServiceServer) GetCounts(context.Context, *emptypb.Empty) (*Counts, error)

func (UnimplementedRecordServiceServer) GetKeyCapacity 

func (UnimplementedRecordServiceServer) GetKeyCapacity(context.Context, *emptypb.Empty) (*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) (*MapValue, error)

func (UnimplementedRecordServiceServer) MapRange 

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

func (UnimplementedRecordServiceServer) MapRemove 

func (UnimplementedRecordServiceServer) MapRemove(context.Context, *MapRemoveRequest) (*MapValue, 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)

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

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

func (x *UpdateRequest) GetColumns() []*ColumnEntry

func (*UpdateRequest) GetFiles 

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

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

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.