A barebones client for message-db implemented in Go.
Everything, including pub/sub, is exposed through the MessageDB interface.
type MessageDB interface {
CreateSubscription(streamName, subscriberID string, subscribers Subscribers) Subscription
Read(streamName string, position, batchSize int) (Messages, error)
ReadAll(streamName string) (Messages, error)
ReadLast(streamName string) (*Message, error)
Write(*Message) (int, error)
}Call messagedb.New(db) and provide it a *sql.DB and you are ready to go!
For example:
package main
import (
"database/sql"
"log"
"github.com/brycedarling/messagedb"
_ "github.com/lib/pq"
)
func main() {
db, err := sql.Open("postgres", "dbname=message_store sslmode=disable user=postgres")
if err != nil {
log.Fatalf("unexpected error opening db: %s", err)
}
defer db.Close()
db.Exec("SET search_path TO message_store,public;")
m := messagedb.New(db)
msgs, err := m.ReadAll("stream")
if err != nil {
log.Fatalf("unexpected error reading stream: %s", err)
}
log.Printf("Read %d messages from stream", len(msgs))
}