commiter

Documentation

Overview

Package commiter contains implementations of committers.

Index

• type Instant
  • func NewInstant(headManager thead.Manager, messageStorage storage.MessageStorage, ...) *Instant
  • func (i *Instant) Add(ctx context.Context, cid cid.Cid) error
• type IntervalCommitter
  • func NewIntervalCommitter(headManager thead.Manager, messageStorage storage.MessageStorage, ...) *IntervalCommitter
  • func (i *IntervalCommitter) Add(ctx context.Context, cid cid.Cid) error
• type MaxBufferCommiterConfig
• type MaxBufferCommitter
  • func NewMaxBufferCommitter(headManager thead.Manager, messageStorage storage.MessageStorage, ...) *MaxBufferCommitter
  • func (mbc *MaxBufferCommitter) Add(ctx context.Context, cid cid.Cid) error

Types

type Instant

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

Instant Commiter adds commit after every single received commit

func NewInstant

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

func (*Instant) Add

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

type IntervalCommitter

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

IntervalCommitter adds commit at given intervals.

func NewIntervalCommitter

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

func (*IntervalCommitter) Add

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

type MaxBufferCommiterConfig

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

type MaxBufferCommitter

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

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

NewMaxBufferCommitter returns a new instance of MaxBufferCommitter.

func (*MaxBufferCommitter) Add

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