shared

Documentation

Index

• type Database
  • func (p *Database) CreateCache()
  • func (p *Database) FetchMessages(topic string, startOffset, endOffset int64) (messages []types.Message, err error)
  • func (p *Database) MaxOffsets() (map[string]int64, error)
  • func (p *Database) StoreMessages(topic string, messages []types.Message) error

Types

type Database

type Database struct {
	DB          *sql.DB
	Writer      sqlutil.Writer
	TopicsTable tables.NaffkaTopics
	// contains filtered or unexported fields
}

Database represents a database implementation, either Postgres or SQLite.

func (*Database) CreateCache

func (p *Database) CreateCache()

func (*Database) FetchMessages

func (p *Database) FetchMessages(topic string, startOffset, endOffset int64) (messages []types.Message, err error)

FetchMessages implements Database.

func (*Database) MaxOffsets

func (p *Database) MaxOffsets() (map[string]int64, error)

MaxOffsets implements Database.

func (*Database) StoreMessages

func (p *Database) StoreMessages(topic string, messages []types.Message) error

StoreMessages implements Database.