republisher

Documentation

Index

• Constants
• Variables
• type Republisher
  • func NewRepublisher(r routing.ValueStore, ds ds.Datastore, self ic.PrivKey, ks keystore.Keystore) *Republisher
  • func (rp *Republisher) Run(proc goprocess.Process)

Constants

const DefaultRecordLifetime = time.Hour * 24

Variables

var DefaultRebroadcastInterval = time.Hour * 4

Types

type Republisher

type Republisher struct {
	Interval time.Duration

	// how long records that are republished should be valid for
	RecordLifetime time.Duration
	// contains filtered or unexported fields
}

func NewRepublisher

func NewRepublisher(r routing.ValueStore, ds ds.Datastore, self ic.PrivKey, ks keystore.Keystore) *Republisher

NewRepublisher creates a new Republisher

func (*Republisher) Run

func (rp *Republisher) Run(proc goprocess.Process)