device

Documentation

Index

• type Store
  • func NewAtomixStore(client atomix.Client) (Store, error)
• type WatchOption
  • func WithChangeID(id devicechange.ID) WatchOption
  • func WithReplay() WatchOption

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

func NewAtomixStore(client atomix.Client) (Store, error)

NewAtomixStore returns a new persistent 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