package server

import (
	"time"

	"go.rctt.net/solec/core"
)

type Storage interface {
	Write(msg core.Message) (err error)
	Read(channel string, since time.Time, num, offset int) (history []core.Message, err error)
}