Go Message DB Client

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

Example Usage

Call messagedb.New(db) and provide it a *sql.DB and you are ready to go!

For example:

db, err := sql.Open("postgres", "dbname=message_store")
if err != nil {
	log.Fatalf("unexpected error opening db: %s", err)
}
defer db.Close()

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

alexrudd/messagedb

Go Message DB Client

Example Usage