badger

Documentation

Index

• type Database
  • func DatabaseFromBadgerDB(db *badger.DB) *Database
  • func OpenDatabase(opts badger.Options) (*Database, error)
  • func (db *Database) ClearRequestLogs(ctx context.Context, projectID ulid.ULID) error
  • func (db *Database) Close() error
  • func (db *Database) DeleteProject(ctx context.Context, projectID ulid.ULID) error
  • func (db *Database) DeleteSenderRequests(ctx context.Context, projectID ulid.ULID) error
  • func (db *Database) FindProjectByID(ctx context.Context, projectID ulid.ULID) (project proj.Project, err error)
  • func (db *Database) FindRequestLogByID(ctx context.Context, reqLogID ulid.ULID) (reqLog reqlog.RequestLog, err error)
  • func (db *Database) FindRequestLogs(ctx context.Context, filter reqlog.FindRequestsFilter, scope *scope.Scope) ([]reqlog.RequestLog, error)
  • func (db *Database) FindSenderRequestByID(ctx context.Context, senderReqID ulid.ULID) (sender.Request, error)
  • func (db *Database) FindSenderRequests(ctx context.Context, filter sender.FindRequestsFilter, scope *scope.Scope) ([]sender.Request, error)
  • func (db *Database) Projects(ctx context.Context) ([]proj.Project, error)
  • func (db *Database) StoreRequestLog(ctx context.Context, reqLog reqlog.RequestLog) error
  • func (db *Database) StoreResponseLog(ctx context.Context, reqLogID ulid.ULID, resLog reqlog.ResponseLog) error
  • func (db *Database) StoreSenderRequest(ctx context.Context, req sender.Request) error
  • func (db *Database) UpsertProject(ctx context.Context, project proj.Project) error

Types

type Database

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

Database is used to store and retrieve data from an underlying Badger database.

func DatabaseFromBadgerDB

func DatabaseFromBadgerDB(db *badger.DB) *Database

DatabaseFromBadgerDB returns a Database with `db` set as the underlying Badger database.

func OpenDatabase

func OpenDatabase(opts badger.Options) (*Database, error)

OpenDatabase opens a new Badger database.

func (*Database) ClearRequestLogs

func (db *Database) ClearRequestLogs(ctx context.Context, projectID ulid.ULID) error

func (*Database) Close

func (db *Database) Close() error

Close closes the underlying Badger database.

func (*Database) DeleteProject

func (db *Database) DeleteProject(ctx context.Context, projectID ulid.ULID) error

func (*Database) DeleteSenderRequests

func (db *Database) DeleteSenderRequests(ctx context.Context, projectID ulid.ULID) error

func (*Database) FindProjectByID

func (db *Database) FindProjectByID(ctx context.Context, projectID ulid.ULID) (project proj.Project, err error)

func (*Database) FindRequestLogByID

func (db *Database) FindRequestLogByID(ctx context.Context, reqLogID ulid.ULID) (reqLog reqlog.RequestLog, err error)

func (*Database) FindRequestLogs

func (db *Database) FindRequestLogs(ctx context.Context, filter reqlog.FindRequestsFilter, scope *scope.Scope) ([]reqlog.RequestLog, error)

func (*Database) FindSenderRequestByID

func (db *Database) FindSenderRequestByID(ctx context.Context, senderReqID ulid.ULID) (sender.Request, error)

func (*Database) FindSenderRequests

func (db *Database) FindSenderRequests(ctx context.Context, filter sender.FindRequestsFilter, scope *scope.Scope) ([]sender.Request, error)

func (*Database) Projects

func (db *Database) Projects(ctx context.Context) ([]proj.Project, error)

func (*Database) StoreRequestLog

func (db *Database) StoreRequestLog(ctx context.Context, reqLog reqlog.RequestLog) error

func (*Database) StoreResponseLog

func (db *Database) StoreResponseLog(ctx context.Context, reqLogID ulid.ULID, resLog reqlog.ResponseLog) error

func (*Database) StoreSenderRequest

func (db *Database) StoreSenderRequest(ctx context.Context, req sender.Request) error

func (*Database) UpsertProject

func (db *Database) UpsertProject(ctx context.Context, project proj.Project) error