storage

Documentation

Index

• type EventBulkInserter
• type EventInserter
• type RecordBuffer
  • func NewRecordBuffer(cfg RecordBufferConfig) *RecordBuffer
  • func (rb *RecordBuffer) RunCollection(collection string)
  • func (rb *RecordBuffer) Stop()
• type RecordBufferConfig

Types

type EventBulkInserter

type EventBulkInserter interface {
	BulkInsert(r []kubeClientModel.Event, collection string) error
}

type EventInserter

type EventInserter interface {
	Insert(r *kubeClientModel.Event, collection string) 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(collection string)

func (*RecordBuffer) Stop

func (rb *RecordBuffer) Stop()

type RecordBufferConfig

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