updateque

Documentation

Index

• func UpdateNodes(rec *record.Record, n *node.Node)
• type RecordChannel
  • func (r *RecordChannel) Inform(datfile, id string, begin, end int64)

Functions

func UpdateNodes

func UpdateNodes(rec *record.Record, n *node.Node)

UpdateNodes do doUpdateNode for each records using related nodes. if success to doUpdateNode, add node to updatelist and recentlist and removes the record from queue.

Types

type RecordChannel

type RecordChannel struct {
	*record.Head
	Ch chan struct{}
	// contains filtered or unexported fields
}

RecordChannel is for informing record was gotten.

var UpdatedRecord RecordChannel

UpdatedRecord is concerned record.

func (*RecordChannel) Inform

func (r *RecordChannel) Inform(datfile, id string, begin, end int64)

Inform call channel if specifiedd condition is met.