store

Mar 4, 2019

Changes in this version

+ var ErrBatchFailed = errors.New("cannot add to batch: failures have been detected")

Feb 27, 2019

Changes in this version

+ const Component

+ var ErrLinkAlreadyExists = errors.New("link already exists")

+ var ErrOutDegreeNotSupported = errors.New("out degree is not supported by the current implementation")

+ var ErrReferencingNotSupported = errors.New(...)

+ var ErrUniqueMapEntry = errors.New("unique map entry is set and map already has an initial link")

+ type AdapterConfig interface

+ EnforceUniqueMapEntry func() error

type MapFilter

+ Prefix string

+ Suffix string

type SegmentFilter

+ Referencing chainscript.LinkHash

+ Reverse bool

+ Step string

+ WithoutParent bool

Jan 2, 2018

Changes in this version

type Adapter

+ AddStoreEventChannel func(chan *Event)

+ type Event struct

+ Data interface{}

+ EventType EventType

+ func NewSavedEvidences() *Event

+ func NewSavedLinks(linkArgs ...*cs.Link) *Event

+ func (event *Event) AddSavedEvidence(linkHash *types.Bytes32, e *cs.Evidence)

+ func (event *Event) AddSavedLinks(links ...*cs.Link)

+ func (event *Event) UnmarshalJSON(b []byte) error

+ type EventType string

+ const SavedEvidences

+ const SavedLinks

+ type EvidenceReader interface

+ GetEvidences func(linkHash *types.Bytes32) (*cs.Evidences, error)

+ type EvidenceStore interface

+ type EvidenceWriter interface

+ AddEvidence func(linkHash *types.Bytes32, evidence *cs.Evidence) error

+ type KeyValueReader interface

+ GetValue func(key []byte) ([]byte, error)

+ type KeyValueStore interface

+ type KeyValueWriter interface

+ DeleteValue func(key []byte) ([]byte, error)

+ SetValue func(key []byte, value []byte) error

+ type LinkWriter interface

+ CreateLink func(link *cs.Link) (*types.Bytes32, error)

type MapFilter

+ func (filter MapFilter) Match(segment *cs.Segment) bool

+ func (filter MapFilter) MatchLink(link *cs.Link) bool

type SegmentFilter

+ LinkHashes []string

+ func (filter SegmentFilter) Match(segment *cs.Segment) bool

+ func (filter SegmentFilter) MatchLink(link *cs.Link) bool

+ type SegmentReader interface

+ FindSegments func(filter *SegmentFilter) (cs.SegmentSlice, error)

+ GetMapIDs func(filter *MapFilter) ([]string, error)

+ GetSegment func(linkHash *types.Bytes32) (*cs.Segment, error)

Oct 6, 2017

Changes in this version

+ const DefaultLimit

+ const MaxLimit

+ const OpTypeDelete

+ const OpTypeSet

+ type Adapter interface

+ AddDidSaveChannel func(chan *cs.Segment)

+ GetInfo func() (interface{}, error)

+ NewBatch func() (Batch, error)

+ type Batch interface

+ Write func() error

+ type BufferedBatch struct

+ SegmentOps []SegmentOperation

+ ValueOps []ValueOperation

+ func NewBufferedBatch(a Adapter) *BufferedBatch

+ func (b *BufferedBatch) DeleteSegment(linkHash *types.Bytes32) (segment *cs.Segment, err error)

+ func (b *BufferedBatch) DeleteValue(key []byte) (value []byte, err error)

+ func (b *BufferedBatch) FindSegments(filter *SegmentFilter) (cs.SegmentSlice, error)

+ func (b *BufferedBatch) GetMapIDs(filter *MapFilter) ([]string, error)

+ func (b *BufferedBatch) GetSegment(linkHash *types.Bytes32) (segment *cs.Segment, err error)

+ func (b *BufferedBatch) GetValue(key []byte) (value []byte, err error)

+ func (b *BufferedBatch) SaveSegment(segment *cs.Segment) error

+ func (b *BufferedBatch) SaveValue(key, value []byte) error

+ type MapFilter struct

+ Process string

+ type OpType int

+ type Pagination struct

+ Limit int

+ Offset int

+ func (p *Pagination) PaginateSegments(a cs.SegmentSlice) cs.SegmentSlice

+ func (p *Pagination) PaginateStrings(a []string) []string

+ type Reader interface

+ FindSegments func(filter *SegmentFilter) (cs.SegmentSlice, error)

+ GetMapIDs func(filter *MapFilter) ([]string, error)

+ GetSegment func(linkHash *types.Bytes32) (*cs.Segment, error)

+ GetValue func(key []byte) ([]byte, error)

+ type SegmentFilter struct

+ MapIDs []string

+ PrevLinkHash *types.Bytes32

+ Process string

+ Tags []string

+ type SegmentOperation struct

+ LinkHash *types.Bytes32

+ Segment *cs.Segment

+ type ValueOperation struct

+ Key []byte

+ Value []byte

+ type Writer interface

+ DeleteSegment func(linkHash *types.Bytes32) (*cs.Segment, error)

+ DeleteValue func(key []byte) ([]byte, error)

+ SaveSegment func(segment *cs.Segment) error

+ SaveValue func(key []byte, value []byte) error