package main

import "context"

type Backend interface {
	Publish(event *Event) error
	Subscribe(ctx context.Context) <-chan *Event
	Since(lastEventID string, subscribePath string) []*Event
	Close() error
}