Versions in this module Expand all Collapse all v0 v0.4.0 May 26, 2018 Changes in this version + const EndpointsID + const ErrCodeInternalFailureException + const ErrCodeInvalidRequestException + const ErrCodeLimitExceededException + const ErrCodeResourceAlreadyExistsException + const ErrCodeResourceNotFoundException + const ErrCodeServiceUnavailableException + const ErrCodeThrottlingException + const ServiceName + type AddAttributesActivity struct + Attributes map[string]string + Name *string + Next *string + func (s *AddAttributesActivity) Validate() error + func (s AddAttributesActivity) GoString() string + func (s AddAttributesActivity) MarshalFields(e protocol.FieldEncoder) error + func (s AddAttributesActivity) String() string + type BatchPutMessageErrorEntry struct + ErrorCode *string + ErrorMessage *string + MessageId *string + func (s BatchPutMessageErrorEntry) GoString() string + func (s BatchPutMessageErrorEntry) MarshalFields(e protocol.FieldEncoder) error + func (s BatchPutMessageErrorEntry) String() string + type BatchPutMessageInput struct + ChannelName *string + Messages []Message + func (s *BatchPutMessageInput) Validate() error + func (s BatchPutMessageInput) GoString() string + func (s BatchPutMessageInput) MarshalFields(e protocol.FieldEncoder) error + func (s BatchPutMessageInput) String() string + type BatchPutMessageOutput struct + BatchPutMessageErrorEntries []BatchPutMessageErrorEntry + func (s BatchPutMessageOutput) GoString() string + func (s BatchPutMessageOutput) MarshalFields(e protocol.FieldEncoder) error + func (s BatchPutMessageOutput) SDKResponseMetadata() aws.Response + func (s BatchPutMessageOutput) String() string + type BatchPutMessageRequest struct + Copy func(*BatchPutMessageInput) BatchPutMessageRequest + Input *BatchPutMessageInput + func (r BatchPutMessageRequest) Send() (*BatchPutMessageOutput, error) + type CancelPipelineReprocessingInput struct + PipelineName *string + ReprocessingId *string + func (s *CancelPipelineReprocessingInput) Validate() error + func (s CancelPipelineReprocessingInput) GoString() string + func (s CancelPipelineReprocessingInput) MarshalFields(e protocol.FieldEncoder) error + func (s CancelPipelineReprocessingInput) String() string + type CancelPipelineReprocessingOutput struct + func (s CancelPipelineReprocessingOutput) GoString() string + func (s CancelPipelineReprocessingOutput) MarshalFields(e protocol.FieldEncoder) error + func (s CancelPipelineReprocessingOutput) SDKResponseMetadata() aws.Response + func (s CancelPipelineReprocessingOutput) String() string + type CancelPipelineReprocessingRequest struct + Copy func(*CancelPipelineReprocessingInput) CancelPipelineReprocessingRequest + Input *CancelPipelineReprocessingInput + func (r CancelPipelineReprocessingRequest) Send() (*CancelPipelineReprocessingOutput, error) + type Channel struct + Arn *string + CreationTime *time.Time + LastUpdateTime *time.Time + Name *string + RetentionPeriod *RetentionPeriod + Status ChannelStatus + func (s Channel) GoString() string + func (s Channel) MarshalFields(e protocol.FieldEncoder) error + func (s Channel) String() string + type ChannelActivity struct + ChannelName *string + Name *string + Next *string + func (s *ChannelActivity) Validate() error + func (s ChannelActivity) GoString() string + func (s ChannelActivity) MarshalFields(e protocol.FieldEncoder) error + func (s ChannelActivity) String() string + type ChannelStatus string + const ChannelStatusActive + const ChannelStatusCreating + const ChannelStatusDeleting + func (enum ChannelStatus) MarshalValue() (string, error) + func (enum ChannelStatus) MarshalValueBuf(b []byte) ([]byte, error) + type ChannelSummary struct + ChannelName *string + CreationTime *time.Time + LastUpdateTime *time.Time + Status ChannelStatus + func (s ChannelSummary) GoString() string + func (s ChannelSummary) MarshalFields(e protocol.FieldEncoder) error + func (s ChannelSummary) String() string + type CreateChannelInput struct + ChannelName *string + RetentionPeriod *RetentionPeriod + func (s *CreateChannelInput) Validate() error + func (s CreateChannelInput) GoString() string + func (s CreateChannelInput) MarshalFields(e protocol.FieldEncoder) error + func (s CreateChannelInput) String() string + type CreateChannelOutput struct + ChannelArn *string + ChannelName *string + RetentionPeriod *RetentionPeriod + func (s CreateChannelOutput) GoString() string + func (s CreateChannelOutput) MarshalFields(e protocol.FieldEncoder) error + func (s CreateChannelOutput) SDKResponseMetadata() aws.Response + func (s CreateChannelOutput) String() string + type CreateChannelRequest struct + Copy func(*CreateChannelInput) CreateChannelRequest + Input *CreateChannelInput + func (r CreateChannelRequest) Send() (*CreateChannelOutput, error) + type CreateDatasetContentInput struct + DatasetName *string + func (s *CreateDatasetContentInput) Validate() error + func (s CreateDatasetContentInput) GoString() string + func (s CreateDatasetContentInput) MarshalFields(e protocol.FieldEncoder) error + func (s CreateDatasetContentInput) String() string + type CreateDatasetContentOutput struct + func (s CreateDatasetContentOutput) GoString() string + func (s CreateDatasetContentOutput) MarshalFields(e protocol.FieldEncoder) error + func (s CreateDatasetContentOutput) SDKResponseMetadata() aws.Response + func (s CreateDatasetContentOutput) String() string + type CreateDatasetContentRequest struct + Copy func(*CreateDatasetContentInput) CreateDatasetContentRequest + Input *CreateDatasetContentInput + func (r CreateDatasetContentRequest) Send() (*CreateDatasetContentOutput, error) + type CreateDatasetInput struct + Actions []DatasetAction + DatasetName *string + Triggers []DatasetTrigger + func (s *CreateDatasetInput) Validate() error + func (s CreateDatasetInput) GoString() string + func (s CreateDatasetInput) MarshalFields(e protocol.FieldEncoder) error + func (s CreateDatasetInput) String() string + type CreateDatasetOutput struct + DatasetArn *string + DatasetName *string + func (s CreateDatasetOutput) GoString() string + func (s CreateDatasetOutput) MarshalFields(e protocol.FieldEncoder) error + func (s CreateDatasetOutput) SDKResponseMetadata() aws.Response + func (s CreateDatasetOutput) String() string + type CreateDatasetRequest struct + Copy func(*CreateDatasetInput) CreateDatasetRequest + Input *CreateDatasetInput + func (r CreateDatasetRequest) Send() (*CreateDatasetOutput, error) + type CreateDatastoreInput struct + DatastoreName *string + RetentionPeriod *RetentionPeriod + func (s *CreateDatastoreInput) Validate() error + func (s CreateDatastoreInput) GoString() string + func (s CreateDatastoreInput) MarshalFields(e protocol.FieldEncoder) error + func (s CreateDatastoreInput) String() string + type CreateDatastoreOutput struct + DatastoreArn *string + DatastoreName *string + RetentionPeriod *RetentionPeriod + func (s CreateDatastoreOutput) GoString() string + func (s CreateDatastoreOutput) MarshalFields(e protocol.FieldEncoder) error + func (s CreateDatastoreOutput) SDKResponseMetadata() aws.Response + func (s CreateDatastoreOutput) String() string + type CreateDatastoreRequest struct + Copy func(*CreateDatastoreInput) CreateDatastoreRequest + Input *CreateDatastoreInput + func (r CreateDatastoreRequest) Send() (*CreateDatastoreOutput, error) + type CreatePipelineInput struct + PipelineActivities []PipelineActivity + PipelineName *string + func (s *CreatePipelineInput) Validate() error + func (s CreatePipelineInput) GoString() string + func (s CreatePipelineInput) MarshalFields(e protocol.FieldEncoder) error + func (s CreatePipelineInput) String() string + type CreatePipelineOutput struct + PipelineArn *string + PipelineName *string + func (s CreatePipelineOutput) GoString() string + func (s CreatePipelineOutput) MarshalFields(e protocol.FieldEncoder) error + func (s CreatePipelineOutput) SDKResponseMetadata() aws.Response + func (s CreatePipelineOutput) String() string + type CreatePipelineRequest struct + Copy func(*CreatePipelineInput) CreatePipelineRequest + Input *CreatePipelineInput + func (r CreatePipelineRequest) Send() (*CreatePipelineOutput, error) + type Dataset struct + Actions []DatasetAction + Arn *string + CreationTime *time.Time + LastUpdateTime *time.Time + Name *string + Status DatasetStatus + Triggers []DatasetTrigger + func (s Dataset) GoString() string + func (s Dataset) MarshalFields(e protocol.FieldEncoder) error + func (s Dataset) String() string + type DatasetAction struct + ActionName *string + QueryAction *SqlQueryDatasetAction + func (s *DatasetAction) Validate() error + func (s DatasetAction) GoString() string + func (s DatasetAction) MarshalFields(e protocol.FieldEncoder) error + func (s DatasetAction) String() string + type DatasetContentState string + const DatasetContentStateCreating + const DatasetContentStateFailed + const DatasetContentStateSucceeded + func (enum DatasetContentState) MarshalValue() (string, error) + func (enum DatasetContentState) MarshalValueBuf(b []byte) ([]byte, error) + type DatasetContentStatus struct + Reason *string + State DatasetContentState + func (s DatasetContentStatus) GoString() string + func (s DatasetContentStatus) MarshalFields(e protocol.FieldEncoder) error + func (s DatasetContentStatus) String() string + type DatasetEntry struct + DataURI *string + EntryName *string + func (s DatasetEntry) GoString() string + func (s DatasetEntry) MarshalFields(e protocol.FieldEncoder) error + func (s DatasetEntry) String() string + type DatasetStatus string + const DatasetStatusActive + const DatasetStatusCreating + const DatasetStatusDeleting + func (enum DatasetStatus) MarshalValue() (string, error) + func (enum DatasetStatus) MarshalValueBuf(b []byte) ([]byte, error) + type DatasetSummary struct + CreationTime *time.Time + DatasetName *string + LastUpdateTime *time.Time + Status DatasetStatus + func (s DatasetSummary) GoString() string + func (s DatasetSummary) MarshalFields(e protocol.FieldEncoder) error + func (s DatasetSummary) String() string + type DatasetTrigger struct + Schedule *Schedule + func (s DatasetTrigger) GoString() string + func (s DatasetTrigger) MarshalFields(e protocol.FieldEncoder) error + func (s DatasetTrigger) String() string + type Datastore struct + Arn *string + CreationTime *time.Time + LastUpdateTime *time.Time + Name *string + RetentionPeriod *RetentionPeriod + Status DatastoreStatus + func (s Datastore) GoString() string + func (s Datastore) MarshalFields(e protocol.FieldEncoder) error + func (s Datastore) String() string + type DatastoreActivity struct + DatastoreName *string + Name *string + func (s *DatastoreActivity) Validate() error + func (s DatastoreActivity) GoString() string + func (s DatastoreActivity) MarshalFields(e protocol.FieldEncoder) error + func (s DatastoreActivity) String() string + type DatastoreStatus string + const DatastoreStatusActive + const DatastoreStatusCreating + const DatastoreStatusDeleting + func (enum DatastoreStatus) MarshalValue() (string, error) + func (enum DatastoreStatus) MarshalValueBuf(b []byte) ([]byte, error) + type DatastoreSummary struct + CreationTime *time.Time + DatastoreName *string + LastUpdateTime *time.Time + Status DatastoreStatus + func (s DatastoreSummary) GoString() string + func (s DatastoreSummary) MarshalFields(e protocol.FieldEncoder) error + func (s DatastoreSummary) String() string + type DeleteChannelInput struct + ChannelName *string + func (s *DeleteChannelInput) Validate() error + func (s DeleteChannelInput) GoString() string + func (s DeleteChannelInput) MarshalFields(e protocol.FieldEncoder) error + func (s DeleteChannelInput) String() string + type DeleteChannelOutput struct + func (s DeleteChannelOutput) GoString() string + func (s DeleteChannelOutput) MarshalFields(e protocol.FieldEncoder) error + func (s DeleteChannelOutput) SDKResponseMetadata() aws.Response + func (s DeleteChannelOutput) String() string + type DeleteChannelRequest struct + Copy func(*DeleteChannelInput) DeleteChannelRequest + Input *DeleteChannelInput + func (r DeleteChannelRequest) Send() (*DeleteChannelOutput, error) + type DeleteDatasetContentInput struct + DatasetName *string + VersionId *string + func (s *DeleteDatasetContentInput) Validate() error + func (s DeleteDatasetContentInput) GoString() string + func (s DeleteDatasetContentInput) MarshalFields(e protocol.FieldEncoder) error + func (s DeleteDatasetContentInput) String() string + type DeleteDatasetContentOutput struct + func (s DeleteDatasetContentOutput) GoString() string + func (s DeleteDatasetContentOutput) MarshalFields(e protocol.FieldEncoder) error + func (s DeleteDatasetContentOutput) SDKResponseMetadata() aws.Response + func (s DeleteDatasetContentOutput) String() string + type DeleteDatasetContentRequest struct + Copy func(*DeleteDatasetContentInput) DeleteDatasetContentRequest + Input *DeleteDatasetContentInput + func (r DeleteDatasetContentRequest) Send() (*DeleteDatasetContentOutput, error) + type DeleteDatasetInput struct + DatasetName *string + func (s *DeleteDatasetInput) Validate() error + func (s DeleteDatasetInput) GoString() string + func (s DeleteDatasetInput) MarshalFields(e protocol.FieldEncoder) error + func (s DeleteDatasetInput) String() string + type DeleteDatasetOutput struct + func (s DeleteDatasetOutput) GoString() string + func (s DeleteDatasetOutput) MarshalFields(e protocol.FieldEncoder) error + func (s DeleteDatasetOutput) SDKResponseMetadata() aws.Response + func (s DeleteDatasetOutput) String() string + type DeleteDatasetRequest struct + Copy func(*DeleteDatasetInput) DeleteDatasetRequest + Input *DeleteDatasetInput + func (r DeleteDatasetRequest) Send() (*DeleteDatasetOutput, error) + type DeleteDatastoreInput struct + DatastoreName *string + func (s *DeleteDatastoreInput) Validate() error + func (s DeleteDatastoreInput) GoString() string + func (s DeleteDatastoreInput) MarshalFields(e protocol.FieldEncoder) error + func (s DeleteDatastoreInput) String() string + type DeleteDatastoreOutput struct + func (s DeleteDatastoreOutput) GoString() string + func (s DeleteDatastoreOutput) MarshalFields(e protocol.FieldEncoder) error + func (s DeleteDatastoreOutput) SDKResponseMetadata() aws.Response + func (s DeleteDatastoreOutput) String() string + type DeleteDatastoreRequest struct + Copy func(*DeleteDatastoreInput) DeleteDatastoreRequest + Input *DeleteDatastoreInput + func (r DeleteDatastoreRequest) Send() (*DeleteDatastoreOutput, error) + type DeletePipelineInput struct + PipelineName *string + func (s *DeletePipelineInput) Validate() error + func (s DeletePipelineInput) GoString() string + func (s DeletePipelineInput) MarshalFields(e protocol.FieldEncoder) error + func (s DeletePipelineInput) String() string + type DeletePipelineOutput struct + func (s DeletePipelineOutput) GoString() string + func (s DeletePipelineOutput) MarshalFields(e protocol.FieldEncoder) error + func (s DeletePipelineOutput) SDKResponseMetadata() aws.Response + func (s DeletePipelineOutput) String() string + type DeletePipelineRequest struct + Copy func(*DeletePipelineInput) DeletePipelineRequest + Input *DeletePipelineInput + func (r DeletePipelineRequest) Send() (*DeletePipelineOutput, error) + type DescribeChannelInput struct + ChannelName *string + func (s *DescribeChannelInput) Validate() error + func (s DescribeChannelInput) GoString() string + func (s DescribeChannelInput) MarshalFields(e protocol.FieldEncoder) error + func (s DescribeChannelInput) String() string + type DescribeChannelOutput struct + Channel *Channel + func (s DescribeChannelOutput) GoString() string + func (s DescribeChannelOutput) MarshalFields(e protocol.FieldEncoder) error + func (s DescribeChannelOutput) SDKResponseMetadata() aws.Response + func (s DescribeChannelOutput) String() string + type DescribeChannelRequest struct + Copy func(*DescribeChannelInput) DescribeChannelRequest + Input *DescribeChannelInput + func (r DescribeChannelRequest) Send() (*DescribeChannelOutput, error) + type DescribeDatasetInput struct + DatasetName *string + func (s *DescribeDatasetInput) Validate() error + func (s DescribeDatasetInput) GoString() string + func (s DescribeDatasetInput) MarshalFields(e protocol.FieldEncoder) error + func (s DescribeDatasetInput) String() string + type DescribeDatasetOutput struct + Dataset *Dataset + func (s DescribeDatasetOutput) GoString() string + func (s DescribeDatasetOutput) MarshalFields(e protocol.FieldEncoder) error + func (s DescribeDatasetOutput) SDKResponseMetadata() aws.Response + func (s DescribeDatasetOutput) String() string + type DescribeDatasetRequest struct + Copy func(*DescribeDatasetInput) DescribeDatasetRequest + Input *DescribeDatasetInput + func (r DescribeDatasetRequest) Send() (*DescribeDatasetOutput, error) + type DescribeDatastoreInput struct + DatastoreName *string + func (s *DescribeDatastoreInput) Validate() error + func (s DescribeDatastoreInput) GoString() string + func (s DescribeDatastoreInput) MarshalFields(e protocol.FieldEncoder) error + func (s DescribeDatastoreInput) String() string + type DescribeDatastoreOutput struct + Datastore *Datastore + func (s DescribeDatastoreOutput) GoString() string + func (s DescribeDatastoreOutput) MarshalFields(e protocol.FieldEncoder) error + func (s DescribeDatastoreOutput) SDKResponseMetadata() aws.Response + func (s DescribeDatastoreOutput) String() string + type DescribeDatastoreRequest struct + Copy func(*DescribeDatastoreInput) DescribeDatastoreRequest + Input *DescribeDatastoreInput + func (r DescribeDatastoreRequest) Send() (*DescribeDatastoreOutput, error) + type DescribeLoggingOptionsInput struct + func (s DescribeLoggingOptionsInput) GoString() string + func (s DescribeLoggingOptionsInput) MarshalFields(e protocol.FieldEncoder) error + func (s DescribeLoggingOptionsInput) String() string + type DescribeLoggingOptionsOutput struct + LoggingOptions *LoggingOptions + func (s DescribeLoggingOptionsOutput) GoString() string + func (s DescribeLoggingOptionsOutput) MarshalFields(e protocol.FieldEncoder) error + func (s DescribeLoggingOptionsOutput) SDKResponseMetadata() aws.Response + func (s DescribeLoggingOptionsOutput) String() string + type DescribeLoggingOptionsRequest struct + Copy func(*DescribeLoggingOptionsInput) DescribeLoggingOptionsRequest + Input *DescribeLoggingOptionsInput + func (r DescribeLoggingOptionsRequest) Send() (*DescribeLoggingOptionsOutput, error) + type DescribePipelineInput struct + PipelineName *string + func (s *DescribePipelineInput) Validate() error + func (s DescribePipelineInput) GoString() string + func (s DescribePipelineInput) MarshalFields(e protocol.FieldEncoder) error + func (s DescribePipelineInput) String() string + type DescribePipelineOutput struct + Pipeline *Pipeline + func (s DescribePipelineOutput) GoString() string + func (s DescribePipelineOutput) MarshalFields(e protocol.FieldEncoder) error + func (s DescribePipelineOutput) SDKResponseMetadata() aws.Response + func (s DescribePipelineOutput) String() string + type DescribePipelineRequest struct + Copy func(*DescribePipelineInput) DescribePipelineRequest + Input *DescribePipelineInput + func (r DescribePipelineRequest) Send() (*DescribePipelineOutput, error) + type DeviceRegistryEnrichActivity struct + Attribute *string + Name *string + Next *string + RoleArn *string + ThingName *string + func (s *DeviceRegistryEnrichActivity) Validate() error + func (s DeviceRegistryEnrichActivity) GoString() string + func (s DeviceRegistryEnrichActivity) MarshalFields(e protocol.FieldEncoder) error + func (s DeviceRegistryEnrichActivity) String() string + type DeviceShadowEnrichActivity struct + Attribute *string + Name *string + Next *string + RoleArn *string + ThingName *string + func (s *DeviceShadowEnrichActivity) Validate() error + func (s DeviceShadowEnrichActivity) GoString() string + func (s DeviceShadowEnrichActivity) MarshalFields(e protocol.FieldEncoder) error + func (s DeviceShadowEnrichActivity) String() string + type FilterActivity struct + Filter *string + Name *string + Next *string + func (s *FilterActivity) Validate() error + func (s FilterActivity) GoString() string + func (s FilterActivity) MarshalFields(e protocol.FieldEncoder) error + func (s FilterActivity) String() string + type GetDatasetContentInput struct + DatasetName *string + VersionId *string + func (s *GetDatasetContentInput) Validate() error + func (s GetDatasetContentInput) GoString() string + func (s GetDatasetContentInput) MarshalFields(e protocol.FieldEncoder) error + func (s GetDatasetContentInput) String() string + type GetDatasetContentOutput struct + Entries []DatasetEntry + Status *DatasetContentStatus + Timestamp *time.Time + func (s GetDatasetContentOutput) GoString() string + func (s GetDatasetContentOutput) MarshalFields(e protocol.FieldEncoder) error + func (s GetDatasetContentOutput) SDKResponseMetadata() aws.Response + func (s GetDatasetContentOutput) String() string + type GetDatasetContentRequest struct + Copy func(*GetDatasetContentInput) GetDatasetContentRequest + Input *GetDatasetContentInput + func (r GetDatasetContentRequest) Send() (*GetDatasetContentOutput, error) + type IoTAnalytics struct + func New(config aws.Config) *IoTAnalytics + func (c *IoTAnalytics) BatchPutMessageRequest(input *BatchPutMessageInput) BatchPutMessageRequest + func (c *IoTAnalytics) CancelPipelineReprocessingRequest(input *CancelPipelineReprocessingInput) CancelPipelineReprocessingRequest + func (c *IoTAnalytics) CreateChannelRequest(input *CreateChannelInput) CreateChannelRequest + func (c *IoTAnalytics) CreateDatasetContentRequest(input *CreateDatasetContentInput) CreateDatasetContentRequest + func (c *IoTAnalytics) CreateDatasetRequest(input *CreateDatasetInput) CreateDatasetRequest + func (c *IoTAnalytics) CreateDatastoreRequest(input *CreateDatastoreInput) CreateDatastoreRequest + func (c *IoTAnalytics) CreatePipelineRequest(input *CreatePipelineInput) CreatePipelineRequest + func (c *IoTAnalytics) DeleteChannelRequest(input *DeleteChannelInput) DeleteChannelRequest + func (c *IoTAnalytics) DeleteDatasetContentRequest(input *DeleteDatasetContentInput) DeleteDatasetContentRequest + func (c *IoTAnalytics) DeleteDatasetRequest(input *DeleteDatasetInput) DeleteDatasetRequest + func (c *IoTAnalytics) DeleteDatastoreRequest(input *DeleteDatastoreInput) DeleteDatastoreRequest + func (c *IoTAnalytics) DeletePipelineRequest(input *DeletePipelineInput) DeletePipelineRequest + func (c *IoTAnalytics) DescribeChannelRequest(input *DescribeChannelInput) DescribeChannelRequest + func (c *IoTAnalytics) DescribeDatasetRequest(input *DescribeDatasetInput) DescribeDatasetRequest + func (c *IoTAnalytics) DescribeDatastoreRequest(input *DescribeDatastoreInput) DescribeDatastoreRequest + func (c *IoTAnalytics) DescribeLoggingOptionsRequest(input *DescribeLoggingOptionsInput) DescribeLoggingOptionsRequest + func (c *IoTAnalytics) DescribePipelineRequest(input *DescribePipelineInput) DescribePipelineRequest + func (c *IoTAnalytics) GetDatasetContentRequest(input *GetDatasetContentInput) GetDatasetContentRequest + func (c *IoTAnalytics) ListChannelsRequest(input *ListChannelsInput) ListChannelsRequest + func (c *IoTAnalytics) ListDatasetsRequest(input *ListDatasetsInput) ListDatasetsRequest + func (c *IoTAnalytics) ListDatastoresRequest(input *ListDatastoresInput) ListDatastoresRequest + func (c *IoTAnalytics) ListPipelinesRequest(input *ListPipelinesInput) ListPipelinesRequest + func (c *IoTAnalytics) PutLoggingOptionsRequest(input *PutLoggingOptionsInput) PutLoggingOptionsRequest + func (c *IoTAnalytics) RunPipelineActivityRequest(input *RunPipelineActivityInput) RunPipelineActivityRequest + func (c *IoTAnalytics) SampleChannelDataRequest(input *SampleChannelDataInput) SampleChannelDataRequest + func (c *IoTAnalytics) StartPipelineReprocessingRequest(input *StartPipelineReprocessingInput) StartPipelineReprocessingRequest + func (c *IoTAnalytics) UpdateChannelRequest(input *UpdateChannelInput) UpdateChannelRequest + func (c *IoTAnalytics) UpdateDatasetRequest(input *UpdateDatasetInput) UpdateDatasetRequest + func (c *IoTAnalytics) UpdateDatastoreRequest(input *UpdateDatastoreInput) UpdateDatastoreRequest + func (c *IoTAnalytics) UpdatePipelineRequest(input *UpdatePipelineInput) UpdatePipelineRequest + type LambdaActivity struct + BatchSize *int64 + LambdaName *string + Name *string + Next *string + func (s *LambdaActivity) Validate() error + func (s LambdaActivity) GoString() string + func (s LambdaActivity) MarshalFields(e protocol.FieldEncoder) error + func (s LambdaActivity) String() string + type ListChannelsInput struct + MaxResults *int64 + NextToken *string + func (s *ListChannelsInput) Validate() error + func (s ListChannelsInput) GoString() string + func (s ListChannelsInput) MarshalFields(e protocol.FieldEncoder) error + func (s ListChannelsInput) String() string + type ListChannelsOutput struct + ChannelSummaries []ChannelSummary + NextToken *string + func (s ListChannelsOutput) GoString() string + func (s ListChannelsOutput) MarshalFields(e protocol.FieldEncoder) error + func (s ListChannelsOutput) SDKResponseMetadata() aws.Response + func (s ListChannelsOutput) String() string + type ListChannelsPager struct + func (p *ListChannelsPager) CurrentPage() *ListChannelsOutput + type ListChannelsRequest struct + Copy func(*ListChannelsInput) ListChannelsRequest + Input *ListChannelsInput + func (p *ListChannelsRequest) Paginate(opts ...aws.Option) ListChannelsPager + func (r ListChannelsRequest) Send() (*ListChannelsOutput, error) + type ListDatasetsInput struct + MaxResults *int64 + NextToken *string + func (s *ListDatasetsInput) Validate() error + func (s ListDatasetsInput) GoString() string + func (s ListDatasetsInput) MarshalFields(e protocol.FieldEncoder) error + func (s ListDatasetsInput) String() string + type ListDatasetsOutput struct + DatasetSummaries []DatasetSummary + NextToken *string + func (s ListDatasetsOutput) GoString() string + func (s ListDatasetsOutput) MarshalFields(e protocol.FieldEncoder) error + func (s ListDatasetsOutput) SDKResponseMetadata() aws.Response + func (s ListDatasetsOutput) String() string + type ListDatasetsPager struct + func (p *ListDatasetsPager) CurrentPage() *ListDatasetsOutput + type ListDatasetsRequest struct + Copy func(*ListDatasetsInput) ListDatasetsRequest + Input *ListDatasetsInput + func (p *ListDatasetsRequest) Paginate(opts ...aws.Option) ListDatasetsPager + func (r ListDatasetsRequest) Send() (*ListDatasetsOutput, error) + type ListDatastoresInput struct + MaxResults *int64 + NextToken *string + func (s *ListDatastoresInput) Validate() error + func (s ListDatastoresInput) GoString() string + func (s ListDatastoresInput) MarshalFields(e protocol.FieldEncoder) error + func (s ListDatastoresInput) String() string + type ListDatastoresOutput struct + DatastoreSummaries []DatastoreSummary + NextToken *string + func (s ListDatastoresOutput) GoString() string + func (s ListDatastoresOutput) MarshalFields(e protocol.FieldEncoder) error + func (s ListDatastoresOutput) SDKResponseMetadata() aws.Response + func (s ListDatastoresOutput) String() string + type ListDatastoresPager struct + func (p *ListDatastoresPager) CurrentPage() *ListDatastoresOutput + type ListDatastoresRequest struct + Copy func(*ListDatastoresInput) ListDatastoresRequest + Input *ListDatastoresInput + func (p *ListDatastoresRequest) Paginate(opts ...aws.Option) ListDatastoresPager + func (r ListDatastoresRequest) Send() (*ListDatastoresOutput, error) + type ListPipelinesInput struct + MaxResults *int64 + NextToken *string + func (s *ListPipelinesInput) Validate() error + func (s ListPipelinesInput) GoString() string + func (s ListPipelinesInput) MarshalFields(e protocol.FieldEncoder) error + func (s ListPipelinesInput) String() string + type ListPipelinesOutput struct + NextToken *string + PipelineSummaries []PipelineSummary + func (s ListPipelinesOutput) GoString() string + func (s ListPipelinesOutput) MarshalFields(e protocol.FieldEncoder) error + func (s ListPipelinesOutput) SDKResponseMetadata() aws.Response + func (s ListPipelinesOutput) String() string + type ListPipelinesPager struct + func (p *ListPipelinesPager) CurrentPage() *ListPipelinesOutput + type ListPipelinesRequest struct + Copy func(*ListPipelinesInput) ListPipelinesRequest + Input *ListPipelinesInput + func (p *ListPipelinesRequest) Paginate(opts ...aws.Option) ListPipelinesPager + func (r ListPipelinesRequest) Send() (*ListPipelinesOutput, error) + type LoggingLevel string + const LoggingLevelError + func (enum LoggingLevel) MarshalValue() (string, error) + func (enum LoggingLevel) MarshalValueBuf(b []byte) ([]byte, error) + type LoggingOptions struct + Enabled *bool + Level LoggingLevel + RoleArn *string + func (s *LoggingOptions) Validate() error + func (s LoggingOptions) GoString() string + func (s LoggingOptions) MarshalFields(e protocol.FieldEncoder) error + func (s LoggingOptions) String() string + type MathActivity struct + Attribute *string + Math *string + Name *string + Next *string + func (s *MathActivity) Validate() error + func (s MathActivity) GoString() string + func (s MathActivity) MarshalFields(e protocol.FieldEncoder) error + func (s MathActivity) String() string + type Message struct + MessageId *string + Payload []byte + func (s *Message) Validate() error + func (s Message) GoString() string + func (s Message) MarshalFields(e protocol.FieldEncoder) error + func (s Message) String() string + type Pipeline struct + Activities []PipelineActivity + Arn *string + CreationTime *time.Time + LastUpdateTime *time.Time + Name *string + ReprocessingSummaries []ReprocessingSummary + func (s Pipeline) GoString() string + func (s Pipeline) MarshalFields(e protocol.FieldEncoder) error + func (s Pipeline) String() string + type PipelineActivity struct + AddAttributes *AddAttributesActivity + Channel *ChannelActivity + Datastore *DatastoreActivity + DeviceRegistryEnrich *DeviceRegistryEnrichActivity + DeviceShadowEnrich *DeviceShadowEnrichActivity + Filter *FilterActivity + Lambda *LambdaActivity + Math *MathActivity + RemoveAttributes *RemoveAttributesActivity + SelectAttributes *SelectAttributesActivity + func (s *PipelineActivity) Validate() error + func (s PipelineActivity) GoString() string + func (s PipelineActivity) MarshalFields(e protocol.FieldEncoder) error + func (s PipelineActivity) String() string + type PipelineSummary struct + CreationTime *time.Time + LastUpdateTime *time.Time + PipelineName *string + ReprocessingSummaries []ReprocessingSummary + func (s PipelineSummary) GoString() string + func (s PipelineSummary) MarshalFields(e protocol.FieldEncoder) error + func (s PipelineSummary) String() string + type PutLoggingOptionsInput struct + LoggingOptions *LoggingOptions + func (s *PutLoggingOptionsInput) Validate() error + func (s PutLoggingOptionsInput) GoString() string + func (s PutLoggingOptionsInput) MarshalFields(e protocol.FieldEncoder) error + func (s PutLoggingOptionsInput) String() string + type PutLoggingOptionsOutput struct + func (s PutLoggingOptionsOutput) GoString() string + func (s PutLoggingOptionsOutput) MarshalFields(e protocol.FieldEncoder) error + func (s PutLoggingOptionsOutput) SDKResponseMetadata() aws.Response + func (s PutLoggingOptionsOutput) String() string + type PutLoggingOptionsRequest struct + Copy func(*PutLoggingOptionsInput) PutLoggingOptionsRequest + Input *PutLoggingOptionsInput + func (r PutLoggingOptionsRequest) Send() (*PutLoggingOptionsOutput, error) + type RemoveAttributesActivity struct + Attributes []string + Name *string + Next *string + func (s *RemoveAttributesActivity) Validate() error + func (s RemoveAttributesActivity) GoString() string + func (s RemoveAttributesActivity) MarshalFields(e protocol.FieldEncoder) error + func (s RemoveAttributesActivity) String() string + type ReprocessingStatus string + const ReprocessingStatusCancelled + const ReprocessingStatusFailed + const ReprocessingStatusRunning + const ReprocessingStatusSucceeded + func (enum ReprocessingStatus) MarshalValue() (string, error) + func (enum ReprocessingStatus) MarshalValueBuf(b []byte) ([]byte, error) + type ReprocessingSummary struct + CreationTime *time.Time + Id *string + Status ReprocessingStatus + func (s ReprocessingSummary) GoString() string + func (s ReprocessingSummary) MarshalFields(e protocol.FieldEncoder) error + func (s ReprocessingSummary) String() string + type RetentionPeriod struct + NumberOfDays *int64 + Unlimited *bool + func (s *RetentionPeriod) Validate() error + func (s RetentionPeriod) GoString() string + func (s RetentionPeriod) MarshalFields(e protocol.FieldEncoder) error + func (s RetentionPeriod) String() string + type RunPipelineActivityInput struct + Payloads [][]byte + PipelineActivity *PipelineActivity + func (s *RunPipelineActivityInput) Validate() error + func (s RunPipelineActivityInput) GoString() string + func (s RunPipelineActivityInput) MarshalFields(e protocol.FieldEncoder) error + func (s RunPipelineActivityInput) String() string + type RunPipelineActivityOutput struct + LogResult *string + Payloads [][]byte + func (s RunPipelineActivityOutput) GoString() string + func (s RunPipelineActivityOutput) MarshalFields(e protocol.FieldEncoder) error + func (s RunPipelineActivityOutput) SDKResponseMetadata() aws.Response + func (s RunPipelineActivityOutput) String() string + type RunPipelineActivityRequest struct + Copy func(*RunPipelineActivityInput) RunPipelineActivityRequest + Input *RunPipelineActivityInput + func (r RunPipelineActivityRequest) Send() (*RunPipelineActivityOutput, error) + type SampleChannelDataInput struct + ChannelName *string + EndTime *time.Time + MaxMessages *int64 + StartTime *time.Time + func (s *SampleChannelDataInput) Validate() error + func (s SampleChannelDataInput) GoString() string + func (s SampleChannelDataInput) MarshalFields(e protocol.FieldEncoder) error + func (s SampleChannelDataInput) String() string + type SampleChannelDataOutput struct + Payloads [][]byte + func (s SampleChannelDataOutput) GoString() string + func (s SampleChannelDataOutput) MarshalFields(e protocol.FieldEncoder) error + func (s SampleChannelDataOutput) SDKResponseMetadata() aws.Response + func (s SampleChannelDataOutput) String() string + type SampleChannelDataRequest struct + Copy func(*SampleChannelDataInput) SampleChannelDataRequest + Input *SampleChannelDataInput + func (r SampleChannelDataRequest) Send() (*SampleChannelDataOutput, error) + type Schedule struct + Expression *string + func (s Schedule) GoString() string + func (s Schedule) MarshalFields(e protocol.FieldEncoder) error + func (s Schedule) String() string + type SelectAttributesActivity struct + Attributes []string + Name *string + Next *string + func (s *SelectAttributesActivity) Validate() error + func (s SelectAttributesActivity) GoString() string + func (s SelectAttributesActivity) MarshalFields(e protocol.FieldEncoder) error + func (s SelectAttributesActivity) String() string + type SqlQueryDatasetAction struct + SqlQuery *string + func (s *SqlQueryDatasetAction) Validate() error + func (s SqlQueryDatasetAction) GoString() string + func (s SqlQueryDatasetAction) MarshalFields(e protocol.FieldEncoder) error + func (s SqlQueryDatasetAction) String() string + type StartPipelineReprocessingInput struct + EndTime *time.Time + PipelineName *string + StartTime *time.Time + func (s *StartPipelineReprocessingInput) Validate() error + func (s StartPipelineReprocessingInput) GoString() string + func (s StartPipelineReprocessingInput) MarshalFields(e protocol.FieldEncoder) error + func (s StartPipelineReprocessingInput) String() string + type StartPipelineReprocessingOutput struct + ReprocessingId *string + func (s StartPipelineReprocessingOutput) GoString() string + func (s StartPipelineReprocessingOutput) MarshalFields(e protocol.FieldEncoder) error + func (s StartPipelineReprocessingOutput) SDKResponseMetadata() aws.Response + func (s StartPipelineReprocessingOutput) String() string + type StartPipelineReprocessingRequest struct + Copy func(*StartPipelineReprocessingInput) StartPipelineReprocessingRequest + Input *StartPipelineReprocessingInput + func (r StartPipelineReprocessingRequest) Send() (*StartPipelineReprocessingOutput, error) + type UpdateChannelInput struct + ChannelName *string + RetentionPeriod *RetentionPeriod + func (s *UpdateChannelInput) Validate() error + func (s UpdateChannelInput) GoString() string + func (s UpdateChannelInput) MarshalFields(e protocol.FieldEncoder) error + func (s UpdateChannelInput) String() string + type UpdateChannelOutput struct + func (s UpdateChannelOutput) GoString() string + func (s UpdateChannelOutput) MarshalFields(e protocol.FieldEncoder) error + func (s UpdateChannelOutput) SDKResponseMetadata() aws.Response + func (s UpdateChannelOutput) String() string + type UpdateChannelRequest struct + Copy func(*UpdateChannelInput) UpdateChannelRequest + Input *UpdateChannelInput + func (r UpdateChannelRequest) Send() (*UpdateChannelOutput, error) + type UpdateDatasetInput struct + Actions []DatasetAction + DatasetName *string + Triggers []DatasetTrigger + func (s *UpdateDatasetInput) Validate() error + func (s UpdateDatasetInput) GoString() string + func (s UpdateDatasetInput) MarshalFields(e protocol.FieldEncoder) error + func (s UpdateDatasetInput) String() string + type UpdateDatasetOutput struct + func (s UpdateDatasetOutput) GoString() string + func (s UpdateDatasetOutput) MarshalFields(e protocol.FieldEncoder) error + func (s UpdateDatasetOutput) SDKResponseMetadata() aws.Response + func (s UpdateDatasetOutput) String() string + type UpdateDatasetRequest struct + Copy func(*UpdateDatasetInput) UpdateDatasetRequest + Input *UpdateDatasetInput + func (r UpdateDatasetRequest) Send() (*UpdateDatasetOutput, error) + type UpdateDatastoreInput struct + DatastoreName *string + RetentionPeriod *RetentionPeriod + func (s *UpdateDatastoreInput) Validate() error + func (s UpdateDatastoreInput) GoString() string + func (s UpdateDatastoreInput) MarshalFields(e protocol.FieldEncoder) error + func (s UpdateDatastoreInput) String() string + type UpdateDatastoreOutput struct + func (s UpdateDatastoreOutput) GoString() string + func (s UpdateDatastoreOutput) MarshalFields(e protocol.FieldEncoder) error + func (s UpdateDatastoreOutput) SDKResponseMetadata() aws.Response + func (s UpdateDatastoreOutput) String() string + type UpdateDatastoreRequest struct + Copy func(*UpdateDatastoreInput) UpdateDatastoreRequest + Input *UpdateDatastoreInput + func (r UpdateDatastoreRequest) Send() (*UpdateDatastoreOutput, error) + type UpdatePipelineInput struct + PipelineActivities []PipelineActivity + PipelineName *string + func (s *UpdatePipelineInput) Validate() error + func (s UpdatePipelineInput) GoString() string + func (s UpdatePipelineInput) MarshalFields(e protocol.FieldEncoder) error + func (s UpdatePipelineInput) String() string + type UpdatePipelineOutput struct + func (s UpdatePipelineOutput) GoString() string + func (s UpdatePipelineOutput) MarshalFields(e protocol.FieldEncoder) error + func (s UpdatePipelineOutput) SDKResponseMetadata() aws.Response + func (s UpdatePipelineOutput) String() string + type UpdatePipelineRequest struct + Copy func(*UpdatePipelineInput) UpdatePipelineRequest + Input *UpdatePipelineInput + func (r UpdatePipelineRequest) Send() (*UpdatePipelineOutput, error)
Go to main page