schemas

package

Go to main page

Versions in this module

v0

v0.0.26

Apr 28, 2024

v0.0.25

Apr 26, 2024

v0.0.24

Apr 14, 2024

v0.0.23

Mar 31, 2024

v0.0.22

Mar 24, 2024

v0.0.20

Mar 17, 2024

Changes in this version

+ const InlineKVWriteService_DropFields_FullMethodName

+ var File_index_proto protoreflect.FileDescriptor

+ type CKVIndexHeader struct

+ BaseIndexEpochMillis uint64

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

+ func (*CKVIndexHeader) ProtoMessage()

+ func (x *CKVIndexHeader) GetBaseIndexEpochMillis() uint64

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

+ func (x *CKVIndexHeader) Reset()

+ func (x *CKVIndexHeader) String() string

+ type CKVIndexSegmentMetadata struct

+ MmapWriteOffset uint64

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

+ func (*CKVIndexSegmentMetadata) ProtoMessage()

+ func (x *CKVIndexSegmentMetadata) GetMmapWriteOffset() uint64

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

+ func (x *CKVIndexSegmentMetadata) Reset()

+ func (x *CKVIndexSegmentMetadata) String() string

+ type DeleteDoc struct

+ PrimaryKey []byte

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

+ func (*DeleteDoc) ProtoMessage()

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

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

+ func (x *DeleteDoc) Reset()

+ func (x *DeleteDoc) String() string

+ type DeleteDocFields struct

+ FieldIds []uint32

+ PrimaryKey []byte

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

+ func (*DeleteDocFields) ProtoMessage()

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

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

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

+ func (x *DeleteDocFields) Reset()

+ func (x *DeleteDocFields) String() string

+ type DropFieldEvent struct

+ DropAll bool

+ FieldNamePrefixes []string

+ FieldNames []string

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

+ func (*DropFieldEvent) ProtoMessage()

+ func (x *DropFieldEvent) GetDropAll() bool

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

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

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

+ func (x *DropFieldEvent) Reset()

+ func (x *DropFieldEvent) String() string

+ type DropFieldsRequest struct

+ DropAll bool

+ FieldNamePrefixes []string

+ FieldNames []string

+ Timestamp *timestamppb.Timestamp

+ UserStoreContextInitializer *UserStoreContextInitializer

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

+ func (*DropFieldsRequest) ProtoMessage()

+ func (x *DropFieldsRequest) GetDropAll() bool

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

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

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

+ func (x *DropFieldsRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

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

+ func (x *DropFieldsRequest) Reset()

+ func (x *DropFieldsRequest) String() string

type IKVDataEvent

+ func (x *IKVDataEvent) GetDropFieldEvent() *DropFieldEvent

+ type IKVDataEvent_DropFieldEvent struct

+ DropFieldEvent *DropFieldEvent

type InlineKVWriteServiceClient

+ DropFields func(ctx context.Context, in *DropFieldsRequest, opts ...grpc.CallOption) (*Status, error)

type InlineKVWriteServiceServer

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

+ type KafkaOffsetStore struct

+ Entries []*KafkaOffsetStoreEntry

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

+ func (*KafkaOffsetStore) ProtoMessage()

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

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

+ func (x *KafkaOffsetStore) Reset()

+ func (x *KafkaOffsetStore) String() string

+ type KafkaOffsetStoreEntry struct

+ Offset int64

+ Partition int32

+ Topic string

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

+ func (*KafkaOffsetStoreEntry) ProtoMessage()

+ func (x *KafkaOffsetStoreEntry) GetOffset() int64

+ func (x *KafkaOffsetStoreEntry) GetPartition() int32

+ func (x *KafkaOffsetStoreEntry) GetTopic() string

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

+ func (x *KafkaOffsetStoreEntry) Reset()

+ func (x *KafkaOffsetStoreEntry) String() string

+ type OffsetTableEntry struct

+ Operation isOffsetTableEntry_Operation

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

+ func (*OffsetTableEntry) ProtoMessage()

+ func (m *OffsetTableEntry) GetOperation() isOffsetTableEntry_Operation

+ func (x *OffsetTableEntry) GetDeleteDoc() *DeleteDoc

+ func (x *OffsetTableEntry) GetDeleteDocFields() *DeleteDocFields

+ func (x *OffsetTableEntry) GetUpdateDocFields() *UpdateDocFields

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

+ func (x *OffsetTableEntry) Reset()

+ func (x *OffsetTableEntry) String() string

+ type OffsetTableEntry_DeleteDoc struct

+ DeleteDoc *DeleteDoc

+ type OffsetTableEntry_DeleteDocFields struct

+ DeleteDocFields *DeleteDocFields

+ type OffsetTableEntry_UpdateDocFields struct

+ UpdateDocFields *UpdateDocFields

+ type SavedCKVIndexSchema struct

+ FieldIdCounter uint64

+ FieldIds map[string]uint32

+ PrimaryKeyFieldName string

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

+ func (*SavedCKVIndexSchema) ProtoMessage()

+ func (x *SavedCKVIndexSchema) GetFieldIdCounter() uint64

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

+ func (x *SavedCKVIndexSchema) GetPrimaryKeyFieldName() string

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

+ func (x *SavedCKVIndexSchema) Reset()

+ func (x *SavedCKVIndexSchema) String() string

type UnimplementedInlineKVWriteServiceServer

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

+ type UpdateDocFields struct

+ FieldIds []uint32

+ Offsets []uint64

+ PrimaryKey []byte

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

+ func (*UpdateDocFields) ProtoMessage()

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

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

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

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

+ func (x *UpdateDocFields) Reset()

+ func (x *UpdateDocFields) String() string

v0.0.19

Mar 10, 2024

v0.0.18

Mar 10, 2024

v0.0.17

Mar 10, 2024

v0.0.16

Mar 10, 2024

v0.0.15

Mar 5, 2024

v0.0.14

Mar 3, 2024

v0.0.13

Feb 27, 2024

v0.0.12

Feb 19, 2024

v0.0.11

Feb 18, 2024

Changes in this version

+ const AdminService_HealthCheck_FullMethodName

+ const InlineKVWriteService_BatchDeleteDocuments_FullMethodName

+ const InlineKVWriteService_BatchDeleteFieldValues_FullMethodName

+ const InlineKVWriteService_BatchUpsertFieldValues_FullMethodName

+ const InlineKVWriteService_DeleteDocument_FullMethodName

+ const InlineKVWriteService_DeleteFieldValues_FullMethodName

+ const InlineKVWriteService_GetUserStoreConfig_FullMethodName

+ const InlineKVWriteService_HelloWorld_FullMethodName

+ const InlineKVWriteService_UpsertFieldValues_FullMethodName

+ var AdminService_ServiceDesc = grpc.ServiceDesc

+ var FieldType_name = map[int32]string

+ var FieldType_value = map[string]int32

+ var File_common_proto protoreflect.FileDescriptor

+ var File_services_proto protoreflect.FileDescriptor

+ var File_streaming_proto protoreflect.FileDescriptor

+ var InlineKVWriteService_ServiceDesc = grpc.ServiceDesc

+ func RegisterAdminServiceServer(s grpc.ServiceRegistrar, srv AdminServiceServer)

+ func RegisterInlineKVWriteServiceServer(s grpc.ServiceRegistrar, srv InlineKVWriteServiceServer)

+ type AccountCredentials struct

+ AccountId string

+ AccountPasskey string

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

+ func (*AccountCredentials) ProtoMessage()

+ func (x *AccountCredentials) GetAccountId() string

+ func (x *AccountCredentials) GetAccountPasskey() string

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

+ func (x *AccountCredentials) Reset()

+ func (x *AccountCredentials) String() string

+ type AdminServiceClient interface

+ HealthCheck func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)

+ func NewAdminServiceClient(cc grpc.ClientConnInterface) AdminServiceClient

+ type AdminServiceServer interface

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

+ type BatchDeleteDocumentsRequest struct

+ DocumentIds []*IKVDocumentOnWire

+ Timestamp *timestamppb.Timestamp

+ UserStoreContextInitializer *UserStoreContextInitializer

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

+ func (*BatchDeleteDocumentsRequest) ProtoMessage()

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

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

+ func (x *BatchDeleteDocumentsRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

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

+ func (x *BatchDeleteDocumentsRequest) Reset()

+ func (x *BatchDeleteDocumentsRequest) String() string

+ type BatchDeleteFieldValuesRequest struct

+ DocumentIds []*IKVDocumentOnWire

+ FieldNames []string

+ Timestamp *timestamppb.Timestamp

+ UserStoreContextInitializer *UserStoreContextInitializer

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

+ func (*BatchDeleteFieldValuesRequest) ProtoMessage()

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

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

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

+ func (x *BatchDeleteFieldValuesRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

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

+ func (x *BatchDeleteFieldValuesRequest) Reset()

+ func (x *BatchDeleteFieldValuesRequest) String() string

+ type BatchUpsertFieldValuesRequest struct

+ Documents []*IKVDocumentOnWire

+ Timestamp *timestamppb.Timestamp

+ UserStoreContextInitializer *UserStoreContextInitializer

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

+ func (*BatchUpsertFieldValuesRequest) ProtoMessage()

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

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

+ func (x *BatchUpsertFieldValuesRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

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

+ func (x *BatchUpsertFieldValuesRequest) Reset()

+ func (x *BatchUpsertFieldValuesRequest) String() string

+ type DeleteDocumentEvent struct

+ DocumentId *IKVDocumentOnWire

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

+ func (*DeleteDocumentEvent) ProtoMessage()

+ func (x *DeleteDocumentEvent) GetDocumentId() *IKVDocumentOnWire

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

+ func (x *DeleteDocumentEvent) Reset()

+ func (x *DeleteDocumentEvent) String() string

+ type DeleteDocumentFieldsEvent struct

+ DocumentId *IKVDocumentOnWire

+ FieldsToDelete []string

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

+ func (*DeleteDocumentFieldsEvent) ProtoMessage()

+ func (x *DeleteDocumentFieldsEvent) GetDocumentId() *IKVDocumentOnWire

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

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

+ func (x *DeleteDocumentFieldsEvent) Reset()

+ func (x *DeleteDocumentFieldsEvent) String() string

+ type DeleteDocumentRequest struct

+ DocumentId *IKVDocumentOnWire

+ Timestamp *timestamppb.Timestamp

+ UserStoreContextInitializer *UserStoreContextInitializer

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

+ func (*DeleteDocumentRequest) ProtoMessage()

+ func (x *DeleteDocumentRequest) GetDocumentId() *IKVDocumentOnWire

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

+ func (x *DeleteDocumentRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

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

+ func (x *DeleteDocumentRequest) Reset()

+ func (x *DeleteDocumentRequest) String() string

+ type DeleteFieldValueRequest struct

+ DocumentId *IKVDocumentOnWire

+ FieldNames []string

+ Timestamp *timestamppb.Timestamp

+ UserStoreContextInitializer *UserStoreContextInitializer

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

+ func (*DeleteFieldValueRequest) ProtoMessage()

+ func (x *DeleteFieldValueRequest) GetDocumentId() *IKVDocumentOnWire

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

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

+ func (x *DeleteFieldValueRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

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

+ func (x *DeleteFieldValueRequest) Reset()

+ func (x *DeleteFieldValueRequest) String() string

+ type EventHeader struct

+ SourceTimestamp *timestamppb.Timestamp

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

+ func (*EventHeader) ProtoMessage()

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

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

+ func (x *EventHeader) Reset()

+ func (x *EventHeader) String() string

+ type FieldSchema struct

+ FieldType FieldType

+ Id int32

+ Name string

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

+ func (*FieldSchema) ProtoMessage()

+ func (x *FieldSchema) GetFieldType() FieldType

+ func (x *FieldSchema) GetId() int32

+ func (x *FieldSchema) GetName() string

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

+ func (x *FieldSchema) Reset()

+ func (x *FieldSchema) String() string

+ type FieldType int32

+ const FieldType_BOOLEAN

+ const FieldType_BYTES

+ const FieldType_FLOAT32

+ const FieldType_FLOAT64

+ const FieldType_INT32

+ const FieldType_INT64

+ const FieldType_STRING

+ const FieldType_UNKNOWN

+ func (FieldType) Descriptor() protoreflect.EnumDescriptor

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

+ func (FieldType) Type() protoreflect.EnumType

+ func (x FieldType) Enum() *FieldType

+ func (x FieldType) Number() protoreflect.EnumNumber

+ func (x FieldType) String() string

+ type FieldValue struct

+ FieldType FieldType

+ Value []byte

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

+ func (*FieldValue) ProtoMessage()

+ func (x *FieldValue) GetFieldType() FieldType

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

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

+ func (x *FieldValue) Reset()

+ func (x *FieldValue) String() string

+ type GetUserStoreConfigRequest struct

+ UserStoreContextInitializer *UserStoreContextInitializer

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

+ func (*GetUserStoreConfigRequest) ProtoMessage()

+ func (x *GetUserStoreConfigRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

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

+ func (x *GetUserStoreConfigRequest) Reset()

+ func (x *GetUserStoreConfigRequest) String() string

+ type GetUserStoreConfigResponse struct

+ GlobalConfig *IKVStoreConfig

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

+ func (*GetUserStoreConfigResponse) ProtoMessage()

+ func (x *GetUserStoreConfigResponse) GetGlobalConfig() *IKVStoreConfig

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

+ func (x *GetUserStoreConfigResponse) Reset()

+ func (x *GetUserStoreConfigResponse) String() string

+ type HealthCheckResponse struct

+ Code int32

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

+ func (*HealthCheckResponse) ProtoMessage()

+ func (x *HealthCheckResponse) GetCode() int32

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

+ func (x *HealthCheckResponse) Reset()

+ func (x *HealthCheckResponse) String() string

+ type HelloWorldRequest struct

+ Echo string

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

+ func (*HelloWorldRequest) ProtoMessage()

+ func (x *HelloWorldRequest) GetEcho() string

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

+ func (x *HelloWorldRequest) Reset()

+ func (x *HelloWorldRequest) String() string

+ type HelloWorldResponse struct

+ Echo string

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

+ func (*HelloWorldResponse) ProtoMessage()

+ func (x *HelloWorldResponse) GetEcho() string

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

+ func (x *HelloWorldResponse) Reset()

+ func (x *HelloWorldResponse) String() string

+ type IKVDataEvent struct

+ Event isIKVDataEvent_Event

+ EventHeader *EventHeader

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

+ func (*IKVDataEvent) ProtoMessage()

+ func (m *IKVDataEvent) GetEvent() isIKVDataEvent_Event

+ func (x *IKVDataEvent) GetDeleteDocumentEvent() *DeleteDocumentEvent

+ func (x *IKVDataEvent) GetDeleteDocumentFieldsEvent() *DeleteDocumentFieldsEvent

+ func (x *IKVDataEvent) GetEventHeader() *EventHeader

+ func (x *IKVDataEvent) GetUpsertDocumentFieldsEvent() *UpsertDocumentFieldsEvent

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

+ func (x *IKVDataEvent) Reset()

+ func (x *IKVDataEvent) String() string

+ type IKVDataEvent_DeleteDocumentEvent struct

+ DeleteDocumentEvent *DeleteDocumentEvent

+ type IKVDataEvent_DeleteDocumentFieldsEvent struct

+ DeleteDocumentFieldsEvent *DeleteDocumentFieldsEvent

+ type IKVDataEvent_UpsertDocumentFieldsEvent struct

+ UpsertDocumentFieldsEvent *UpsertDocumentFieldsEvent

+ type IKVDocumentOnWire struct

+ Document map[string]*FieldValue

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

+ func (*IKVDocumentOnWire) ProtoMessage()

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

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

+ func (x *IKVDocumentOnWire) Reset()

+ func (x *IKVDocumentOnWire) String() string

+ type IKVStoreConfig struct

+ BooleanConfigs map[string]bool

+ BytesConfigs map[string][]byte

+ FloatConfigs map[string]float32

+ IntConfigs map[string]int64

+ StringConfigs map[string]string

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

+ func (*IKVStoreConfig) ProtoMessage()

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

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

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

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

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

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

+ func (x *IKVStoreConfig) Reset()

+ func (x *IKVStoreConfig) String() string

+ type InlineKVWriteServiceClient interface

+ BatchDeleteDocuments func(ctx context.Context, in *BatchDeleteDocumentsRequest, opts ...grpc.CallOption) (*Status, error)

+ BatchDeleteFieldValues func(ctx context.Context, in *BatchDeleteFieldValuesRequest, ...) (*Status, error)

+ BatchUpsertFieldValues func(ctx context.Context, in *BatchUpsertFieldValuesRequest, ...) (*Status, error)

+ DeleteDocument func(ctx context.Context, in *DeleteDocumentRequest, opts ...grpc.CallOption) (*Status, error)

+ DeleteFieldValues func(ctx context.Context, in *DeleteFieldValueRequest, opts ...grpc.CallOption) (*Status, error)

+ GetUserStoreConfig func(ctx context.Context, in *GetUserStoreConfigRequest, opts ...grpc.CallOption) (*GetUserStoreConfigResponse, error)

+ HelloWorld func(ctx context.Context, in *HelloWorldRequest, opts ...grpc.CallOption) (*HelloWorldResponse, error)

+ UpsertFieldValues func(ctx context.Context, in *UpsertFieldValuesRequest, opts ...grpc.CallOption) (*Status, error)

+ func NewInlineKVWriteServiceClient(cc grpc.ClientConnInterface) InlineKVWriteServiceClient

+ type InlineKVWriteServiceServer interface

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

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

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

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

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

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

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

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

+ type Status struct

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

+ func (*Status) ProtoMessage()

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

+ func (x *Status) Reset()

+ func (x *Status) String() string

+ type UnimplementedAdminServiceServer struct

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

+ type UnimplementedInlineKVWriteServiceServer struct

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

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

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

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

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

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

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

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

+ type UnsafeAdminServiceServer interface

+ type UnsafeInlineKVWriteServiceServer interface

+ type UpsertDocumentFieldsEvent struct

+ Document *IKVDocumentOnWire

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

+ func (*UpsertDocumentFieldsEvent) ProtoMessage()

+ func (x *UpsertDocumentFieldsEvent) GetDocument() *IKVDocumentOnWire

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

+ func (x *UpsertDocumentFieldsEvent) Reset()

+ func (x *UpsertDocumentFieldsEvent) String() string

+ type UpsertFieldValuesRequest struct

+ Document *IKVDocumentOnWire

+ Timestamp *timestamppb.Timestamp

+ UserStoreContextInitializer *UserStoreContextInitializer

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

+ func (*UpsertFieldValuesRequest) ProtoMessage()

+ func (x *UpsertFieldValuesRequest) GetDocument() *IKVDocumentOnWire

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

+ func (x *UpsertFieldValuesRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

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

+ func (x *UpsertFieldValuesRequest) Reset()

+ func (x *UpsertFieldValuesRequest) String() string

+ type UserStoreContextInitializer struct

+ Credentials *AccountCredentials

+ StoreName string

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

+ func (*UserStoreContextInitializer) ProtoMessage()

+ func (x *UserStoreContextInitializer) GetCredentials() *AccountCredentials

+ func (x *UserStoreContextInitializer) GetStoreName() string

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

+ func (x *UserStoreContextInitializer) Reset()

+ func (x *UserStoreContextInitializer) String() string

+ type UserStoreSchemaUpdateRequest struct

+ NewFieldsToAdd []*FieldSchema

+ UserStoreContextInitializer *UserStoreContextInitializer

+ func (*UserStoreSchemaUpdateRequest) Descriptor() ([]byte, []int)

+ func (*UserStoreSchemaUpdateRequest) ProtoMessage()

+ func (x *UserStoreSchemaUpdateRequest) GetNewFieldsToAdd() []*FieldSchema

+ func (x *UserStoreSchemaUpdateRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

+ func (x *UserStoreSchemaUpdateRequest) ProtoReflect() protoreflect.Message

+ func (x *UserStoreSchemaUpdateRequest) Reset()

+ func (x *UserStoreSchemaUpdateRequest) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL