stateservice

Documentation

Overview

Package stateservice implements a centralized IoT device state storage service. See the controller.StateService proto.

Index

• type Service
  • func New(ctx context.Context, projectParams *cloudconfig.Params) (*Service, error)
  • func (s *Service) GetDeviceState(ctx context.Context, req *cpb.GetDeviceStateRequest) (*cpb.DeviceState, error)
  • func (s *Service) SetDeviceState(ctx context.Context, req *cpb.SetDeviceStateRequest) (*cpb.SetDeviceStateResponse, error)
• type Store

Types

type Service

type Service struct {
	cpb.UnimplementedStateServiceServer
	// contains filtered or unexported fields
}

Service implements controller.StateService.

func New

func New(ctx context.Context, projectParams *cloudconfig.Params) (*Service, error)

New returns a new StateService implementation.

func (*Service) GetDeviceState

func (s *Service) GetDeviceState(ctx context.Context, req *cpb.GetDeviceStateRequest) (*cpb.DeviceState, error)

func (*Service) SetDeviceState

func (s *Service) SetDeviceState(ctx context.Context, req *cpb.SetDeviceStateRequest) (*cpb.SetDeviceStateResponse, error)

type Store

type Store interface {
	StoreDeviceState(ctx context.Context, user *acls.Identity, s *controller.DeviceState) error
	GetDeviceState(ctx context.Context, user *acls.Identity, name string) (*controller.DeviceState, error)
	ListDevices(ctx context.Context, user *acls.Identity) ([]string, error)
}