consumer

type Consumer interface {
	// InitStream initializes a resource stream for the consumer.
	InitStream(resourceUrl string) error

	// NotifyStream lazily notifies the relevant stream, if it exists, about
	// a change in a particular resource.
	NotifyStream(obj *rd.StreamResponse) error

	// WatchStream publishes changes to resources that are being watched.
	WatchStream(resourceUrl string) (<-chan WatchResponse, error)

	// CloseStream closes a resource stream for the consumer.
	CloseStream(resourceUrl string) error
}

type Registry interface {
	// Register creates a new entry for the given consumer identified by id.
	Register(id string) (Consumer, error)

	// Deregister deregisters the consumer identified by id.
	Deregister(id string) error

	// GetAll returns all the registered consumer instances.
	GetAll() []Consumer
}

type WatchResponse struct {
	// Object is the information about the change in a resource that's being
	// watched.
	Object *rd.StreamResponse

	// Closed tells if the stream being watched was closed.
	Closed bool

	// Error tells of any errors while processing the stream.
	Error error
}