sitewiseclient

package
v0.0.0-...-aa487cb Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 28, 2024 License: MPL-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type API 

type API interface {
	ListAssetModels(ctx context.Context) (*iotsitewise.ListAssetModelsOutput, error)
	ListAssetModelsNext(ctx context.Context, nextToken *string) (*iotsitewise.ListAssetModelsOutput, error)
	ListAssets(ctx context.Context, assetModelId *string) (*iotsitewise.ListAssetsOutput, error)
	ListAssetsNext(ctx context.Context, assetModelId *string, nextToken *string) (*iotsitewise.ListAssetsOutput, error)
	DescribeAssetModel(ctx context.Context, assetModelId *string) (*iotsitewise.DescribeAssetModelOutput, error)
	DeleteAssetModel(ctx context.Context, assetModelId *string) (*iotsitewise.DeleteAssetModelOutput, error)
	CreateDataBulkImportJob(ctx context.Context, jobNumber int, bucket string, filesToImport []string, roleArn string) (*iotsitewise.CreateBulkImportJobOutput, error)
	ListBulkImportJobs(ctx context.Context, nextToken *string) (*iotsitewise.ListBulkImportJobsOutput, error)
	GetBulkImportJobStatus(ctx context.Context, jobId *string) (*iotsitewise.DescribeBulkImportJobOutput, error)
	CreateAssetModel(ctx context.Context, name string, properties map[string]string, uomMap map[string][]string) (*iotsitewise.CreateAssetModelOutput, error)
	CreateAsset(ctx context.Context, name string, assetModelId string, thingId string) (*iotsitewise.CreateAssetOutput, error)
	DescribeModel(ctx context.Context, assetModelId string) (*iotsitewise.DescribeAssetModelOutput, error)
	PollForModelActiveStatus(ctx context.Context, modelId string, maxRetry int) bool
	IsModelActive(ctx context.Context, model *iotsitewise.DescribeAssetModelOutput) bool
	DescribeAsset(ctx context.Context, assetId string) (*iotsitewise.DescribeAssetOutput, error)
	IsAssetActive(ctx context.Context, asset *iotsitewise.DescribeAssetOutput) bool
	PollForAssetActiveStatus(ctx context.Context, assetId string, maxRetry int) bool
	UpdateAssetModelProperties(ctx context.Context, assetModel *iotsitewise.DescribeAssetModelOutput, thingProperties map[string]string, uomMap map[string][]string) error
	UpdateAssetProperties(ctx context.Context, assetId string, thingProperties map[string]string) error
	PopulateTimeSeriesByAlias(ctx context.Context, propertyAlias string, ts []int64, values []float64) error
	PopulateSampledSamplesTimeSeriesByAlias(ctx context.Context, propertyAlias string, ts []int64, values []any) error
	PopulateArbitrarySamplesByAlias(ctx context.Context, points []DataPoint) error
}

type DataPoint 

type DataPoint struct {
	PropertyAlias string
	Ts            int64
	Value         any
}

type IotSiteWiseClient 

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

func New 

func New(logger *logrus.Entry) (*IotSiteWiseClient, error)

func (*IotSiteWiseClient) CreateAsset 

func (c *IotSiteWiseClient) CreateAsset(ctx context.Context, name string, assetModelId string, thingId string) (*iotsitewise.CreateAssetOutput, error)

func (*IotSiteWiseClient) CreateAssetModel 

func (c *IotSiteWiseClient) CreateAssetModel(ctx context.Context, name string, properties map[string]string, uomMap map[string][]string) (*iotsitewise.CreateAssetModelOutput, error)

func (*IotSiteWiseClient) CreateDataBulkImportJob 

func (c *IotSiteWiseClient) CreateDataBulkImportJob(ctx context.Context, jobNumber int, bucket string, filesToImport []string, roleArn string) (*iotsitewise.CreateBulkImportJobOutput, error)

func (*IotSiteWiseClient) DeleteAssetModel 

func (c *IotSiteWiseClient) DeleteAssetModel(ctx context.Context, assetModelId *string) (*iotsitewise.DeleteAssetModelOutput, error)

func (*IotSiteWiseClient) DescribeAsset 

func (c *IotSiteWiseClient) DescribeAsset(ctx context.Context, assetId string) (*iotsitewise.DescribeAssetOutput, error)

func (*IotSiteWiseClient) DescribeAssetModel 

func (c *IotSiteWiseClient) DescribeAssetModel(ctx context.Context, assetModelId *string) (*iotsitewise.DescribeAssetModelOutput, error)

func (*IotSiteWiseClient) DescribeModel 

func (c *IotSiteWiseClient) DescribeModel(ctx context.Context, assetModelId string) (*iotsitewise.DescribeAssetModelOutput, error)

func (*IotSiteWiseClient) GetBulkImportJobStatus 

func (c *IotSiteWiseClient) GetBulkImportJobStatus(ctx context.Context, jobId *string) (*iotsitewise.DescribeBulkImportJobOutput, error)

func (*IotSiteWiseClient) IsAssetActive 

func (c *IotSiteWiseClient) IsAssetActive(ctx context.Context, asset *iotsitewise.DescribeAssetOutput) bool

func (*IotSiteWiseClient) IsModelActive 

func (c *IotSiteWiseClient) IsModelActive(ctx context.Context, model *iotsitewise.DescribeAssetModelOutput) bool

func (*IotSiteWiseClient) ListAssetModels 

func (c *IotSiteWiseClient) ListAssetModels(ctx context.Context) (*iotsitewise.ListAssetModelsOutput, error)

func (*IotSiteWiseClient) ListAssetModelsNext 

func (c *IotSiteWiseClient) ListAssetModelsNext(ctx context.Context, nextToken *string) (*iotsitewise.ListAssetModelsOutput, error)

func (*IotSiteWiseClient) ListAssets 

func (c *IotSiteWiseClient) ListAssets(ctx context.Context, assetModelId *string) (*iotsitewise.ListAssetsOutput, error)

func (*IotSiteWiseClient) ListAssetsNext 

func (c *IotSiteWiseClient) ListAssetsNext(ctx context.Context, assetModelId *string, nextToken *string) (*iotsitewise.ListAssetsOutput, error)

func (*IotSiteWiseClient) ListBulkImportJobs 

func (c *IotSiteWiseClient) ListBulkImportJobs(ctx context.Context, nextToken *string) (*iotsitewise.ListBulkImportJobsOutput, error)

func (*IotSiteWiseClient) PollForAssetActiveStatus 

func (c *IotSiteWiseClient) PollForAssetActiveStatus(ctx context.Context, assetId string, maxRetry int) bool

func (*IotSiteWiseClient) PollForModelActiveStatus 

func (c *IotSiteWiseClient) PollForModelActiveStatus(ctx context.Context, modelId string, maxRetry int) bool

func (*IotSiteWiseClient) PopulateArbitrarySamplesByAlias 

func (c *IotSiteWiseClient) PopulateArbitrarySamplesByAlias(ctx context.Context, points []DataPoint) error

func (*IotSiteWiseClient) PopulateSampledSamplesTimeSeriesByAlias 

func (c *IotSiteWiseClient) PopulateSampledSamplesTimeSeriesByAlias(ctx context.Context, propertyAlias string, ts []int64, values []any) error

func (*IotSiteWiseClient) PopulateTimeSeriesByAlias 

func (c *IotSiteWiseClient) PopulateTimeSeriesByAlias(ctx context.Context, propertyAlias string, ts []int64, values []float64) error

func (*IotSiteWiseClient) UpdateAssetModelProperties 

func (c *IotSiteWiseClient) UpdateAssetModelProperties(ctx context.Context, assetModel *iotsitewise.DescribeAssetModelOutput, thingProperties map[string]string, uomMap map[string][]string) error

func (*IotSiteWiseClient) UpdateAssetProperties 

func (c *IotSiteWiseClient) UpdateAssetProperties(ctx context.Context, assetId string, thingProperties map[string]string) error

property is map with key as SiteWise property id and as value the alias of the property to be updated

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.