cache.go 313 B

1234567891011121314
  1. package server
  2. import (
  3. _ "github.com/mattn/go-sqlite3" // SQLite driver
  4. "time"
  5. )
  6. type cache interface {
  7. AddMessage(m *message) error
  8. Messages(topic string, since sinceTime) ([]*message, error)
  9. MessageCount(topic string) (int, error)
  10. Topics() (map[string]*topic, error)
  11. Prune(keep time.Duration) error
  12. }