indexer

Jan 20, 2023

Changes in this version

+ var ErrCodecOverflow = errors.New("overflow")

+ var ErrStatsNotSupported = errors.New("stats is not supported by store")

+ type BinaryValueCodec struct

+ ZeroCopy bool

+ func (BinaryValueCodec) MarshalValue(v Value) ([]byte, error)

+ func (BinaryValueCodec) MarshalValueKeys(vk [][]byte) ([]byte, error)

+ func (c BinaryValueCodec) UnmarshalValue(b []byte) (Value, error)

+ func (c BinaryValueCodec) UnmarshalValueKeys(b []byte) ([][]byte, error)

+ type BinaryWithJsonFallbackCodec struct

+ func (bjc BinaryWithJsonFallbackCodec) MarshalValue(v Value) ([]byte, error)

+ func (bjc BinaryWithJsonFallbackCodec) MarshalValueKeys(vk [][]byte) ([]byte, error)

+ func (bjc BinaryWithJsonFallbackCodec) UnmarshalValue(b []byte) (Value, error)

+ func (bjc BinaryWithJsonFallbackCodec) UnmarshalValueKeys(b []byte) ([][]byte, error)

+ type Interface interface

+ Close func() error

+ Flush func() error

+ Get func(multihash.Multihash) ([]Value, bool, error)

+ Iter func() (Iterator, error)

+ Put func(Value, ...multihash.Multihash) error

+ Remove func(Value, ...multihash.Multihash) error

+ RemoveProvider func(context.Context, peer.ID) error

+ RemoveProviderContext func(providerID peer.ID, contextID []byte) error

+ Size func() (int64, error)

+ Stats func() (*Stats, error)

+ type Iterator interface

+ Close func() error

+ Next func() (multihash.Multihash, []Value, error)

+ type JsonValueCodec struct

+ func (JsonValueCodec) MarshalValue(v Value) ([]byte, error)

+ func (JsonValueCodec) MarshalValueKeys(vk [][]byte) ([]byte, error)

+ func (JsonValueCodec) UnmarshalValue(b []byte) (v Value, err error)

+ func (JsonValueCodec) UnmarshalValueKeys(b []byte) (vk [][]byte, err error)

+ type Stats struct

+ MultihashCount uint64

+ type Value struct

+ ContextID []byte

+ MetadataBytes []byte

+ ProviderID peer.ID

+ func (v Value) Equal(other Value) bool

+ func (v Value) Match(other Value) bool

+ func (v Value) MatchEqual(other Value) (isMatch bool, isEqual bool)

+ type ValueCodec interface

+ MarshalValue func(Value) ([]byte, error)

+ MarshalValueKeys func([][]byte) ([]byte, error)

+ UnmarshalValue func(b []byte) (Value, error)

+ UnmarshalValueKeys func([]byte) ([][]byte, error)