repo

Documentation

Index

• type DeviceState
• type DeviceStatus
• type Repo
  • func NewRedisRepo(addr string) (repo Repo, err error)
• type Server
  • func (s *Server) DeleteDeviceState(context context.Context, request *repopb.DeleteDeviceStateRequest) (response *repopb.DeleteDeviceStateResponse, err error)
  • func (s *Server) Get(context context.Context, request *repopb.GetRequest) (response *repopb.GetResponse, err error)
  • func (s *Server) SetDeviceState(context context.Context, request *repopb.SetDeviceStateRequest) (response *repopb.SetDeviceStateResponse, err error)

Types

type DeviceState

type DeviceState struct {
	ID     string
	Status DeviceStatus
}

type DeviceStatus

type DeviceStatus struct {
	Fingerprint  []byte
	Enabled      bool
	BasicEnabled bool
	NamespaceID  string
}

type Repo

type Repo interface {
	SetDeviceStatus(DeviceState) (err error)
	GetDeviceStatus(id string) (DeviceState, error)
	DeleteDeviceStatus(id string) (err error)
}

func NewRedisRepo

func NewRedisRepo(addr string) (repo Repo, err error)

type Server

type Server struct {
	Repo Repo
	Log  *zap.Logger
}

func (*Server) DeleteDeviceState

func (s *Server) DeleteDeviceState(context context.Context, request *repopb.DeleteDeviceStateRequest) (response *repopb.DeleteDeviceStateResponse, err error)

func (*Server) Get

func (s *Server) Get(context context.Context, request *repopb.GetRequest) (response *repopb.GetResponse, err error)

func (*Server) SetDeviceState

func (s *Server) SetDeviceState(context context.Context, request *repopb.SetDeviceStateRequest) (response *repopb.SetDeviceStateResponse, err error)