database

Documentation

Index

• type DBDriver
  • func NewDBDriver(db_path string) (*DBDriver, error)
  • func (d *DBDriver) AddMessageToTopic(topic string, data []byte) error
  • func (d *DBDriver) Close()
  • func (d *DBDriver) CreateTopic(topic string) error
  • func (d *DBDriver) Debug()
  • func (d *DBDriver) Debug2()
  • func (d *DBDriver) DeleteMessagesUntilOffset(topic string, offset int64) error
  • func (d *DBDriver) DeleteTopic(topic string) error
  • func (d *DBDriver) GetEarliestMessageFromTopic(topic string) ([]byte, int64, error)
  • func (d *DBDriver) GetEarliestOffset(topic string) (int64, error)
  • func (d *DBDriver) GetLatestMessageFromTopic(topic string) ([]byte, int64, error)
  • func (d *DBDriver) GetLatestOffset(topic string) (int64, error)
  • func (d *DBDriver) GetMessageAtOffset(topic string, offset int64) ([]byte, error)
• type Topic

Types

type DBDriver

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

func NewDBDriver

func NewDBDriver(db_path string) (*DBDriver, error)

func (*DBDriver) AddMessageToTopic

func (d *DBDriver) AddMessageToTopic(topic string, data []byte) error

func (*DBDriver) Close

func (d *DBDriver) Close()

func (*DBDriver) CreateTopic

func (d *DBDriver) CreateTopic(topic string) error

func (*DBDriver) Debug

func (d *DBDriver) Debug()

func (*DBDriver) Debug2

func (d *DBDriver) Debug2()

func (*DBDriver) DeleteMessagesUntilOffset

func (d *DBDriver) DeleteMessagesUntilOffset(topic string, offset int64) error

func (*DBDriver) DeleteTopic

func (d *DBDriver) DeleteTopic(topic string) error

func (*DBDriver) GetEarliestMessageFromTopic

func (d *DBDriver) GetEarliestMessageFromTopic(topic string) ([]byte, int64, error)

func (*DBDriver) GetEarliestOffset

func (d *DBDriver) GetEarliestOffset(topic string) (int64, error)

func (*DBDriver) GetLatestMessageFromTopic

func (d *DBDriver) GetLatestMessageFromTopic(topic string) ([]byte, int64, error)

func (*DBDriver) GetLatestOffset

func (d *DBDriver) GetLatestOffset(topic string) (int64, error)

func (*DBDriver) GetMessageAtOffset

func (d *DBDriver) GetMessageAtOffset(topic string, offset int64) ([]byte, error)

type Topic

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