bufferedbatch

Documentation

Index

• type Batch
  • func NewBatch(ctx context.Context, a store.Adapter) *Batch
  • func (b *Batch) CreateLink(ctx context.Context, link *cs.Link) (_ *types.Bytes32, err error)
  • func (b *Batch) FindSegments(ctx context.Context, filter *store.SegmentFilter) (_ cs.SegmentSlice, err error)
  • func (b *Batch) GetMapIDs(ctx context.Context, filter *store.MapFilter) (_ []string, err error)
  • func (b *Batch) GetSegment(ctx context.Context, linkHash *types.Bytes32) (segment *cs.Segment, err error)
  • func (b *Batch) Write(ctx context.Context) (err error)

Types

type Batch

type Batch struct {
	Links []*cs.Link
	// contains filtered or unexported fields
}

Batch can be used as a base class for types that want to implement github.com/stratumn/go-indigocore/store.Batch. All operations are stored in arrays and can be replayed. Only the Write method must be implemented.

func NewBatch

func NewBatch(ctx context.Context, a store.Adapter) *Batch

NewBatch creates a new Batch.

func (*Batch) CreateLink

func (b *Batch) CreateLink(ctx context.Context, link *cs.Link) (_ *types.Bytes32, err error)

CreateLink implements github.com/stratumn/go-indigocore/store.LinkWriter.CreateLink.

func (*Batch) FindSegments

func (b *Batch) FindSegments(ctx context.Context, filter *store.SegmentFilter) (_ cs.SegmentSlice, err error)

FindSegments returns the union of segments in the store and not committed yet.

func (*Batch) GetMapIDs

func (b *Batch) GetMapIDs(ctx context.Context, filter *store.MapFilter) (_ []string, err error)

GetMapIDs returns the union of mapIds in the store and not committed yet.

func (*Batch) GetSegment

func (b *Batch) GetSegment(ctx context.Context, linkHash *types.Bytes32) (segment *cs.Segment, err error)

GetSegment returns a segment from the cache or delegates the call to the store.

func (*Batch) Write

func (b *Batch) Write(ctx context.Context) (err error)

Write implements github.com/stratumn/go-indigocore/store.Batch.Write.