sponge_devices

Documentation

Index

• Constants
• type DevicesManager
  • func NewDevicesManager(ctx context.Context, d DevicesRecorder, user, userToken string) *DevicesManager
  • func (r *DevicesManager) AddDevices(d *devices.Device) error
  • func (r *DevicesManager) DeleteDevices(guid string) error
  • func (r *DevicesManager) ExistDevices(guid string) bool
  • func (r *DevicesManager) GetDevices(guid string) *devices.Device
  • func (r *DevicesManager) ListDevices() map[string]*devices.Device
  • func (r *DevicesManager) NewWatcher() clientv3.WatchChan
  • func (r *DevicesManager) UpdateDevices(d *devices.Device) error
• type DevicesRecorder

Constants

const (
	DevicesSavePathPrefixFormat = "/spongeregister/superbahnManager/devices/%v/"
)

Types

type DevicesManager

type DevicesManager struct {
	// contains filtered or unexported fields
}

func NewDevicesManager

func NewDevicesManager(ctx context.Context, d DevicesRecorder, user, userToken string) *DevicesManager

func (*DevicesManager) AddDevices

func (r *DevicesManager) AddDevices(d *devices.Device) error

func (*DevicesManager) DeleteDevices

func (r *DevicesManager) DeleteDevices(guid string) error

func (*DevicesManager) ExistDevices

func (r *DevicesManager) ExistDevices(guid string) bool

func (*DevicesManager) GetDevices

func (r *DevicesManager) GetDevices(guid string) *devices.Device

func (*DevicesManager) ListDevices

func (r *DevicesManager) ListDevices() map[string]*devices.Device

func (*DevicesManager) NewWatcher

func (r *DevicesManager) NewWatcher() clientv3.WatchChan

func (*DevicesManager) UpdateDevices

func (r *DevicesManager) UpdateDevices(d *devices.Device) error

type DevicesRecorder

type DevicesRecorder interface {
	Put(string, string) error
	Get(string) ([]byte, error)
	GetWithPrefix(string) (map[string][]byte, error)
	Del(string) error
	GetWatcher(string) clientv3.WatchChan
}