buffering

Documentation

Index

• type IStreamWriter
• type StreamIngestBuffer
  • func NewStreamIngestBuffer(bulkFlushFrequency time.Duration, bulkMaxSize int, channelBufferSize int, ...) *StreamIngestBuffer
  • func (s *StreamIngestBuffer) AppendMesssage(message DeferedStreamRecord)
  • func (s *StreamIngestBuffer) Clear()
  • func (s *StreamIngestBuffer) Close() error
  • func (s *StreamIngestBuffer) GetBuffer() *[]DeferedStreamRecord
  • func (s *StreamIngestBuffer) GetBulkFlushFrequency() time.Duration
  • func (s *StreamIngestBuffer) GetChannelMsg() chan DeferedStreamRecord
  • func (s *StreamIngestBuffer) IsFull() bool
  • func (s *StreamIngestBuffer) Lock()
  • func (s *StreamIngestBuffer) PutMessage(msgId MessageId, creationDate time.Time, message interface{})
  • func (s *StreamIngestBuffer) Save() error
  • func (s *StreamIngestBuffer) Unlock()

Types

type IStreamWriter

type IStreamWriter interface {
	Init() error
	Open() error
	Close() error
	Write(record *[]DeferedStreamRecord) error
}

type StreamIngestBuffer

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

func NewStreamIngestBuffer

func NewStreamIngestBuffer(bulkFlushFrequency time.Duration, bulkMaxSize int, channelBufferSize int, writer IStreamWriter) *StreamIngestBuffer

func (*StreamIngestBuffer) AppendMesssage

func (s *StreamIngestBuffer) AppendMesssage(message DeferedStreamRecord)

func (*StreamIngestBuffer) Clear

func (s *StreamIngestBuffer) Clear()

func (*StreamIngestBuffer) Close

func (s *StreamIngestBuffer) Close() error

func (*StreamIngestBuffer) GetBuffer

func (s *StreamIngestBuffer) GetBuffer() *[]DeferedStreamRecord

func (*StreamIngestBuffer) GetBulkFlushFrequency

func (s *StreamIngestBuffer) GetBulkFlushFrequency() time.Duration

func (*StreamIngestBuffer) GetChannelMsg

func (s *StreamIngestBuffer) GetChannelMsg() chan DeferedStreamRecord

func (*StreamIngestBuffer) IsFull

func (s *StreamIngestBuffer) IsFull() bool

func (*StreamIngestBuffer) Lock

func (s *StreamIngestBuffer) Lock()

func (*StreamIngestBuffer) PutMessage

func (s *StreamIngestBuffer) PutMessage(msgId MessageId, creationDate time.Time, message interface{})

func (*StreamIngestBuffer) Save

func (s *StreamIngestBuffer) Save() error

func (*StreamIngestBuffer) Unlock

func (s *StreamIngestBuffer) Unlock()