storage

Documentation

Index

• type EventBulkInserter
• type EventCleaner
• type EventInserter
• type RecordBuffer
  • func NewRecordBuffer(cfg RecordBufferConfig) *RecordBuffer
  • func (rb *RecordBuffer) RunCollection()
  • func (rb *RecordBuffer) Stop()
• type RecordBufferConfig
• type RecordCleaner
  • func NewRecordCleaner(cfg RecordCleanerConfig) *RecordCleaner
  • func (rc *RecordCleaner) RunPeriodicCleanup()
  • func (rc *RecordCleaner) Stop()
• type RecordCleanerConfig

Types

type EventBulkInserter

type EventBulkInserter interface {
	BulkInsert(r []model.Record) error
}

type EventCleaner

type EventCleaner interface {
	Cleanup(deleteBefore time.Time) error
}

type EventInserter

type EventInserter interface {
	Insert(r *model.Record) error
}

type RecordBuffer

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

func NewRecordBuffer

func NewRecordBuffer(cfg RecordBufferConfig) *RecordBuffer

func (*RecordBuffer) RunCollection

func (rb *RecordBuffer) RunCollection()

func (*RecordBuffer) Stop

func (rb *RecordBuffer) Stop()

type RecordBufferConfig

type RecordBufferConfig struct {
	Storage         EventBulkInserter
	BufferCap       int
	InsertPeriod    time.Duration
	MinInsertEvents int
	Collector       <-chan model.Record
}

type RecordCleaner

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

func NewRecordCleaner

func NewRecordCleaner(cfg RecordCleanerConfig) *RecordCleaner

func (*RecordCleaner) RunPeriodicCleanup

func (rc *RecordCleaner) RunPeriodicCleanup()

func (*RecordCleaner) Stop

func (rc *RecordCleaner) Stop()

type RecordCleanerConfig

type RecordCleanerConfig struct {
	Storage          EventCleaner
	CleanupRunPeriod time.Duration
	RetentionPeriod  time.Duration
}