Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store interface {
io.Closer
// Get gets a device change
Get(id devicechange.ID) (*devicechange.DeviceChange, error)
// Create creates a new device change
Create(change *devicechange.DeviceChange) error
// Update updates an existing device change
Update(change *devicechange.DeviceChange) error
// Delete deletes a device change
Delete(change *devicechange.DeviceChange) error
// List lists device change
List(deviceID device.VersionedID, ch chan<- *devicechange.DeviceChange) (stream.Context, error)
// Watch watches the device change store for changes
Watch(deviceID device.VersionedID, ch chan<- stream.Event, opts ...WatchOption) (stream.Context, error)
}
Store stores DeviceChanges
func NewAtomixStore ¶
NewAtomixStore returns a new persistent Store
func NewLocalStore ¶
NewLocalStore returns a new local device store
type WatchOption ¶
type WatchOption interface {
// contains filtered or unexported methods
}
WatchOption is a configuration option for Watch calls
func WithChangeID ¶
func WithChangeID(id devicechange.ID) WatchOption
WithChangeID returns a Watch option that watches for changes to the given change ID
func WithReplay ¶
func WithReplay() WatchOption
WithReplay returns a WatchOption that replays past changes
Click to show internal directories.
Click to hide internal directories.