Versions in this module Expand all Collapse all v0 v0.1.6 Dec 12, 2024 Changes in this version + type AssociateGormResult struct + DataCid string + DataSize int64 + type DataFilter struct + Operator string + Property string + Value interface{} + type DataStoreSQL struct + func NewDataStoreSQL(config MessageStoreSQLConfig) (*DataStoreSQL, error) + func (dss *DataStoreSQL) Associate(tenant string, messageCid string, dataCid string) (*AssociateGormResult, error) + func (dss *DataStoreSQL) Clear() error + func (dss *DataStoreSQL) Close() error + func (dss *DataStoreSQL) Delete(tenant string, messageCid string, dataCid string) error + func (dss *DataStoreSQL) Get(tenant string, messageCid string, dataCid string) (string, int64, io.Reader, error) + func (dss *DataStoreSQL) Open() error + func (dss *DataStoreSQL) Put(tenant string, messageCid string, dataCid string, dataStream io.Reader) (*PutGormResult, error) + type EventLogSQL struct + func NewEventLogSQL(config MessageStoreSQLConfig) (*EventLogSQL, error) + func (els *EventLogSQL) Append(tenant string, messageCid string, indexes KeyValues) error + func (els *EventLogSQL) Clear() error + func (els *EventLogSQL) Close() error + func (els *EventLogSQL) DeleteEventsByCid(tenant string, messageCids []string) error + func (els *EventLogSQL) GetEvents(tenant string, options *EventOptions) ([]string, error) + func (els *EventLogSQL) Open() error + func (els *EventLogSQL) QueryEvents(tenant string, filters []DataFilter, options *EventOptions) ([]string, error) + type EventOptions struct + Cursor string + type GetGormResult struct + DataCid string + DataSize int64 + DataStream io.Reader + type GormMessageStore struct + func NewMessageStoreSQL(config MessageStoreSQLConfig) (*GormMessageStore, error) + func (mss *GormMessageStore) Clear() error + func (mss *GormMessageStore) Close() error + func (mss *GormMessageStore) Delete(tenant string, cidString string, options *MessageStoreOptions) error + func (mss *GormMessageStore) Get(tenant string, messageCid string) (interface{}, error) + func (mss *GormMessageStore) Open() error + func (mss *GormMessageStore) Put(tenant string, message GenericMessage, indexes KeyValues, ...) error + func (mss *GormMessageStore) Query(tenant string, filters []DataFilter, messageSort *MessageSort, ...) ([]GenericMessage, string, error) type MessageSort + Direction string + Property string + type MessageStoreSQL struct + type MessageStoreSQLConfig struct + DBConfig config.DBConfig + type PutGormResult struct + DataCid string + DataSize int64 v0.1.4 Oct 22, 2024 Changes in this version + const DELIMITER + const INDEX_SUBLEVEL_NAME + const MAX_INT_STRING_LEN + const NEGATIVE_OFFSET + const NEGATIVE_PREFIX + const SortDirectionAscending + const SortDirectionDescending + var PlaceholderValue = []byte + type BlockstoreLevel struct + func NewBlockstoreLevel(path string) (*BlockstoreLevel, error) + func (b *BlockstoreLevel) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) + func (b *BlockstoreLevel) Clear() error + func (b *BlockstoreLevel) Close() error + func (b *BlockstoreLevel) Delete(ctx context.Context, c cid.Cid) error + func (b *BlockstoreLevel) Get(ctx context.Context, c cid.Cid) ([]byte, error) + func (b *BlockstoreLevel) Has(ctx context.Context, c cid.Cid) (bool, error) + func (b *BlockstoreLevel) IsEmpty() (bool, error) + func (b *BlockstoreLevel) Open() error + func (b *BlockstoreLevel) Partition(tenant string) (*BlockstoreLevel, error) + func (b *BlockstoreLevel) Put(ctx context.Context, c cid.Cid, block []byte) error + func (b *BlockstoreLevel) PutMany(ctx context.Context, blocks map[cid.Cid][]byte) error + type DataStoreLevel struct + func NewDataStoreLevel(config DataStoreLevelConfig) (*DataStoreLevel, error) + func (d *DataStoreLevel) Clear(ctx context.Context) error + func (d *DataStoreLevel) Close() error + func (d *DataStoreLevel) Delete(ctx context.Context, tenant, messageCid, dataCid string) error + func (d *DataStoreLevel) Get(ctx context.Context, tenant, messageCid, dataCid string) (*GetResult, error) + func (d *DataStoreLevel) Open() error + func (d *DataStoreLevel) Put(ctx context.Context, tenant, messageCid, dataCid string, dataReader io.Reader) (*PutResult, error) + type DataStoreLevelConfig struct + BlockstoreLocation string + type EqualFilter interface + type Filter = map[string]interface + type GenericMessage interface + type GetResult struct + DataCid string + DataReader io.ReadCloser + DataSize uint64 + type IndexLevel struct + func NewIndexLevel(config IndexLevelConfig) (*IndexLevel, error) + func (il *IndexLevel) Clear() error + func (il *IndexLevel) Close() error + func (il *IndexLevel) Delete(tenant string, itemId string, options *IndexLevelOptions) error + func (il *IndexLevel) Put(tenant string, itemId string, indexes KeyValues, options *IndexLevelOptions) error + func (il *IndexLevel) Query(tenant string, filters []Filter, queryOptions QueryOptions, ...) ([]string, error) + type IndexLevelConfig struct + Location string + type IndexLevelOptions struct + Context context.Context + type IndexedItem struct + Indexes KeyValues + ItemID string + type KeyValues map[string]interface + type LevelWrapper struct + func NewLevelWrapper(config LevelWrapperConfig) *LevelWrapper + func (lw *LevelWrapper) Batch(operations []LevelWrapperBatchOperation, options *LevelWrapperOptions) error + func (lw *LevelWrapper) Clear() error + func (lw *LevelWrapper) Close() error + func (lw *LevelWrapper) Delete(key string, options *LevelWrapperOptions) error + func (lw *LevelWrapper) Get(key string, options *LevelWrapperOptions) ([]byte, error) + func (lw *LevelWrapper) Has(key string, options *LevelWrapperOptions) (bool, error) + func (lw *LevelWrapper) IsEmpty(options *LevelWrapperOptions) (bool, error) + func (lw *LevelWrapper) Iterator(iterOptions *LevelWrapperIteratorOptions, options *LevelWrapperOptions) (iterator.Iterator, error) + func (lw *LevelWrapper) Keys(options *LevelWrapperOptions) (iterator.Iterator, error) + func (lw *LevelWrapper) Open() error + func (lw *LevelWrapper) Partition(name string) (*LevelWrapper, error) + func (lw *LevelWrapper) Put(key string, value []byte, options *LevelWrapperOptions) error + type LevelWrapperBatchOperation struct + Key []byte + Type string + Value []byte + type LevelWrapperConfig struct + Location string + OpenOptions *opt.Options + type LevelWrapperIteratorOptions struct + Limit []byte + Reverse bool + Start []byte + type LevelWrapperOptions struct + Context context.Context + type MessageSort struct + DateCreated *SortDirection + DatePublished *SortDirection + MessageTimestamp *SortDirection + type MessageStoreLevel struct + func NewMessageStoreLevel(config MessageStoreLevelConfig) (*MessageStoreLevel, error) + func (msl *MessageStoreLevel) Clear() error + func (msl *MessageStoreLevel) Close() error + func (msl *MessageStoreLevel) Delete(tenant, cidString string, options *MessageStoreOptions) error + func (msl *MessageStoreLevel) Get(tenant, cidString string, options *MessageStoreOptions) (GenericMessage, error) + func (msl *MessageStoreLevel) Open() error + func (msl *MessageStoreLevel) Put(tenant string, message GenericMessage, indexes KeyValues, ...) error + func (msl *MessageStoreLevel) Query(tenant string, filters []Filter, messageSort *MessageSort, ...) ([]GenericMessage, string, error) + type MessageStoreLevelConfig struct + BlockstoreLocation string + CreateLevelDatabase func(string) (*LevelWrapper, error) + IndexLocation string + type MessageStoreOptions struct + Signal context.Context + type Pagination struct + Cursor string + Limit int + type PutResult struct + DataCid string + DataSize uint64 + type QueryOptions struct + Cursor string + Limit int + SortDirection string + SortProperty string + type RangeFilter map[string]interface + type SortDirection string + const SortAscending + const SortDescending
Go to main page