ikvclient

Apr 26, 2024

Changes in this version

type DefaultIKVReader

+ func (reader *DefaultIKVReader) MultiGetBytesValues(primaryKeys []interface{}, fieldNames []string) ([][]byte, error)

type IKVReader

+ MultiGetBytesValues func(primaryKeys []interface{}, fieldNames []string) ([][]byte, error)

type NativeReaderV2

+ func (nr *NativeReaderV2) MultiGetFieldValues(numPrimaryKeys int32, sizePrefixedPrimaryKeys []byte, fieldNames []string) ([][]byte, error)

Mar 17, 2024

Changes in this version

type DefaultIKVWriter

+ func (writer *DefaultIKVWriter) DropAllFields() error

+ func (writer *DefaultIKVWriter) DropFieldsByName(fieldNames []string) error

+ func (writer *DefaultIKVWriter) DropFieldsByNamePrefix(fieldNamePrefixes []string) error

type IKVWriter

+ DropAllFields func() error

+ DropFieldsByName func(fieldNames []string) error

+ DropFieldsByNamePrefix func(fieldNamePrefixes []string) error

Mar 10, 2024

Changes in this version

+ var EMPTY_STRING string = ""

Mar 3, 2024

Changes in this version

type DefaultIKVWriter

+ func (writer *DefaultIKVWriter) DeleteDocument(document *IKVDocument) error

+ func (writer *DefaultIKVWriter) DeleteFields(document *IKVDocument, fieldsToDelete []string) error

type IKVWriter

+ DeleteDocument func(document *IKVDocument) error

+ DeleteFields func(document *IKVDocument, fieldsToDelete []string) error

Feb 27, 2024

Changes in this version

+ var BUCKET_NAME string = "ikv-binaries"

+ var REGION string = "us-west-2"

+ type BinaryManager struct

+ func NewBinaryManager(mount_dir string) (*BinaryManager, error)

+ func (manager *BinaryManager) GetPathToNativeBinary() (string, error)

+ type NativeReaderV2 struct

+ func NewNativeReaderV2(dllPath string) (*NativeReaderV2, error)

+ func (nr *NativeReaderV2) Close() error

+ func (nr *NativeReaderV2) GetFieldValue(primaryKey []byte, fieldName string) []byte

+ func (nr *NativeReaderV2) HealthCheck(input string) (bool, error)

+ func (nr *NativeReaderV2) Open(config []byte) error

Feb 19, 2024

Changes in this version

type DefaultIKVReader

+ func (reader *DefaultIKVReader) HealthCheck() (bool, error)

type DefaultIKVWriter

+ func (writer *DefaultIKVWriter) HealthCheck() (bool, error)

type IKVReader

+ func NewDefaultIKVReader(clientOptions *ClientOptions) (IKVReader, error)

+ HealthCheck func() (bool, error)

type IKVWriter

+ HealthCheck func() (bool, error)

Feb 18, 2024

Changes in this version

+ type ClientOptions struct

+ type ClientOptionsBuilder struct

+ func NewClientOptionsBuilder() *ClientOptionsBuilder

+ func (builder *ClientOptionsBuilder) Build() (ClientOptions, error)

+ func (builder *ClientOptionsBuilder) WithAccountId(accountId string) *ClientOptionsBuilder

+ func (builder *ClientOptionsBuilder) WithAccountPasskey(accountPasskey string) *ClientOptionsBuilder

+ func (builder *ClientOptionsBuilder) WithConsoleLogging(level string) *ClientOptionsBuilder

+ func (builder *ClientOptionsBuilder) WithFileLogging(filepath string, level string) *ClientOptionsBuilder

+ func (builder *ClientOptionsBuilder) WithKafkaPropertyOverride(key string, value string) *ClientOptionsBuilder

+ func (builder *ClientOptionsBuilder) WithMountDirectory(dir string) *ClientOptionsBuilder

+ func (builder *ClientOptionsBuilder) WithStoreName(name string) *ClientOptionsBuilder

+ type DefaultIKVReader struct

+ func (reader *DefaultIKVReader) GetBytesValue(key interface{}, fieldname string) ([]byte, error)

+ func (reader *DefaultIKVReader) GetStringValue(key interface{}, fieldname string) (string, error)

+ func (reader *DefaultIKVReader) Shutdown() error

+ func (reader *DefaultIKVReader) Startup() error

+ type DefaultIKVWriter struct

+ func NewDefaultIKVWriter(clientOptions *ClientOptions) (*DefaultIKVWriter, error)

+ func (writer *DefaultIKVWriter) Helloworld(input string) (*schemas.HelloWorldResponse, error)

+ func (writer *DefaultIKVWriter) Shutdown() error

+ func (writer *DefaultIKVWriter) Startup() error

+ func (writer *DefaultIKVWriter) UpsertFields(document *IKVDocument) error

+ type IKVClientFactory struct

+ func (f *IKVClientFactory) CreateNewReader(clientOptions *ClientOptions) (IKVReader, error)

+ func (f *IKVClientFactory) CreateNewWriter(clientOptions *ClientOptions) (IKVWriter, error)

+ type IKVDocument struct

+ type IKVDocumentBuilder struct

+ func NewIKVDocumentBuilder() *IKVDocumentBuilder

+ func (builder *IKVDocumentBuilder) Build() (IKVDocument, error)

+ func (builder *IKVDocumentBuilder) PutBytesField(fieldname string, value []byte) *IKVDocumentBuilder

+ func (builder *IKVDocumentBuilder) PutStringField(fieldname string, value string) *IKVDocumentBuilder

+ type IKVReader interface

+ GetBytesValue func(key interface{}, fieldname string) ([]byte, error)

+ GetStringValue func(key interface{}, fieldname string) (string, error)

+ Shutdown func() error

+ Startup func() error

+ type IKVWriter interface

+ Shutdown func() error

+ Startup func() error

+ UpsertFields func(document *IKVDocument) error