follow

type Checkpoint struct {
	Cursor      string    `json:"cursor"`
	Initialized bool      `json:"initialized"`
	Count       int       `json:"count"`
	LatestAt    time.Time `json:"latest_at,omitempty"`
}

type Manager struct {
	// contains filtered or unexported fields
}

type Sink interface {
	EnsureFollowRoom(context.Context, protocol.Follow, protocol.Room) error
	ImportFollowMessage(context.Context, protocol.Follow, string, protocol.Message) (bool, error)
	GetFollowCheckpoint(context.Context, string) (Checkpoint, error)
	SetFollowCheckpoint(context.Context, string, Checkpoint) error
	SetFollowCheckpoints(context.Context, map[string]Checkpoint, []string) error
}