server/storage.go


1
2
3
4
5
6
7
8
9
10
11
12

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)
}