Versions in this module Expand all Collapse all v0 v0.1.0 Aug 3, 2021 Changes in this version + var ErrNotFound = errors.New("tag not found") + var TagUidFunc = rand.Uint32 + type State = uint32 + const StateSeen + const StateSent + const StateSplit + const StateStored + const StateSynced + const TotalChunks + type Tag struct + Address swarm.Address + Seen int64 + Sent int64 + Split int64 + StartedAt time.Time + Stored int64 + Synced int64 + Total int64 + Uid uint32 + func NewTag(ctx context.Context, uid uint32, total int64, tracer *tracing.Tracer, ...) *Tag + func (t *Tag) Context() context.Context + func (t *Tag) Done(s State) bool + func (t *Tag) DoneSplit(address swarm.Address) (int64, error) + func (t *Tag) ETA(state State) (time.Time, error) + func (t *Tag) FinishRootSpan() + func (t *Tag) Get(state State) int64 + func (t *Tag) Inc(state State) error + func (t *Tag) IncN(state State, n int64) error + func (t *Tag) Status(state State) (int64, int64, error) + func (t *Tag) TotalCounter() int64 + func (t *Tag) WaitTillDone(ctx context.Context, s State) error + func (tag *Tag) MarshalBinary() (data []byte, err error) + func (tag *Tag) UnmarshalBinary(buffer []byte) error + type Tags struct + func NewTags(stateStore storage.StateStorer, logger logging.Logger) *Tags + func (ts *Tags) All() (t []*Tag) + func (ts *Tags) Close() (err error) + func (ts *Tags) Create(total int64) (*Tag, error) + func (ts *Tags) Delete(k interface{}) + func (ts *Tags) Get(uid uint32) (*Tag, error) + func (ts *Tags) GetByAddress(address swarm.Address) (*Tag, error) + func (ts *Tags) ListAll(ctx context.Context, offset, limit int) (t []*Tag, err error) + func (ts *Tags) MarshalJSON() (out []byte, err error) + func (ts *Tags) Range(fn func(k, v interface{}) bool) + func (ts *Tags) UnmarshalJSON(value []byte) error