Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Writer writersList
Functions ¶
func NewAsyncGroup ¶
func NewAsyncGroup() *asyncGroup
Types ¶
type DataContext ¶
type DataContext struct {
Write *writersList
Read *readersList
// contains filtered or unexported fields
}
func NewDataContext ¶
func NewDataContext(logger logger.Logger) *DataContext
func (*DataContext) SaveAll ¶
func (dc *DataContext) SaveAll(writers ...*writer)
func (*DataContext) WaitForCompletions ¶
func (dc *DataContext) WaitForCompletions(writers ...*writer) error
type ItemsCursor ¶
type ItemsCursor struct {
// contains filtered or unexported fields
}
func (*ItemsCursor) Next ¶
func (ic *ItemsCursor) Next() (*v3io.Item, error)
get the next matching item. this may potentially block as this lazy loads items from the collection
func (*ItemsCursor) Release ¶
func (ic *ItemsCursor) Release()
release a cursor and its underlying resources
Click to show internal directories.
Click to hide internal directories.