iotdata

package

v1.10.0 Latest Latest Go to latest Published: Aug 4, 2026 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Viridian-Inc/cloudmock

Links

Open Source Insights

Documentation ¶

Index ¶

type IoTDataService
- func New(accountID, region string) *IoTDataService
type PublishedMessage
type Shadow
type Store
- func NewStore(accountID, region string) *Store

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type IoTDataService ¶

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

IoTDataService is the cloudmock implementation of the AWS IoT Data Plane API.

func New ¶

func New(accountID, region string) *IoTDataService

New returns a new IoTDataService for the given AWS account ID and region.

func (*IoTDataService) Actions ¶

func (s *IoTDataService) Actions() []service.Action

Actions returns the list of IoT Data API actions supported by this service.

func (*IoTDataService) HandleRequest ¶

func (s *IoTDataService) HandleRequest(ctx *service.RequestContext) (*service.Response, error)

HandleRequest routes an incoming IoT Data request to the appropriate handler.

func (*IoTDataService) HealthCheck ¶

func (s *IoTDataService) HealthCheck() error

HealthCheck always returns nil.

func (*IoTDataService) Name ¶

func (s *IoTDataService) Name() string

Name returns the AWS service name used for routing.

type PublishedMessage ¶

type PublishedMessage struct {
	Topic   string
	Payload []byte
	QoS     int
	Time    time.Time
}

type Shadow ¶

type Shadow struct {
	ThingName  string
	ShadowName string // empty for classic shadow
	State      map[string]any
	Metadata   map[string]any
	Version    int64
	Timestamp  time.Time
}

type Store ¶

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

func NewStore ¶

func NewStore(accountID, region string) *Store

func (*Store) DeleteThingShadow ¶

func (s *Store) DeleteThingShadow(thingName, shadowName string) *service.AWSError

func (*Store) GetThingShadow ¶

func (s *Store) GetThingShadow(thingName, shadowName string) (*Shadow, *service.AWSError)

func (*Store) ListNamedShadowsForThing ¶

func (s *Store) ListNamedShadowsForThing(thingName string) ([]string, *service.AWSError)

func (*Store) Publish ¶

func (s *Store) Publish(topic string, payload []byte, qos int)

func (*Store) UpdateThingShadow ¶

func (s *Store) UpdateThingShadow(thingName, shadowName string, state map[string]any) (*Shadow, *service.AWSError)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL