Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StreamService ¶
type StreamService interface {
//Add will add the content items to the embedded stream id
Add(items []model.StreamItem) error
//Remove will remove the content items from the embedded stream id
Remove(items []model.StreamItem) error
//Load will pull a coalesced view of the streams in the query
Load(query model.StreamQuery, limit int, fromSlug string) (*model.StreamQueryResponse, error)
}
StreamService is the interface to the underlying stream storage system.
func NewRoshiStreamService ¶
func NewRoshiStreamService(urlString string, timeout time.Duration) (StreamService, error)
NewRoshiStreamService takes a url for the roshi server and returns the service
Source Files
Click to show internal directories.
Click to hide internal directories.