device

Documentation

Index

• Variables
• type Config
• type Datastore
  • func NewDatastore(params *datastore.Params[*entities.Device], storeType datastore.StoreType) *Datastore
  • func (ds *Datastore) DeviceDAO() (dao.DeviceDAO, error)
• type Service
  • func NewService(config *Config) (*Service, error)
  • func (s *Service) Save(device *entities.Device) error

Variables

var (
	DatastorePartition = "devices"

	Configuration *Config

	DefaultConfig = Config{
		Datastore: &datastore.Config{
			Backend:          "AFERO_FS",
			ConsistencyLevel: "local",
			RootDir:          "trusted-data/datastore",
			ReadBufferSize:   50,
			Serializer:       "json",
		},
	}
)

var (
	ErrInvalidDeviceID = fmt.Errorf("invalid device ID")
)

Types

type Config

type Config struct {
	Datastore *datastore.Config `yaml:"datastore" json:"datastore" mapstructure:"datastore"`
}

type Datastore

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

func NewDatastore

func NewDatastore(
	params *datastore.Params[*entities.Device],
	storeType datastore.StoreType) *Datastore

func (*Datastore) DeviceDAO

func (ds *Datastore) DeviceDAO() (dao.DeviceDAO, error)

type Service

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

func NewService

func NewService(config *Config) (*Service, error)

func (*Service) Save

func (s *Service) Save(device *entities.Device) error