schemas

package
v0.0.9 Latest Latest
Warning

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

 Go to latest Published: Feb 18, 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_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_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: "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 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 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
}

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
	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) 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_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)
	// 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)
	// 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 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) 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 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

type UserStoreSchemaUpdateRequest 

type UserStoreSchemaUpdateRequest struct {
	UserStoreContextInitializer *UserStoreContextInitializer `protobuf:"bytes,1,opt,name=userStoreContextInitializer,proto3" json:"userStoreContextInitializer,omitempty"`
	// duplicates (exact match) are ignored
	// conflicts throw an error (ex. re-registering with different type)
	NewFieldsToAdd []*FieldSchema `protobuf:"bytes,2,rep,name=newFieldsToAdd,proto3" json:"newFieldsToAdd,omitempty"`
	// contains filtered or unexported fields
}

func (*UserStoreSchemaUpdateRequest) Descriptor deprecated 

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

Deprecated: Use UserStoreSchemaUpdateRequest.ProtoReflect.Descriptor instead.

func (*UserStoreSchemaUpdateRequest) GetNewFieldsToAdd 

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

func (*UserStoreSchemaUpdateRequest) GetUserStoreContextInitializer 

func (x *UserStoreSchemaUpdateRequest) GetUserStoreContextInitializer() *UserStoreContextInitializer

func (*UserStoreSchemaUpdateRequest) ProtoMessage 

func (*UserStoreSchemaUpdateRequest) ProtoMessage()

func (*UserStoreSchemaUpdateRequest) ProtoReflect 

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

func (*UserStoreSchemaUpdateRequest) Reset 

func (x *UserStoreSchemaUpdateRequest) Reset()

func (*UserStoreSchemaUpdateRequest) String 

func (x *UserStoreSchemaUpdateRequest) 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.