commiter

type Instant ¶

type Instant struct {
	// contains filtered or unexported fields
}

Instant Commiter adds commit after every single received commit

func NewInstant(headManager thead.Manager, messageStorage storage.MessageStorage, pinner sentinel.Pinner,
	ipnsManager ipns.Manager) *Instant

func (i *Instant) Add(ctx context.Context, cid cid.Cid) error

type IntervalCommitter ¶ added in v1.0.2

type IntervalCommitter struct {
	// contains filtered or unexported fields
}

IntervalCommitter adds commit at given intervals.

func NewIntervalCommitter(headManager thead.Manager, messageStorage storage.MessageStorage, pinner sentinel.Pinner,
	ipnsManager ipns.Manager, ticker *clock.Ticker) *IntervalCommitter

func (i *IntervalCommitter) Add(ctx context.Context, cid cid.Cid) error

type MaxBufferCommiterConfig ¶ added in v1.2.0

type MaxBufferCommiterConfig struct {
	MaxBufferSize int           `envconfig:"COMMITER_MAX_BUFFER_SIZE" default:"1000"`
	Interval      time.Duration `envconfig:"COMMITER_INTERVAL" default:"1m"`
}

type MaxBufferCommitter ¶ added in v1.0.2

type MaxBufferCommitter struct {
	// contains filtered or unexported fields
}

MaxBufferCommitter adds commit after buffer is filled. If it's not filled for a long time, it adds commit after a specified interval.

func NewMaxBufferCommitter(
	headManager thead.Manager,
	messageStorage storage.MessageStorage,
	pinner sentinel.Pinner,
	ipnsManager ipns.Manager,
	config MaxBufferCommiterConfig) *MaxBufferCommitter

func (mbc *MaxBufferCommitter) Add(ctx context.Context, cid cid.Cid) error