Documentation
¶
Index ¶
- func SQLiteBufferConfig() *service.ConfigSpec
- type SQLiteBuffer
- func (m *SQLiteBuffer) Close(ctx context.Context) error
- func (m *SQLiteBuffer) EndOfInput()
- func (m *SQLiteBuffer) ReadBatch(ctx context.Context) (service.MessageBatch, service.AckFunc, error)
- func (m *SQLiteBuffer) WriteBatch(ctx context.Context, msgBatch service.MessageBatch, aFn service.AckFunc) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SQLiteBufferConfig ¶
func SQLiteBufferConfig() *service.ConfigSpec
SQLiteBufferConfig returns a config spec for an SQLite buffer.
Types ¶
type SQLiteBuffer ¶
type SQLiteBuffer struct {
// contains filtered or unexported fields
}
SQLiteBuffer stores messages for consumption through an SQLite DB.
func NewSQLiteBufferFromConfig ¶
func NewSQLiteBufferFromConfig(conf *service.ParsedConfig, res *service.Resources) (*SQLiteBuffer, error)
NewSQLiteBufferFromConfig creates a new SQLite buffer from a parsed config.
func (*SQLiteBuffer) Close ¶
func (m *SQLiteBuffer) Close(ctx context.Context) error
Close the underlying DB connection.
func (*SQLiteBuffer) EndOfInput ¶
func (m *SQLiteBuffer) EndOfInput()
EndOfInput signals to the buffer that the input is finished and therefore once the DB is drained it should close.
func (*SQLiteBuffer) ReadBatch ¶
func (m *SQLiteBuffer) ReadBatch(ctx context.Context) (service.MessageBatch, service.AckFunc, error)
ReadBatch attempts to pop a row from the DB.
func (*SQLiteBuffer) WriteBatch ¶
func (m *SQLiteBuffer) WriteBatch(ctx context.Context, msgBatch service.MessageBatch, aFn service.AckFunc) error
WriteBatch adds a new message to the DB.
Source Files
Click to show internal directories.
Click to hide internal directories.