tube

func (*Record) Clone ¶

func (r *Record) Clone() *Record

func (*Tube) BulkRead ¶

func (t *Tube) BulkRead() []*Record

BulkRead returns a listing of all elements of the Tube table

func (*Tube) BulkWrite ¶

func (t *Tube) BulkWrite(bulk []*Record)

BulkWrite writes the given set of records to our local view. Resulting changes are pushed to downstream peers as necessary and in bulk.

func (*Tube) Forget ¶

func (t *Tube) Forget(key string, notAfterRev Rev, notAfterUpdated time.Time) bool

Forget…

func (*Tube) Lookup ¶

func (t *Tube) Lookup(key string) *Record

Lookup…

func (*Tube) NewArrivals ¶

func (t *Tube) NewArrivals() *pubsub.Subscription

NewArrivals returns a subscription for the stream of arriving peer identities.

func (*Tube) NewDepartures ¶

func (t *Tube) NewDepartures() *pubsub.Subscription

NewDepartures returns a subscription for the stream of departing peer identities.

func (*Tube) Scrub ¶

func (t *Tube) Scrub(key string, notAfterRev Rev, notAfterUpdated time.Time)

Scrub…

func (*Tube) Write ¶

func (t *Tube) Write(key string, rev Rev, value interface{}) (changed bool)

Write updates the state of our local view for the given key. Write will block until the diffusion of the write operation reaches its terminal nodes.

This simple form of backpressure ensures self-inflicted DDoS in the presence of software bugs.

func (*View) Dump ¶

func (v *View) Dump() string

Dump returns a textual representation of the contents of this view

func (*View) Forget ¶

func (v *View) Forget(key string, notAfterRev Rev, notUpdatedAfter time.Time) bool

Forget removes the record for key from the view, only if the current record has revision no greater than notAfterRev and has not been updated after notUpdatedAfter.

The notAfterRev condition is not in effect is notAfterRev is zero. Similarly, the notUpdatedAfter condition is not in effect if notUpdatedAfter is zero.

The returned value reflects whether a removal takes place.

func (*View) Lookup ¶

func (v *View) Lookup(key string) *Record

Lookup returns a copy of the record for the given key, if one is present.

func (*View) NewArrivals ¶

func (v *View) NewArrivals() *pubsub.Subscription

NewArrivals returns a subscription for the stream of arriving peer identities.

func (*View) NewDepartures ¶

func (v *View) NewDepartures() *pubsub.Subscription

NewDepartures returns a subscription for the stream of departing peer identities.

func (*View) Peek ¶

func (v *View) Peek() []*Record

Peek returns a copy of the current state of the view.

func (*View) Update ¶

func (v *View) Update(r *Record) (changed bool)

Update updates the state of the view at key r.Key. The first update to a key must have revision bigger than zero, otherwise it won't take effect. The returned value reflects whether an actual change took place in the view.

func (XTube) Avatar ¶

func (x XTube) Avatar() tissue.FolkAvatar

Avatar returns an Avatar pointing to this tube

func (XTube) BulkWrite ¶

func (x XTube) BulkWrite(bulk []*Record)

func (XTube) Scrub ¶

func (x XTube) Scrub(key string, notAfterRev Rev, notAfterUpdated time.Time)

func (XTube) Write ¶

func (x XTube) Write(key string, rev Rev, value interface{}) bool

Write…

func (YTube) BulkWrite ¶

func (y YTube) BulkWrite(bulk []*Record)

func (YTube) Scrub ¶

func (y YTube) Scrub(key string, notAfterRev Rev, notAfterUpdated time.Time)

func (YTube) Write ¶

func (y YTube) Write(key string, rev Rev, value interface{}) bool