schemas

package
v0.0.26 Latest Latest
Warning

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

 Go to latest Published: Apr 28, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	InlineKVWriteService_HelloWorld_FullMethodName             = "/ikvschemas.InlineKVWriteService/helloWorld"
	InlineKVWriteService_UpsertFieldValues_FullMethodName      = "/ikvschemas.InlineKVWriteService/upsertFieldValues"
	InlineKVWriteService_BatchUpsertFieldValues_FullMethodName = "/ikvschemas.InlineKVWriteService/batchUpsertFieldValues"
	InlineKVWriteService_DeleteFieldValues_FullMethodName      = "/ikvschemas.InlineKVWriteService/deleteFieldValues"
	InlineKVWriteService_BatchDeleteFieldValues_FullMethodName = "/ikvschemas.InlineKVWriteService/batchDeleteFieldValues"
	InlineKVWriteService_DeleteDocument_FullMethodName         = "/ikvschemas.InlineKVWriteService/deleteDocument"
	InlineKVWriteService_BatchDeleteDocuments_FullMethodName   = "/ikvschemas.InlineKVWriteService/batchDeleteDocuments"
	InlineKVWriteService_DropFields_FullMethodName             = "/ikvschemas.InlineKVWriteService/dropFields"
	InlineKVWriteService_GetUserStoreConfig_FullMethodName     = "/ikvschemas.InlineKVWriteService/getUserStoreConfig"
)
View Source 
const (
	AdminService_HealthCheck_FullMethodName = "/ikvschemas.AdminService/healthCheck"
)

Variables

View Source 
var (
	FieldType_name = map[int32]string{
		0: "UNKNOWN",
		1: "INT32",
		2: "INT64",
		3: "FLOAT32",
		4: "FLOAT64",
		5: "STRING",
		6: "BYTES",
		7: "BOOLEAN",
	}
	FieldType_value = map[string]int32{
		"UNKNOWN": 0,
		"INT32":   1,
		"INT64":   2,
		"FLOAT32": 3,
		"FLOAT64": 4,
		"STRING":  5,
		"BYTES":   6,
		"BOOLEAN": 7,
	}
)

Enum value maps for FieldType.

View Source 
var AdminService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ikvschemas.AdminService",
	HandlerType: (*AdminServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "healthCheck",
			Handler:    _AdminService_HealthCheck_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "services.proto",
}

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

View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_index_proto protoreflect.FileDescriptor
View Source 
var File_services_proto protoreflect.FileDescriptor
View Source 
var File_streaming_proto protoreflect.FileDescriptor
View Source 
var InlineKVWriteService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ikvschemas.InlineKVWriteService",
	HandlerType: (*InlineKVWriteServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "helloWorld",
			Handler:    _InlineKVWriteService_HelloWorld_Handler,
		},
		{
			MethodName: "upsertFieldValues",
			Handler:    _InlineKVWriteService_UpsertFieldValues_Handler,
		},
		{
			MethodName: "batchUpsertFieldValues",
			Handler:    _InlineKVWriteService_BatchUpsertFieldValues_Handler,
		},
		{
			MethodName: "deleteFieldValues",
			Handler:    _InlineKVWriteService_DeleteFieldValues_Handler,
		},
		{
			MethodName: "batchDeleteFieldValues",
			Handler:    _InlineKVWriteService_BatchDeleteFieldValues_Handler,
		},
		{
			MethodName: "deleteDocument",
			Handler:    _InlineKVWriteService_DeleteDocument_Handler,
		},
		{
			MethodName: "batchDeleteDocuments",
			Handler:    _InlineKVWriteService_BatchDeleteDocuments_Handler,
		},
		{
			MethodName: "dropFields",
			Handler:    _InlineKVWriteService_DropFields_Handler,
		},
		{
			MethodName: "getUserStoreConfig",
			Handler:    _InlineKVWriteService_GetUserStoreConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "services.proto",
}

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

Functions

func RegisterAdminServiceServer 

func RegisterAdminServiceServer(s grpc.ServiceRegistrar, srv AdminServiceServer)

func RegisterInlineKVWriteServiceServer 

func RegisterInlineKVWriteServiceServer(s grpc.ServiceRegistrar, srv InlineKVWriteServiceServer)

Types

type AccountCredentials 

type AccountCredentials struct {
	AccountId      string `protobuf:"bytes,1,opt,name=accountId,proto3" json:"accountId,omitempty"`
	AccountPasskey string `protobuf:"bytes,2,opt,name=accountPasskey,proto3" json:"accountPasskey,omitempty"`
	// contains filtered or unexported fields
}

func (*AccountCredentials) Descriptor deprecated 

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

Deprecated: Use AccountCredentials.ProtoReflect.Descriptor instead.

func (*AccountCredentials) GetAccountId 

func (x *AccountCredentials) GetAccountId() string

func (*AccountCredentials) GetAccountPasskey 

func (x *AccountCredentials) GetAccountPasskey() string

func (*AccountCredentials) ProtoMessage 

func (*AccountCredentials) ProtoMessage()

func (*AccountCredentials) ProtoReflect 

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

func (*AccountCredentials) Reset 

func (x *AccountCredentials) Reset()

func (*AccountCredentials) String 

func (x *AccountCredentials) String() string

type AdminServiceClient 

type AdminServiceClient interface {
	HealthCheck(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

AdminServiceClient is the client API for AdminService 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 NewAdminServiceClient 

func NewAdminServiceClient(cc grpc.ClientConnInterface) AdminServiceClient

type AdminServiceServer 

type AdminServiceServer interface {
	HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error)
	// contains filtered or unexported methods
}

AdminServiceServer is the server API for AdminService service. All implementations must embed UnimplementedAdminServiceServer for forward compatibility

type BatchDeleteDocumentsRequest 

type BatchDeleteDocumentsRequest struct {
	UserStoreContextInitializer *UserStoreContextInitializer `protobuf:"bytes,1,opt,name=userStoreContextInitializer,proto3" json:"userStoreContextInitializer,omitempty"`
	Timestamp                   *timestamppb.Timestamp       `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	DocumentIds                 []*IKVDocumentOnWire         `protobuf:"bytes,3,rep,name=documentIds,proto3" json:"documentIds,omitempty"`
	// contains filtered or unexported fields
}

Delete a batch of documents.

func (*BatchDeleteDocumentsRequest) Descriptor deprecated 

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

Deprecated: Use BatchDeleteDocumentsRequest.ProtoReflect.Descriptor instead.

func (*BatchDeleteDocumentsRequest) GetDocumentIds 

func (x *BatchDeleteDocumentsRequest) GetDocumentIds() []*IKVDocumentOnWire

func (*BatchDeleteDocumentsRequest) GetTimestamp 

func (x *BatchDeleteDocumentsRequest) GetTimestamp() *timestamppb.Timestamp

func (*BatchDeleteDocumentsRequest) GetUserStoreContextInitializer 

func (x *BatchDeleteDocumentsRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

func (*BatchDeleteDocumentsRequest) ProtoMessage 

func (*BatchDeleteDocumentsRequest) ProtoMessage()

func (*BatchDeleteDocumentsRequest) ProtoReflect 

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

func (*BatchDeleteDocumentsRequest) Reset 

func (x *BatchDeleteDocumentsRequest) Reset()

func (*BatchDeleteDocumentsRequest) String 

func (x *BatchDeleteDocumentsRequest) String() string

type BatchDeleteFieldValuesRequest 

type BatchDeleteFieldValuesRequest struct {
	UserStoreContextInitializer *UserStoreContextInitializer `protobuf:"bytes,1,opt,name=userStoreContextInitializer,proto3" json:"userStoreContextInitializer,omitempty"`
	Timestamp                   *timestamppb.Timestamp       `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	DocumentIds                 []*IKVDocumentOnWire         `protobuf:"bytes,3,rep,name=documentIds,proto3" json:"documentIds,omitempty"`
	FieldNames                  []string                     `protobuf:"bytes,4,rep,name=fieldNames,proto3" json:"fieldNames,omitempty"`
	// contains filtered or unexported fields
}

Delete fields from a batch of documents.

func (*BatchDeleteFieldValuesRequest) Descriptor deprecated 

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

Deprecated: Use BatchDeleteFieldValuesRequest.ProtoReflect.Descriptor instead.

func (*BatchDeleteFieldValuesRequest) GetDocumentIds 

func (x *BatchDeleteFieldValuesRequest) GetDocumentIds() []*IKVDocumentOnWire

func (*BatchDeleteFieldValuesRequest) GetFieldNames 

func (x *BatchDeleteFieldValuesRequest) GetFieldNames() []string

func (*BatchDeleteFieldValuesRequest) GetTimestamp 

func (x *BatchDeleteFieldValuesRequest) GetTimestamp() *timestamppb.Timestamp

func (*BatchDeleteFieldValuesRequest) GetUserStoreContextInitializer 

func (x *BatchDeleteFieldValuesRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

func (*BatchDeleteFieldValuesRequest) ProtoMessage 

func (*BatchDeleteFieldValuesRequest) ProtoMessage()

func (*BatchDeleteFieldValuesRequest) ProtoReflect 

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

func (*BatchDeleteFieldValuesRequest) Reset 

func (x *BatchDeleteFieldValuesRequest) Reset()

func (*BatchDeleteFieldValuesRequest) String 

func (x *BatchDeleteFieldValuesRequest) String() string

type BatchUpsertFieldValuesRequest 

type BatchUpsertFieldValuesRequest struct {
	UserStoreContextInitializer *UserStoreContextInitializer `protobuf:"bytes,1,opt,name=userStoreContextInitializer,proto3" json:"userStoreContextInitializer,omitempty"`
	Timestamp                   *timestamppb.Timestamp       `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Documents                   []*IKVDocumentOnWire         `protobuf:"bytes,3,rep,name=documents,proto3" json:"documents,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchUpsertFieldValuesRequest) Descriptor deprecated 

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

Deprecated: Use BatchUpsertFieldValuesRequest.ProtoReflect.Descriptor instead.

func (*BatchUpsertFieldValuesRequest) GetDocuments 

func (x *BatchUpsertFieldValuesRequest) GetDocuments() []*IKVDocumentOnWire

func (*BatchUpsertFieldValuesRequest) GetTimestamp 

func (x *BatchUpsertFieldValuesRequest) GetTimestamp() *timestamppb.Timestamp

func (*BatchUpsertFieldValuesRequest) GetUserStoreContextInitializer 

func (x *BatchUpsertFieldValuesRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

func (*BatchUpsertFieldValuesRequest) ProtoMessage 

func (*BatchUpsertFieldValuesRequest) ProtoMessage()

func (*BatchUpsertFieldValuesRequest) ProtoReflect 

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

func (*BatchUpsertFieldValuesRequest) Reset 

func (x *BatchUpsertFieldValuesRequest) Reset()

func (*BatchUpsertFieldValuesRequest) String 

func (x *BatchUpsertFieldValuesRequest) String() string

type CKVIndexHeader added in v0.0.20 

type CKVIndexHeader struct {

	// / Epoch (~ build time) of the current base index.
	BaseIndexEpochMillis uint64 `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

/ Index level headers and metadata.

func (*CKVIndexHeader) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use CKVIndexHeader.ProtoReflect.Descriptor instead.

func (*CKVIndexHeader) GetBaseIndexEpochMillis added in v0.0.20 

func (x *CKVIndexHeader) GetBaseIndexEpochMillis() uint64

func (*CKVIndexHeader) ProtoMessage added in v0.0.20 

func (*CKVIndexHeader) ProtoMessage()

func (*CKVIndexHeader) ProtoReflect added in v0.0.20 

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

func (*CKVIndexHeader) Reset added in v0.0.20 

func (x *CKVIndexHeader) Reset()

func (*CKVIndexHeader) String added in v0.0.20 

func (x *CKVIndexHeader) String() string

type CKVIndexSegmentMetadata added in v0.0.20 

type CKVIndexSegmentMetadata struct {

	// defaults to 0
	MmapWriteOffset uint64 `protobuf:"varint,1,opt,name=mmap_write_offset,json=mmapWriteOffset,proto3" json:"mmap_write_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*CKVIndexSegmentMetadata) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use CKVIndexSegmentMetadata.ProtoReflect.Descriptor instead.

func (*CKVIndexSegmentMetadata) GetMmapWriteOffset added in v0.0.20 

func (x *CKVIndexSegmentMetadata) GetMmapWriteOffset() uint64

func (*CKVIndexSegmentMetadata) ProtoMessage added in v0.0.20 

func (*CKVIndexSegmentMetadata) ProtoMessage()

func (*CKVIndexSegmentMetadata) ProtoReflect added in v0.0.20 

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

func (*CKVIndexSegmentMetadata) Reset added in v0.0.20 

func (x *CKVIndexSegmentMetadata) Reset()

func (*CKVIndexSegmentMetadata) String added in v0.0.20 

func (x *CKVIndexSegmentMetadata) String() string

type DeleteDoc added in v0.0.20 

type DeleteDoc struct {
	PrimaryKey []byte `protobuf:"bytes,1,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDoc) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use DeleteDoc.ProtoReflect.Descriptor instead.

func (*DeleteDoc) GetPrimaryKey added in v0.0.20 

func (x *DeleteDoc) GetPrimaryKey() []byte

func (*DeleteDoc) ProtoMessage added in v0.0.20 

func (*DeleteDoc) ProtoMessage()

func (*DeleteDoc) ProtoReflect added in v0.0.20 

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

func (*DeleteDoc) Reset added in v0.0.20 

func (x *DeleteDoc) Reset()

func (*DeleteDoc) String added in v0.0.20 

func (x *DeleteDoc) String() string

type DeleteDocFields added in v0.0.20 

type DeleteDocFields struct {
	PrimaryKey []byte   `protobuf:"bytes,1,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	FieldIds   []uint32 `protobuf:"varint,2,rep,packed,name=field_ids,json=fieldIds,proto3" json:"field_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDocFields) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use DeleteDocFields.ProtoReflect.Descriptor instead.

func (*DeleteDocFields) GetFieldIds added in v0.0.20 

func (x *DeleteDocFields) GetFieldIds() []uint32

func (*DeleteDocFields) GetPrimaryKey added in v0.0.20 

func (x *DeleteDocFields) GetPrimaryKey() []byte

func (*DeleteDocFields) ProtoMessage added in v0.0.20 

func (*DeleteDocFields) ProtoMessage()

func (*DeleteDocFields) ProtoReflect added in v0.0.20 

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

func (*DeleteDocFields) Reset added in v0.0.20 

func (x *DeleteDocFields) Reset()

func (*DeleteDocFields) String added in v0.0.20 

func (x *DeleteDocFields) String() string

type DeleteDocumentEvent 

type DeleteDocumentEvent struct {
	DocumentId *IKVDocumentOnWire `protobuf:"bytes,1,opt,name=documentId,proto3" json:"documentId,omitempty"`
	// contains filtered or unexported fields
}

Delete specified document.

func (*DeleteDocumentEvent) Descriptor deprecated 

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

Deprecated: Use DeleteDocumentEvent.ProtoReflect.Descriptor instead.

func (*DeleteDocumentEvent) GetDocumentId 

func (x *DeleteDocumentEvent) GetDocumentId() *IKVDocumentOnWire

func (*DeleteDocumentEvent) ProtoMessage 

func (*DeleteDocumentEvent) ProtoMessage()

func (*DeleteDocumentEvent) ProtoReflect 

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

func (*DeleteDocumentEvent) Reset 

func (x *DeleteDocumentEvent) Reset()

func (*DeleteDocumentEvent) String 

func (x *DeleteDocumentEvent) String() string

type DeleteDocumentFieldsEvent 

type DeleteDocumentFieldsEvent struct {
	DocumentId     *IKVDocumentOnWire `protobuf:"bytes,1,opt,name=documentId,proto3" json:"documentId,omitempty"`
	FieldsToDelete []string           `protobuf:"bytes,2,rep,name=fieldsToDelete,proto3" json:"fieldsToDelete,omitempty"`
	// contains filtered or unexported fields
}

Delete specified fields for specified document.

func (*DeleteDocumentFieldsEvent) Descriptor deprecated 

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

Deprecated: Use DeleteDocumentFieldsEvent.ProtoReflect.Descriptor instead.

func (*DeleteDocumentFieldsEvent) GetDocumentId 

func (x *DeleteDocumentFieldsEvent) GetDocumentId() *IKVDocumentOnWire

func (*DeleteDocumentFieldsEvent) GetFieldsToDelete 

func (x *DeleteDocumentFieldsEvent) GetFieldsToDelete() []string

func (*DeleteDocumentFieldsEvent) ProtoMessage 

func (*DeleteDocumentFieldsEvent) ProtoMessage()

func (*DeleteDocumentFieldsEvent) ProtoReflect 

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

func (*DeleteDocumentFieldsEvent) Reset 

func (x *DeleteDocumentFieldsEvent) Reset()

func (*DeleteDocumentFieldsEvent) String 

func (x *DeleteDocumentFieldsEvent) String() string

type DeleteDocumentRequest 

type DeleteDocumentRequest struct {
	UserStoreContextInitializer *UserStoreContextInitializer `protobuf:"bytes,1,opt,name=userStoreContextInitializer,proto3" json:"userStoreContextInitializer,omitempty"`
	Timestamp                   *timestamppb.Timestamp       `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	DocumentId                  *IKVDocumentOnWire           `protobuf:"bytes,3,opt,name=documentId,proto3" json:"documentId,omitempty"`
	// contains filtered or unexported fields
}

Delete a document.

func (*DeleteDocumentRequest) Descriptor deprecated 

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

Deprecated: Use DeleteDocumentRequest.ProtoReflect.Descriptor instead.

func (*DeleteDocumentRequest) GetDocumentId 

func (x *DeleteDocumentRequest) GetDocumentId() *IKVDocumentOnWire

func (*DeleteDocumentRequest) GetTimestamp 

func (x *DeleteDocumentRequest) GetTimestamp() *timestamppb.Timestamp

func (*DeleteDocumentRequest) GetUserStoreContextInitializer 

func (x *DeleteDocumentRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

func (*DeleteDocumentRequest) ProtoMessage 

func (*DeleteDocumentRequest) ProtoMessage()

func (*DeleteDocumentRequest) ProtoReflect 

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

func (*DeleteDocumentRequest) Reset 

func (x *DeleteDocumentRequest) Reset()

func (*DeleteDocumentRequest) String 

func (x *DeleteDocumentRequest) String() string

type DeleteFieldValueRequest 

type DeleteFieldValueRequest struct {
	UserStoreContextInitializer *UserStoreContextInitializer `protobuf:"bytes,1,opt,name=userStoreContextInitializer,proto3" json:"userStoreContextInitializer,omitempty"`
	Timestamp                   *timestamppb.Timestamp       `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	DocumentId                  *IKVDocumentOnWire           `protobuf:"bytes,3,opt,name=documentId,proto3" json:"documentId,omitempty"`
	FieldNames                  []string                     `protobuf:"bytes,4,rep,name=fieldNames,proto3" json:"fieldNames,omitempty"`
	// contains filtered or unexported fields
}

Delete fields from a document.

func (*DeleteFieldValueRequest) Descriptor deprecated 

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

Deprecated: Use DeleteFieldValueRequest.ProtoReflect.Descriptor instead.

func (*DeleteFieldValueRequest) GetDocumentId 

func (x *DeleteFieldValueRequest) GetDocumentId() *IKVDocumentOnWire

func (*DeleteFieldValueRequest) GetFieldNames 

func (x *DeleteFieldValueRequest) GetFieldNames() []string

func (*DeleteFieldValueRequest) GetTimestamp 

func (x *DeleteFieldValueRequest) GetTimestamp() *timestamppb.Timestamp

func (*DeleteFieldValueRequest) GetUserStoreContextInitializer 

func (x *DeleteFieldValueRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

func (*DeleteFieldValueRequest) ProtoMessage 

func (*DeleteFieldValueRequest) ProtoMessage()

func (*DeleteFieldValueRequest) ProtoReflect 

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

func (*DeleteFieldValueRequest) Reset 

func (x *DeleteFieldValueRequest) Reset()

func (*DeleteFieldValueRequest) String 

func (x *DeleteFieldValueRequest) String() string

type DropFieldEvent added in v0.0.20 

type DropFieldEvent struct {

	// field name list (exact match required)
	FieldNames []string `protobuf:"bytes,1,rep,name=field_names,json=fieldNames,proto3" json:"field_names,omitempty"`
	// field name prefix list (exact match required)
	FieldNamePrefixes []string `protobuf:"bytes,2,rep,name=field_name_prefixes,json=fieldNamePrefixes,proto3" json:"field_name_prefixes,omitempty"`
	// CAUTION! drops all except primary-key
	// Only checked if field_names and field_name_prefixes are empty
	// set to false when not populated by proto3
	DropAll bool `protobuf:"varint,3,opt,name=drop_all,json=dropAll,proto3" json:"drop_all,omitempty"`
	// contains filtered or unexported fields
}

Drop (delete) field(s) from all documents. No-op if the fields don't exist. Attempts to delete primary-key will be ignored.

func (*DropFieldEvent) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use DropFieldEvent.ProtoReflect.Descriptor instead.

func (*DropFieldEvent) GetDropAll added in v0.0.20 

func (x *DropFieldEvent) GetDropAll() bool

func (*DropFieldEvent) GetFieldNamePrefixes added in v0.0.20 

func (x *DropFieldEvent) GetFieldNamePrefixes() []string

func (*DropFieldEvent) GetFieldNames added in v0.0.20 

func (x *DropFieldEvent) GetFieldNames() []string

func (*DropFieldEvent) ProtoMessage added in v0.0.20 

func (*DropFieldEvent) ProtoMessage()

func (*DropFieldEvent) ProtoReflect added in v0.0.20 

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

func (*DropFieldEvent) Reset added in v0.0.20 

func (x *DropFieldEvent) Reset()

func (*DropFieldEvent) String added in v0.0.20 

func (x *DropFieldEvent) String() string

type DropFieldsRequest added in v0.0.20 

type DropFieldsRequest struct {
	UserStoreContextInitializer *UserStoreContextInitializer `protobuf:"bytes,1,opt,name=userStoreContextInitializer,proto3" json:"userStoreContextInitializer,omitempty"`
	Timestamp                   *timestamppb.Timestamp       `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	FieldNames                  []string                     `protobuf:"bytes,3,rep,name=field_names,json=fieldNames,proto3" json:"field_names,omitempty"`
	FieldNamePrefixes           []string                     `protobuf:"bytes,4,rep,name=field_name_prefixes,json=fieldNamePrefixes,proto3" json:"field_name_prefixes,omitempty"`
	DropAll                     bool                         `protobuf:"varint,5,opt,name=drop_all,json=dropAll,proto3" json:"drop_all,omitempty"`
	// contains filtered or unexported fields
}

Drop (delete) field(s) from all documents. No-op if the fields don't exist. Attempts to delete primary-key will be ignored.

func (*DropFieldsRequest) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use DropFieldsRequest.ProtoReflect.Descriptor instead.

func (*DropFieldsRequest) GetDropAll added in v0.0.20 

func (x *DropFieldsRequest) GetDropAll() bool

func (*DropFieldsRequest) GetFieldNamePrefixes added in v0.0.20 

func (x *DropFieldsRequest) GetFieldNamePrefixes() []string

func (*DropFieldsRequest) GetFieldNames added in v0.0.20 

func (x *DropFieldsRequest) GetFieldNames() []string

func (*DropFieldsRequest) GetTimestamp added in v0.0.20 

func (x *DropFieldsRequest) GetTimestamp() *timestamppb.Timestamp

func (*DropFieldsRequest) GetUserStoreContextInitializer added in v0.0.20 

func (x *DropFieldsRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

func (*DropFieldsRequest) ProtoMessage added in v0.0.20 

func (*DropFieldsRequest) ProtoMessage()

func (*DropFieldsRequest) ProtoReflect added in v0.0.20 

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

func (*DropFieldsRequest) Reset added in v0.0.20 

func (x *DropFieldsRequest) Reset()

func (*DropFieldsRequest) String added in v0.0.20 

func (x *DropFieldsRequest) String() string

type EventHeader 

type EventHeader struct {
	SourceTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=sourceTimestamp,proto3,oneof" json:"sourceTimestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*EventHeader) Descriptor deprecated 

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

Deprecated: Use EventHeader.ProtoReflect.Descriptor instead.

func (*EventHeader) GetSourceTimestamp 

func (x *EventHeader) GetSourceTimestamp() *timestamppb.Timestamp

func (*EventHeader) ProtoMessage 

func (*EventHeader) ProtoMessage()

func (*EventHeader) ProtoReflect 

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

func (*EventHeader) Reset 

func (x *EventHeader) Reset()

func (*EventHeader) String 

func (x *EventHeader) String() string

type FieldSchema 

type FieldSchema struct {

	// the case-sensitive field name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// unique field-id. `name` and `id`
	// have 1:1 mappings.
	Id        int32     `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	FieldType FieldType `protobuf:"varint,3,opt,name=fieldType,proto3,enum=ikvschemas.FieldType" json:"fieldType,omitempty"`
	// contains filtered or unexported fields
}

TODO: inspect TO BE DEPRECATED

func (*FieldSchema) Descriptor deprecated 

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

Deprecated: Use FieldSchema.ProtoReflect.Descriptor instead.

func (*FieldSchema) GetFieldType 

func (x *FieldSchema) GetFieldType() FieldType

func (*FieldSchema) GetId 

func (x *FieldSchema) GetId() int32

func (*FieldSchema) GetName 

func (x *FieldSchema) GetName() string

func (*FieldSchema) ProtoMessage 

func (*FieldSchema) ProtoMessage()

func (*FieldSchema) ProtoReflect 

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

func (*FieldSchema) Reset 

func (x *FieldSchema) Reset()

func (*FieldSchema) String 

func (x *FieldSchema) String() string

type FieldType 

type FieldType int32
const (
	// usually signifies writer/producer is ahead
	// w.r.t the symbol list
	FieldType_UNKNOWN FieldType = 0
	FieldType_INT32   FieldType = 1
	FieldType_INT64   FieldType = 2
	FieldType_FLOAT32 FieldType = 3
	FieldType_FLOAT64 FieldType = 4
	FieldType_STRING  FieldType = 5
	FieldType_BYTES   FieldType = 6
	FieldType_BOOLEAN FieldType = 7
)

func (FieldType) Descriptor 

func (FieldType) Descriptor() protoreflect.EnumDescriptor

func (FieldType) Enum 

func (x FieldType) Enum() *FieldType

func (FieldType) EnumDescriptor deprecated 

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

Deprecated: Use FieldType.Descriptor instead.

func (FieldType) Number 

func (x FieldType) Number() protoreflect.EnumNumber

func (FieldType) String 

func (x FieldType) String() string

func (FieldType) Type 

func (FieldType) Type() protoreflect.EnumType

type FieldValue 

type FieldValue struct {
	FieldType FieldType `protobuf:"varint,1,opt,name=fieldType,proto3,enum=ikvschemas.FieldType" json:"fieldType,omitempty"`
	Value     []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldValue) Descriptor deprecated 

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

Deprecated: Use FieldValue.ProtoReflect.Descriptor instead.

func (*FieldValue) GetFieldType 

func (x *FieldValue) GetFieldType() FieldType

func (*FieldValue) GetValue 

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

func (*FieldValue) ProtoMessage 

func (*FieldValue) ProtoMessage()

func (*FieldValue) ProtoReflect 

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

func (*FieldValue) Reset 

func (x *FieldValue) Reset()

func (*FieldValue) String 

func (x *FieldValue) String() string

type GetUserStoreConfigRequest 

type GetUserStoreConfigRequest struct {
	UserStoreContextInitializer *UserStoreContextInitializer `protobuf:"bytes,1,opt,name=userStoreContextInitializer,proto3" json:"userStoreContextInitializer,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserStoreConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetUserStoreConfigRequest.ProtoReflect.Descriptor instead.

func (*GetUserStoreConfigRequest) GetUserStoreContextInitializer 

func (x *GetUserStoreConfigRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

func (*GetUserStoreConfigRequest) ProtoMessage 

func (*GetUserStoreConfigRequest) ProtoMessage()

func (*GetUserStoreConfigRequest) ProtoReflect 

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

func (*GetUserStoreConfigRequest) Reset 

func (x *GetUserStoreConfigRequest) Reset()

func (*GetUserStoreConfigRequest) String 

func (x *GetUserStoreConfigRequest) String() string

type GetUserStoreConfigResponse 

type GetUserStoreConfigResponse struct {
	GlobalConfig *IKVStoreConfig `protobuf:"bytes,1,opt,name=globalConfig,proto3" json:"globalConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserStoreConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetUserStoreConfigResponse.ProtoReflect.Descriptor instead.

func (*GetUserStoreConfigResponse) GetGlobalConfig 

func (x *GetUserStoreConfigResponse) GetGlobalConfig() *IKVStoreConfig

func (*GetUserStoreConfigResponse) ProtoMessage 

func (*GetUserStoreConfigResponse) ProtoMessage()

func (*GetUserStoreConfigResponse) ProtoReflect 

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

func (*GetUserStoreConfigResponse) Reset 

func (x *GetUserStoreConfigResponse) Reset()

func (*GetUserStoreConfigResponse) String 

func (x *GetUserStoreConfigResponse) String() string

type HealthCheckResponse 

type HealthCheckResponse struct {

	// health status <-> code value mapping
	// is defined in AWS ALB health check
	// settings.
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetCode 

func (x *HealthCheckResponse) GetCode() int32

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type HelloWorldRequest 

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

func (*HelloWorldRequest) Descriptor deprecated 

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

Deprecated: Use HelloWorldRequest.ProtoReflect.Descriptor instead.

func (*HelloWorldRequest) GetEcho 

func (x *HelloWorldRequest) GetEcho() string

func (*HelloWorldRequest) ProtoMessage 

func (*HelloWorldRequest) ProtoMessage()

func (*HelloWorldRequest) ProtoReflect 

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

func (*HelloWorldRequest) Reset 

func (x *HelloWorldRequest) Reset()

func (*HelloWorldRequest) String 

func (x *HelloWorldRequest) String() string

type HelloWorldResponse 

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

func (*HelloWorldResponse) Descriptor deprecated 

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

Deprecated: Use HelloWorldResponse.ProtoReflect.Descriptor instead.

func (*HelloWorldResponse) GetEcho 

func (x *HelloWorldResponse) GetEcho() string

func (*HelloWorldResponse) ProtoMessage 

func (*HelloWorldResponse) ProtoMessage()

func (*HelloWorldResponse) ProtoReflect 

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

func (*HelloWorldResponse) Reset 

func (x *HelloWorldResponse) Reset()

func (*HelloWorldResponse) String 

func (x *HelloWorldResponse) String() string

type IKVDataEvent 

type IKVDataEvent struct {
	EventHeader *EventHeader `protobuf:"bytes,1,opt,name=eventHeader,proto3" json:"eventHeader,omitempty"`
	// event data (upsert, delete, etc...)
	//
	// Types that are assignable to Event:
	//
	//	*IKVDataEvent_UpsertDocumentFieldsEvent
	//	*IKVDataEvent_DeleteDocumentFieldsEvent
	//	*IKVDataEvent_DeleteDocumentEvent
	//	*IKVDataEvent_DropFieldEvent
	Event isIKVDataEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*IKVDataEvent) Descriptor deprecated 

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

Deprecated: Use IKVDataEvent.ProtoReflect.Descriptor instead.

func (*IKVDataEvent) GetDeleteDocumentEvent 

func (x *IKVDataEvent) GetDeleteDocumentEvent() *DeleteDocumentEvent

func (*IKVDataEvent) GetDeleteDocumentFieldsEvent 

func (x *IKVDataEvent) GetDeleteDocumentFieldsEvent() *DeleteDocumentFieldsEvent

func (*IKVDataEvent) GetDropFieldEvent added in v0.0.20 

func (x *IKVDataEvent) GetDropFieldEvent() *DropFieldEvent

func (*IKVDataEvent) GetEvent 

func (m *IKVDataEvent) GetEvent() isIKVDataEvent_Event

func (*IKVDataEvent) GetEventHeader 

func (x *IKVDataEvent) GetEventHeader() *EventHeader

func (*IKVDataEvent) GetUpsertDocumentFieldsEvent 

func (x *IKVDataEvent) GetUpsertDocumentFieldsEvent() *UpsertDocumentFieldsEvent

func (*IKVDataEvent) ProtoMessage 

func (*IKVDataEvent) ProtoMessage()

func (*IKVDataEvent) ProtoReflect 

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

func (*IKVDataEvent) Reset 

func (x *IKVDataEvent) Reset()

func (*IKVDataEvent) String 

func (x *IKVDataEvent) String() string

type IKVDataEvent_DeleteDocumentEvent 

type IKVDataEvent_DeleteDocumentEvent struct {
	DeleteDocumentEvent *DeleteDocumentEvent `protobuf:"bytes,4,opt,name=deleteDocumentEvent,proto3,oneof"`
}

type IKVDataEvent_DeleteDocumentFieldsEvent 

type IKVDataEvent_DeleteDocumentFieldsEvent struct {
	DeleteDocumentFieldsEvent *DeleteDocumentFieldsEvent `protobuf:"bytes,3,opt,name=deleteDocumentFieldsEvent,proto3,oneof"`
}

type IKVDataEvent_DropFieldEvent added in v0.0.20 

type IKVDataEvent_DropFieldEvent struct {
	DropFieldEvent *DropFieldEvent `protobuf:"bytes,5,opt,name=dropFieldEvent,proto3,oneof"`
}

type IKVDataEvent_UpsertDocumentFieldsEvent 

type IKVDataEvent_UpsertDocumentFieldsEvent struct {
	UpsertDocumentFieldsEvent *UpsertDocumentFieldsEvent `protobuf:"bytes,2,opt,name=upsertDocumentFieldsEvent,proto3,oneof"`
}

type IKVDocumentOnWire 

type IKVDocumentOnWire struct {

	// field_name vs field_value
	Document map[string]*FieldValue `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*IKVDocumentOnWire) Descriptor deprecated 

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

Deprecated: Use IKVDocumentOnWire.ProtoReflect.Descriptor instead.

func (*IKVDocumentOnWire) GetDocument 

func (x *IKVDocumentOnWire) GetDocument() map[string]*FieldValue

func (*IKVDocumentOnWire) ProtoMessage 

func (*IKVDocumentOnWire) ProtoMessage()

func (*IKVDocumentOnWire) ProtoReflect 

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

func (*IKVDocumentOnWire) Reset 

func (x *IKVDocumentOnWire) Reset()

func (*IKVDocumentOnWire) String 

func (x *IKVDocumentOnWire) String() string

type IKVStoreConfig 

type IKVStoreConfig struct {

	// Map key uniquely defines a config key
	// Config keys are unique across all typed maps
	StringConfigs  map[string]string  `` /* 167-byte string literal not displayed */
	IntConfigs     map[string]int64   `` /* 162-byte string literal not displayed */
	FloatConfigs   map[string]float32 `` /* 167-byte string literal not displayed */
	BytesConfigs   map[string][]byte  `` /* 165-byte string literal not displayed */
	BooleanConfigs map[string]bool    `` /* 170-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*IKVStoreConfig) Descriptor deprecated 

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

Deprecated: Use IKVStoreConfig.ProtoReflect.Descriptor instead.

func (*IKVStoreConfig) GetBooleanConfigs 

func (x *IKVStoreConfig) GetBooleanConfigs() map[string]bool

func (*IKVStoreConfig) GetBytesConfigs 

func (x *IKVStoreConfig) GetBytesConfigs() map[string][]byte

func (*IKVStoreConfig) GetFloatConfigs 

func (x *IKVStoreConfig) GetFloatConfigs() map[string]float32

func (*IKVStoreConfig) GetIntConfigs 

func (x *IKVStoreConfig) GetIntConfigs() map[string]int64

func (*IKVStoreConfig) GetStringConfigs 

func (x *IKVStoreConfig) GetStringConfigs() map[string]string

func (*IKVStoreConfig) ProtoMessage 

func (*IKVStoreConfig) ProtoMessage()

func (*IKVStoreConfig) ProtoReflect 

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

func (*IKVStoreConfig) Reset 

func (x *IKVStoreConfig) Reset()

func (*IKVStoreConfig) String 

func (x *IKVStoreConfig) String() string

type InlineKVWriteServiceClient 

type InlineKVWriteServiceClient interface {
	HelloWorld(ctx context.Context, in *HelloWorldRequest, opts ...grpc.CallOption) (*HelloWorldResponse, error)
	// Write methods
	UpsertFieldValues(ctx context.Context, in *UpsertFieldValuesRequest, opts ...grpc.CallOption) (*Status, error)
	BatchUpsertFieldValues(ctx context.Context, in *BatchUpsertFieldValuesRequest, opts ...grpc.CallOption) (*Status, error)
	DeleteFieldValues(ctx context.Context, in *DeleteFieldValueRequest, opts ...grpc.CallOption) (*Status, error)
	BatchDeleteFieldValues(ctx context.Context, in *BatchDeleteFieldValuesRequest, opts ...grpc.CallOption) (*Status, error)
	DeleteDocument(ctx context.Context, in *DeleteDocumentRequest, opts ...grpc.CallOption) (*Status, error)
	BatchDeleteDocuments(ctx context.Context, in *BatchDeleteDocumentsRequest, opts ...grpc.CallOption) (*Status, error)
	DropFields(ctx context.Context, in *DropFieldsRequest, opts ...grpc.CallOption) (*Status, error)
	// Gateway-specified configuration
	GetUserStoreConfig(ctx context.Context, in *GetUserStoreConfigRequest, opts ...grpc.CallOption) (*GetUserStoreConfigResponse, error)
}

InlineKVWriteServiceClient is the client API for InlineKVWriteService 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 NewInlineKVWriteServiceClient 

func NewInlineKVWriteServiceClient(cc grpc.ClientConnInterface) InlineKVWriteServiceClient

type InlineKVWriteServiceServer 

type InlineKVWriteServiceServer interface {
	HelloWorld(context.Context, *HelloWorldRequest) (*HelloWorldResponse, error)
	// Write methods
	UpsertFieldValues(context.Context, *UpsertFieldValuesRequest) (*Status, error)
	BatchUpsertFieldValues(context.Context, *BatchUpsertFieldValuesRequest) (*Status, error)
	DeleteFieldValues(context.Context, *DeleteFieldValueRequest) (*Status, error)
	BatchDeleteFieldValues(context.Context, *BatchDeleteFieldValuesRequest) (*Status, error)
	DeleteDocument(context.Context, *DeleteDocumentRequest) (*Status, error)
	BatchDeleteDocuments(context.Context, *BatchDeleteDocumentsRequest) (*Status, error)
	DropFields(context.Context, *DropFieldsRequest) (*Status, error)
	// Gateway-specified configuration
	GetUserStoreConfig(context.Context, *GetUserStoreConfigRequest) (*GetUserStoreConfigResponse, error)
	// contains filtered or unexported methods
}

InlineKVWriteServiceServer is the server API for InlineKVWriteService service. All implementations must embed UnimplementedInlineKVWriteServiceServer for forward compatibility

type KafkaOffsetStore added in v0.0.20 

type KafkaOffsetStore struct {
	Entries []*KafkaOffsetStoreEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaOffsetStore) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use KafkaOffsetStore.ProtoReflect.Descriptor instead.

func (*KafkaOffsetStore) GetEntries added in v0.0.20 

func (x *KafkaOffsetStore) GetEntries() []*KafkaOffsetStoreEntry

func (*KafkaOffsetStore) ProtoMessage added in v0.0.20 

func (*KafkaOffsetStore) ProtoMessage()

func (*KafkaOffsetStore) ProtoReflect added in v0.0.20 

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

func (*KafkaOffsetStore) Reset added in v0.0.20 

func (x *KafkaOffsetStore) Reset()

func (*KafkaOffsetStore) String added in v0.0.20 

func (x *KafkaOffsetStore) String() string

type KafkaOffsetStoreEntry added in v0.0.20 

type KafkaOffsetStoreEntry struct {
	Topic     string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition int32  `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset    int64  `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaOffsetStoreEntry) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use KafkaOffsetStoreEntry.ProtoReflect.Descriptor instead.

func (*KafkaOffsetStoreEntry) GetOffset added in v0.0.20 

func (x *KafkaOffsetStoreEntry) GetOffset() int64

func (*KafkaOffsetStoreEntry) GetPartition added in v0.0.20 

func (x *KafkaOffsetStoreEntry) GetPartition() int32

func (*KafkaOffsetStoreEntry) GetTopic added in v0.0.20 

func (x *KafkaOffsetStoreEntry) GetTopic() string

func (*KafkaOffsetStoreEntry) ProtoMessage added in v0.0.20 

func (*KafkaOffsetStoreEntry) ProtoMessage()

func (*KafkaOffsetStoreEntry) ProtoReflect added in v0.0.20 

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

func (*KafkaOffsetStoreEntry) Reset added in v0.0.20 

func (x *KafkaOffsetStoreEntry) Reset()

func (*KafkaOffsetStoreEntry) String added in v0.0.20 

func (x *KafkaOffsetStoreEntry) String() string

type OffsetTableEntry added in v0.0.20 

type OffsetTableEntry struct {

	// Types that are assignable to Operation:
	//
	//	*OffsetTableEntry_UpdateDocFields
	//	*OffsetTableEntry_DeleteDocFields
	//	*OffsetTableEntry_DeleteDoc
	Operation isOffsetTableEntry_Operation `protobuf_oneof:"operation"`
	// contains filtered or unexported fields
}

Single entry in offset table on-disk stream.

func (*OffsetTableEntry) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use OffsetTableEntry.ProtoReflect.Descriptor instead.

func (*OffsetTableEntry) GetDeleteDoc added in v0.0.20 

func (x *OffsetTableEntry) GetDeleteDoc() *DeleteDoc

func (*OffsetTableEntry) GetDeleteDocFields added in v0.0.20 

func (x *OffsetTableEntry) GetDeleteDocFields() *DeleteDocFields

func (*OffsetTableEntry) GetOperation added in v0.0.20 

func (m *OffsetTableEntry) GetOperation() isOffsetTableEntry_Operation

func (*OffsetTableEntry) GetUpdateDocFields added in v0.0.20 

func (x *OffsetTableEntry) GetUpdateDocFields() *UpdateDocFields

func (*OffsetTableEntry) ProtoMessage added in v0.0.20 

func (*OffsetTableEntry) ProtoMessage()

func (*OffsetTableEntry) ProtoReflect added in v0.0.20 

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

func (*OffsetTableEntry) Reset added in v0.0.20 

func (x *OffsetTableEntry) Reset()

func (*OffsetTableEntry) String added in v0.0.20 

func (x *OffsetTableEntry) String() string

type OffsetTableEntry_DeleteDoc added in v0.0.20 

type OffsetTableEntry_DeleteDoc struct {
	DeleteDoc *DeleteDoc `protobuf:"bytes,3,opt,name=deleteDoc,proto3,oneof"`
}

type OffsetTableEntry_DeleteDocFields added in v0.0.20 

type OffsetTableEntry_DeleteDocFields struct {
	DeleteDocFields *DeleteDocFields `protobuf:"bytes,2,opt,name=deleteDocFields,proto3,oneof"`
}

type OffsetTableEntry_UpdateDocFields added in v0.0.20 

type OffsetTableEntry_UpdateDocFields struct {
	UpdateDocFields *UpdateDocFields `protobuf:"bytes,1,opt,name=updateDocFields,proto3,oneof"`
}

type SavedCKVIndexSchema added in v0.0.20 

type SavedCKVIndexSchema struct {
	PrimaryKeyFieldName string            `protobuf:"bytes,1,opt,name=primary_key_field_name,json=primaryKeyFieldName,proto3" json:"primary_key_field_name,omitempty"`
	FieldIds            map[string]uint32 `` /* 174-byte string literal not displayed */
	// Used to assign field-ids to new fields. Primary-key always gets id=0.
	// Current value denotes an available id, i.e.
	// [0, current-1] are already taken.
	FieldIdCounter uint64 `protobuf:"varint,3,opt,name=field_id_counter,json=fieldIdCounter,proto3" json:"field_id_counter,omitempty"`
	// contains filtered or unexported fields
}

func (*SavedCKVIndexSchema) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use SavedCKVIndexSchema.ProtoReflect.Descriptor instead.

func (*SavedCKVIndexSchema) GetFieldIdCounter added in v0.0.20 

func (x *SavedCKVIndexSchema) GetFieldIdCounter() uint64

func (*SavedCKVIndexSchema) GetFieldIds added in v0.0.20 

func (x *SavedCKVIndexSchema) GetFieldIds() map[string]uint32

func (*SavedCKVIndexSchema) GetPrimaryKeyFieldName added in v0.0.20 

func (x *SavedCKVIndexSchema) GetPrimaryKeyFieldName() string

func (*SavedCKVIndexSchema) ProtoMessage added in v0.0.20 

func (*SavedCKVIndexSchema) ProtoMessage()

func (*SavedCKVIndexSchema) ProtoReflect added in v0.0.20 

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

func (*SavedCKVIndexSchema) Reset added in v0.0.20 

func (x *SavedCKVIndexSchema) Reset()

func (*SavedCKVIndexSchema) String added in v0.0.20 

func (x *SavedCKVIndexSchema) String() string

type Status 

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

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type UnimplementedAdminServiceServer 

type UnimplementedAdminServiceServer struct {
}

UnimplementedAdminServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAdminServiceServer) HealthCheck 

func (UnimplementedAdminServiceServer) HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error)

type UnimplementedInlineKVWriteServiceServer 

type UnimplementedInlineKVWriteServiceServer struct {
}

UnimplementedInlineKVWriteServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedInlineKVWriteServiceServer) BatchDeleteDocuments 

func (UnimplementedInlineKVWriteServiceServer) BatchDeleteDocuments(context.Context, *BatchDeleteDocumentsRequest) (*Status, error)

func (UnimplementedInlineKVWriteServiceServer) BatchDeleteFieldValues 

func (UnimplementedInlineKVWriteServiceServer) BatchDeleteFieldValues(context.Context, *BatchDeleteFieldValuesRequest) (*Status, error)

func (UnimplementedInlineKVWriteServiceServer) BatchUpsertFieldValues 

func (UnimplementedInlineKVWriteServiceServer) BatchUpsertFieldValues(context.Context, *BatchUpsertFieldValuesRequest) (*Status, error)

func (UnimplementedInlineKVWriteServiceServer) DeleteDocument 

func (UnimplementedInlineKVWriteServiceServer) DeleteDocument(context.Context, *DeleteDocumentRequest) (*Status, error)

func (UnimplementedInlineKVWriteServiceServer) DeleteFieldValues 

func (UnimplementedInlineKVWriteServiceServer) DeleteFieldValues(context.Context, *DeleteFieldValueRequest) (*Status, error)

func (UnimplementedInlineKVWriteServiceServer) DropFields added in v0.0.20 

func (UnimplementedInlineKVWriteServiceServer) DropFields(context.Context, *DropFieldsRequest) (*Status, error)

func (UnimplementedInlineKVWriteServiceServer) GetUserStoreConfig 

func (UnimplementedInlineKVWriteServiceServer) GetUserStoreConfig(context.Context, *GetUserStoreConfigRequest) (*GetUserStoreConfigResponse, error)

func (UnimplementedInlineKVWriteServiceServer) HelloWorld 

func (UnimplementedInlineKVWriteServiceServer) HelloWorld(context.Context, *HelloWorldRequest) (*HelloWorldResponse, error)

func (UnimplementedInlineKVWriteServiceServer) UpsertFieldValues 

func (UnimplementedInlineKVWriteServiceServer) UpsertFieldValues(context.Context, *UpsertFieldValuesRequest) (*Status, error)

type UnsafeAdminServiceServer 

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

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

type UnsafeInlineKVWriteServiceServer 

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

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

type UpdateDocFields added in v0.0.20 

type UpdateDocFields struct {
	PrimaryKey []byte   `protobuf:"bytes,1,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	FieldIds   []uint32 `protobuf:"varint,2,rep,packed,name=field_ids,json=fieldIds,proto3" json:"field_ids,omitempty"`
	Offsets    []uint64 `protobuf:"varint,3,rep,packed,name=offsets,proto3" json:"offsets,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDocFields) Descriptor deprecated added in v0.0.20 

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

Deprecated: Use UpdateDocFields.ProtoReflect.Descriptor instead.

func (*UpdateDocFields) GetFieldIds added in v0.0.20 

func (x *UpdateDocFields) GetFieldIds() []uint32

func (*UpdateDocFields) GetOffsets added in v0.0.20 

func (x *UpdateDocFields) GetOffsets() []uint64

func (*UpdateDocFields) GetPrimaryKey added in v0.0.20 

func (x *UpdateDocFields) GetPrimaryKey() []byte

func (*UpdateDocFields) ProtoMessage added in v0.0.20 

func (*UpdateDocFields) ProtoMessage()

func (*UpdateDocFields) ProtoReflect added in v0.0.20 

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

func (*UpdateDocFields) Reset added in v0.0.20 

func (x *UpdateDocFields) Reset()

func (*UpdateDocFields) String added in v0.0.20 

func (x *UpdateDocFields) String() string

type UpsertDocumentFieldsEvent 

type UpsertDocumentFieldsEvent struct {
	Document *IKVDocumentOnWire `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
	// contains filtered or unexported fields
}

Upsert fields for specified document.

func (*UpsertDocumentFieldsEvent) Descriptor deprecated 

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

Deprecated: Use UpsertDocumentFieldsEvent.ProtoReflect.Descriptor instead.

func (*UpsertDocumentFieldsEvent) GetDocument 

func (x *UpsertDocumentFieldsEvent) GetDocument() *IKVDocumentOnWire

func (*UpsertDocumentFieldsEvent) ProtoMessage 

func (*UpsertDocumentFieldsEvent) ProtoMessage()

func (*UpsertDocumentFieldsEvent) ProtoReflect 

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

func (*UpsertDocumentFieldsEvent) Reset 

func (x *UpsertDocumentFieldsEvent) Reset()

func (*UpsertDocumentFieldsEvent) String 

func (x *UpsertDocumentFieldsEvent) String() string

type UpsertFieldValuesRequest 

type UpsertFieldValuesRequest struct {
	UserStoreContextInitializer *UserStoreContextInitializer `protobuf:"bytes,1,opt,name=userStoreContextInitializer,proto3" json:"userStoreContextInitializer,omitempty"`
	Timestamp                   *timestamppb.Timestamp       `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Document                    *IKVDocumentOnWire           `protobuf:"bytes,3,opt,name=document,proto3" json:"document,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertFieldValuesRequest) Descriptor deprecated 

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

Deprecated: Use UpsertFieldValuesRequest.ProtoReflect.Descriptor instead.

func (*UpsertFieldValuesRequest) GetDocument 

func (x *UpsertFieldValuesRequest) GetDocument() *IKVDocumentOnWire

func (*UpsertFieldValuesRequest) GetTimestamp 

func (x *UpsertFieldValuesRequest) GetTimestamp() *timestamppb.Timestamp

func (*UpsertFieldValuesRequest) GetUserStoreContextInitializer 

func (x *UpsertFieldValuesRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

func (*UpsertFieldValuesRequest) ProtoMessage 

func (*UpsertFieldValuesRequest) ProtoMessage()

func (*UpsertFieldValuesRequest) ProtoReflect 

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

func (*UpsertFieldValuesRequest) Reset 

func (x *UpsertFieldValuesRequest) Reset()

func (*UpsertFieldValuesRequest) String 

func (x *UpsertFieldValuesRequest) String() string

type UserStoreContextInitializer 

type UserStoreContextInitializer struct {
	Credentials *AccountCredentials `protobuf:"bytes,1,opt,name=credentials,proto3" json:"credentials,omitempty"`
	StoreName   string              `protobuf:"bytes,2,opt,name=storeName,proto3" json:"storeName,omitempty"`
	// contains filtered or unexported fields
}

Used to construct UserStoreContext - used for schema/configuration/etc.

func (*UserStoreContextInitializer) Descriptor deprecated 

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

Deprecated: Use UserStoreContextInitializer.ProtoReflect.Descriptor instead.

func (*UserStoreContextInitializer) GetCredentials 

func (x *UserStoreContextInitializer) GetCredentials() *AccountCredentials

func (*UserStoreContextInitializer) GetStoreName 

func (x *UserStoreContextInitializer) GetStoreName() string

func (*UserStoreContextInitializer) ProtoMessage 

func (*UserStoreContextInitializer) ProtoMessage()

func (*UserStoreContextInitializer) ProtoReflect 

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

func (*UserStoreContextInitializer) Reset 

func (x *UserStoreContextInitializer) Reset()

func (*UserStoreContextInitializer) String 

func (x *UserStoreContextInitializer) String() string

Source Files

View all Source files

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.