iotanalytics

package

Go to main page

Versions in this module

v0

v0.24.0

Jul 22, 2020

v0.23.0

May 28, 2020

v0.22.0

Apr 27, 2020

v0.21.0

Apr 22, 2020

v0.20.0

Mar 17, 2020

v0.19.0

Jan 30, 2020

v0.18.0

Dec 12, 2019

v0.17.0

Nov 21, 2019

v0.16.0

Nov 13, 2019

v0.15.0

Oct 18, 2019

Changes in this version

type DatasetContentSummary

+ CompletionTime *time.Time

v0.14.0

Oct 8, 2019

v0.13.0

Oct 2, 2019

v0.12.0

Sep 17, 2019

v0.11.0

Aug 23, 2019

v0.10.0

Jul 25, 2019

Changes in this version

type Channel

+ Storage *ChannelStorage

+ type ChannelStorage struct

+ CustomerManagedS3 *CustomerManagedChannelS3Storage

+ ServiceManagedS3 *ServiceManagedChannelS3Storage

+ func (s *ChannelStorage) Validate() error

+ func (s ChannelStorage) MarshalFields(e protocol.FieldEncoder) error

+ func (s ChannelStorage) String() string

+ type ChannelStorageSummary struct

+ CustomerManagedS3 *CustomerManagedChannelS3StorageSummary

+ ServiceManagedS3 *ServiceManagedChannelS3StorageSummary

+ func (s ChannelStorageSummary) MarshalFields(e protocol.FieldEncoder) error

+ func (s ChannelStorageSummary) String() string

type ChannelSummary

+ ChannelStorage *ChannelStorageSummary

type CreateChannelInput

+ ChannelStorage *ChannelStorage

type CreateDatastoreInput

+ DatastoreStorage *DatastoreStorage

+ type CustomerManagedChannelS3Storage struct

+ Bucket *string

+ KeyPrefix *string

+ RoleArn *string

+ func (s *CustomerManagedChannelS3Storage) Validate() error

+ func (s CustomerManagedChannelS3Storage) MarshalFields(e protocol.FieldEncoder) error

+ func (s CustomerManagedChannelS3Storage) String() string

+ type CustomerManagedChannelS3StorageSummary struct

+ Bucket *string

+ KeyPrefix *string

+ RoleArn *string

+ func (s CustomerManagedChannelS3StorageSummary) MarshalFields(e protocol.FieldEncoder) error

+ func (s CustomerManagedChannelS3StorageSummary) String() string

+ type CustomerManagedDatastoreS3Storage struct

+ Bucket *string

+ KeyPrefix *string

+ RoleArn *string

+ func (s *CustomerManagedDatastoreS3Storage) Validate() error

+ func (s CustomerManagedDatastoreS3Storage) MarshalFields(e protocol.FieldEncoder) error

+ func (s CustomerManagedDatastoreS3Storage) String() string

+ type CustomerManagedDatastoreS3StorageSummary struct

+ Bucket *string

+ KeyPrefix *string

+ RoleArn *string

+ func (s CustomerManagedDatastoreS3StorageSummary) MarshalFields(e protocol.FieldEncoder) error

+ func (s CustomerManagedDatastoreS3StorageSummary) String() string

type Datastore

+ Storage *DatastoreStorage

+ type DatastoreStorage struct

+ CustomerManagedS3 *CustomerManagedDatastoreS3Storage

+ ServiceManagedS3 *ServiceManagedDatastoreS3Storage

+ func (s *DatastoreStorage) Validate() error

+ func (s DatastoreStorage) MarshalFields(e protocol.FieldEncoder) error

+ func (s DatastoreStorage) String() string

+ type DatastoreStorageSummary struct

+ CustomerManagedS3 *CustomerManagedDatastoreS3StorageSummary

+ ServiceManagedS3 *ServiceManagedDatastoreS3StorageSummary

+ func (s DatastoreStorageSummary) MarshalFields(e protocol.FieldEncoder) error

+ func (s DatastoreStorageSummary) String() string

type DatastoreSummary

+ DatastoreStorage *DatastoreStorageSummary

+ type ServiceManagedChannelS3Storage struct

+ func (s ServiceManagedChannelS3Storage) MarshalFields(e protocol.FieldEncoder) error

+ func (s ServiceManagedChannelS3Storage) String() string

+ type ServiceManagedChannelS3StorageSummary struct

+ func (s ServiceManagedChannelS3StorageSummary) MarshalFields(e protocol.FieldEncoder) error

+ func (s ServiceManagedChannelS3StorageSummary) String() string

+ type ServiceManagedDatastoreS3Storage struct

+ func (s ServiceManagedDatastoreS3Storage) MarshalFields(e protocol.FieldEncoder) error

+ func (s ServiceManagedDatastoreS3Storage) String() string

+ type ServiceManagedDatastoreS3StorageSummary struct

+ func (s ServiceManagedDatastoreS3StorageSummary) MarshalFields(e protocol.FieldEncoder) error

+ func (s ServiceManagedDatastoreS3StorageSummary) String() string

type UpdateChannelInput

+ ChannelStorage *ChannelStorage

type UpdateDatastoreInput

+ DatastoreStorage *DatastoreStorage

v0.9.0

May 28, 2019

Changes in this version

+ const ServiceID

+ type BatchPutMessageResponse struct

+ func (r *BatchPutMessageResponse) SDKResponseMetdata() *aws.Response

+ type CancelPipelineReprocessingResponse struct

+ func (r *CancelPipelineReprocessingResponse) SDKResponseMetdata() *aws.Response

+ type Client struct

+ func (c *Client) BatchPutMessageRequest(input *BatchPutMessageInput) BatchPutMessageRequest

+ func (c *Client) CancelPipelineReprocessingRequest(input *CancelPipelineReprocessingInput) CancelPipelineReprocessingRequest

+ func (c *Client) CreateChannelRequest(input *CreateChannelInput) CreateChannelRequest

+ func (c *Client) CreateDatasetContentRequest(input *CreateDatasetContentInput) CreateDatasetContentRequest

+ func (c *Client) CreateDatasetRequest(input *CreateDatasetInput) CreateDatasetRequest

+ func (c *Client) CreateDatastoreRequest(input *CreateDatastoreInput) CreateDatastoreRequest

+ func (c *Client) CreatePipelineRequest(input *CreatePipelineInput) CreatePipelineRequest

+ func (c *Client) DeleteChannelRequest(input *DeleteChannelInput) DeleteChannelRequest

+ func (c *Client) DeleteDatasetContentRequest(input *DeleteDatasetContentInput) DeleteDatasetContentRequest

+ func (c *Client) DeleteDatasetRequest(input *DeleteDatasetInput) DeleteDatasetRequest

+ func (c *Client) DeleteDatastoreRequest(input *DeleteDatastoreInput) DeleteDatastoreRequest

+ func (c *Client) DeletePipelineRequest(input *DeletePipelineInput) DeletePipelineRequest

+ func (c *Client) DescribeChannelRequest(input *DescribeChannelInput) DescribeChannelRequest

+ func (c *Client) DescribeDatasetRequest(input *DescribeDatasetInput) DescribeDatasetRequest

+ func (c *Client) DescribeDatastoreRequest(input *DescribeDatastoreInput) DescribeDatastoreRequest

+ func (c *Client) DescribeLoggingOptionsRequest(input *DescribeLoggingOptionsInput) DescribeLoggingOptionsRequest

+ func (c *Client) DescribePipelineRequest(input *DescribePipelineInput) DescribePipelineRequest

+ func (c *Client) GetDatasetContentRequest(input *GetDatasetContentInput) GetDatasetContentRequest

+ func (c *Client) ListChannelsRequest(input *ListChannelsInput) ListChannelsRequest

+ func (c *Client) ListDatasetContentsRequest(input *ListDatasetContentsInput) ListDatasetContentsRequest

+ func (c *Client) ListDatasetsRequest(input *ListDatasetsInput) ListDatasetsRequest

+ func (c *Client) ListDatastoresRequest(input *ListDatastoresInput) ListDatastoresRequest

+ func (c *Client) ListPipelinesRequest(input *ListPipelinesInput) ListPipelinesRequest

+ func (c *Client) ListTagsForResourceRequest(input *ListTagsForResourceInput) ListTagsForResourceRequest

+ func (c *Client) PutLoggingOptionsRequest(input *PutLoggingOptionsInput) PutLoggingOptionsRequest

+ func (c *Client) RunPipelineActivityRequest(input *RunPipelineActivityInput) RunPipelineActivityRequest

+ func (c *Client) SampleChannelDataRequest(input *SampleChannelDataInput) SampleChannelDataRequest

+ func (c *Client) StartPipelineReprocessingRequest(input *StartPipelineReprocessingInput) StartPipelineReprocessingRequest

+ func (c *Client) TagResourceRequest(input *TagResourceInput) TagResourceRequest

+ func (c *Client) UntagResourceRequest(input *UntagResourceInput) UntagResourceRequest

+ func (c *Client) UpdateChannelRequest(input *UpdateChannelInput) UpdateChannelRequest

+ func (c *Client) UpdateDatasetRequest(input *UpdateDatasetInput) UpdateDatasetRequest

+ func (c *Client) UpdateDatastoreRequest(input *UpdateDatastoreInput) UpdateDatastoreRequest

+ func (c *Client) UpdatePipelineRequest(input *UpdatePipelineInput) UpdatePipelineRequest

+ type CreateChannelResponse struct

+ func (r *CreateChannelResponse) SDKResponseMetdata() *aws.Response

+ type CreateDatasetContentResponse struct

+ func (r *CreateDatasetContentResponse) SDKResponseMetdata() *aws.Response

+ type CreateDatasetResponse struct

+ func (r *CreateDatasetResponse) SDKResponseMetdata() *aws.Response

+ type CreateDatastoreResponse struct

+ func (r *CreateDatastoreResponse) SDKResponseMetdata() *aws.Response

+ type CreatePipelineResponse struct

+ func (r *CreatePipelineResponse) SDKResponseMetdata() *aws.Response

type DatasetContentDeliveryDestination

+ S3DestinationConfiguration *S3DestinationConfiguration

+ type DeleteChannelResponse struct

+ func (r *DeleteChannelResponse) SDKResponseMetdata() *aws.Response

+ type DeleteDatasetContentResponse struct

+ func (r *DeleteDatasetContentResponse) SDKResponseMetdata() *aws.Response

+ type DeleteDatasetResponse struct

+ func (r *DeleteDatasetResponse) SDKResponseMetdata() *aws.Response

+ type DeleteDatastoreResponse struct

+ func (r *DeleteDatastoreResponse) SDKResponseMetdata() *aws.Response

+ type DeletePipelineResponse struct

+ func (r *DeletePipelineResponse) SDKResponseMetdata() *aws.Response

+ type DescribeChannelResponse struct

+ func (r *DescribeChannelResponse) SDKResponseMetdata() *aws.Response

+ type DescribeDatasetResponse struct

+ func (r *DescribeDatasetResponse) SDKResponseMetdata() *aws.Response

+ type DescribeDatastoreResponse struct

+ func (r *DescribeDatastoreResponse) SDKResponseMetdata() *aws.Response

+ type DescribeLoggingOptionsResponse struct

+ func (r *DescribeLoggingOptionsResponse) SDKResponseMetdata() *aws.Response

+ type DescribePipelineResponse struct

+ func (r *DescribePipelineResponse) SDKResponseMetdata() *aws.Response

+ type GetDatasetContentResponse struct

+ func (r *GetDatasetContentResponse) SDKResponseMetdata() *aws.Response

+ type GlueConfiguration struct

+ DatabaseName *string

+ TableName *string

+ func (s *GlueConfiguration) Validate() error

+ func (s GlueConfiguration) MarshalFields(e protocol.FieldEncoder) error

+ func (s GlueConfiguration) String() string

+ type ListChannelsPaginator struct

+ func NewListChannelsPaginator(req ListChannelsRequest) ListChannelsPaginator

+ func (p *ListChannelsPaginator) CurrentPage() *ListChannelsOutput

+ type ListChannelsResponse struct

+ func (r *ListChannelsResponse) SDKResponseMetdata() *aws.Response

+ type ListDatasetContentsPaginator struct

+ func NewListDatasetContentsPaginator(req ListDatasetContentsRequest) ListDatasetContentsPaginator

+ func (p *ListDatasetContentsPaginator) CurrentPage() *ListDatasetContentsOutput

+ type ListDatasetContentsResponse struct

+ func (r *ListDatasetContentsResponse) SDKResponseMetdata() *aws.Response

+ type ListDatasetsPaginator struct

+ func NewListDatasetsPaginator(req ListDatasetsRequest) ListDatasetsPaginator

+ func (p *ListDatasetsPaginator) CurrentPage() *ListDatasetsOutput

+ type ListDatasetsResponse struct

+ func (r *ListDatasetsResponse) SDKResponseMetdata() *aws.Response

+ type ListDatastoresPaginator struct

+ func NewListDatastoresPaginator(req ListDatastoresRequest) ListDatastoresPaginator

+ func (p *ListDatastoresPaginator) CurrentPage() *ListDatastoresOutput

+ type ListDatastoresResponse struct

+ func (r *ListDatastoresResponse) SDKResponseMetdata() *aws.Response

+ type ListPipelinesPaginator struct

+ func NewListPipelinesPaginator(req ListPipelinesRequest) ListPipelinesPaginator

+ func (p *ListPipelinesPaginator) CurrentPage() *ListPipelinesOutput

+ type ListPipelinesResponse struct

+ func (r *ListPipelinesResponse) SDKResponseMetdata() *aws.Response

+ type ListTagsForResourceResponse struct

+ func (r *ListTagsForResourceResponse) SDKResponseMetdata() *aws.Response

+ type PutLoggingOptionsResponse struct

+ func (r *PutLoggingOptionsResponse) SDKResponseMetdata() *aws.Response

+ type RunPipelineActivityResponse struct

+ func (r *RunPipelineActivityResponse) SDKResponseMetdata() *aws.Response

+ type S3DestinationConfiguration struct

+ Bucket *string

+ GlueConfiguration *GlueConfiguration

+ Key *string

+ RoleArn *string

+ func (s *S3DestinationConfiguration) Validate() error

+ func (s S3DestinationConfiguration) MarshalFields(e protocol.FieldEncoder) error

+ func (s S3DestinationConfiguration) String() string

+ type SampleChannelDataResponse struct

+ func (r *SampleChannelDataResponse) SDKResponseMetdata() *aws.Response

+ type StartPipelineReprocessingResponse struct

+ func (r *StartPipelineReprocessingResponse) SDKResponseMetdata() *aws.Response

+ type TagResourceResponse struct

+ func (r *TagResourceResponse) SDKResponseMetdata() *aws.Response

+ type UntagResourceResponse struct

+ func (r *UntagResourceResponse) SDKResponseMetdata() *aws.Response

+ type UpdateChannelResponse struct

+ func (r *UpdateChannelResponse) SDKResponseMetdata() *aws.Response

+ type UpdateDatasetResponse struct

+ func (r *UpdateDatasetResponse) SDKResponseMetdata() *aws.Response

+ type UpdateDatastoreResponse struct

+ func (r *UpdateDatastoreResponse) SDKResponseMetdata() *aws.Response

+ type UpdatePipelineResponse struct

+ func (r *UpdatePipelineResponse) SDKResponseMetdata() *aws.Response

v0.8.0

Apr 25, 2019

Changes in this version

type CreateDatasetInput

+ VersioningConfiguration *VersioningConfiguration

type Dataset

+ VersioningConfiguration *VersioningConfiguration

type ListDatasetContentsInput

+ ScheduledBefore *time.Time

+ ScheduledOnOrAfter *time.Time

type UpdateDatasetInput

+ VersioningConfiguration *VersioningConfiguration

+ type VersioningConfiguration struct

+ MaxVersions *int64

+ Unlimited *bool

+ func (s *VersioningConfiguration) Validate() error

+ func (s VersioningConfiguration) GoString() string

+ func (s VersioningConfiguration) MarshalFields(e protocol.FieldEncoder) error

+ func (s VersioningConfiguration) String() string

v0.7.0

Jan 3, 2019

v0.6.0

Dec 3, 2018

Changes in this version

type CreateDatasetInput

+ ContentDeliveryRules []DatasetContentDeliveryRule

type Dataset

+ ContentDeliveryRules []DatasetContentDeliveryRule

+ type DatasetContentDeliveryDestination struct

+ IotEventsDestinationConfiguration *IotEventsDestinationConfiguration

+ func (s *DatasetContentDeliveryDestination) Validate() error

+ func (s DatasetContentDeliveryDestination) GoString() string

+ func (s DatasetContentDeliveryDestination) MarshalFields(e protocol.FieldEncoder) error

+ func (s DatasetContentDeliveryDestination) String() string

+ type DatasetContentDeliveryRule struct

+ Destination *DatasetContentDeliveryDestination

+ EntryName *string

+ func (s *DatasetContentDeliveryRule) Validate() error

+ func (s DatasetContentDeliveryRule) GoString() string

+ func (s DatasetContentDeliveryRule) MarshalFields(e protocol.FieldEncoder) error

+ func (s DatasetContentDeliveryRule) String() string

+ type IotEventsDestinationConfiguration struct

+ InputName *string

+ RoleArn *string

+ func (s *IotEventsDestinationConfiguration) Validate() error

+ func (s IotEventsDestinationConfiguration) GoString() string

+ func (s IotEventsDestinationConfiguration) MarshalFields(e protocol.FieldEncoder) error

+ func (s IotEventsDestinationConfiguration) String() string

type UpdateDatasetInput

+ ContentDeliveryRules []DatasetContentDeliveryRule

v0.5.0

Sep 27, 2018

Changes in this version

+ type ChannelStatistics struct

+ Size *EstimatedResourceSize

+ func (s ChannelStatistics) GoString() string

+ func (s ChannelStatistics) MarshalFields(e protocol.FieldEncoder) error

+ func (s ChannelStatistics) String() string

+ type ComputeType string

+ const ComputeTypeAcu1

+ const ComputeTypeAcu2

+ func (enum ComputeType) MarshalValue() (string, error)

+ func (enum ComputeType) MarshalValueBuf(b []byte) ([]byte, error)

+ type ContainerDatasetAction struct

+ ExecutionRoleArn *string

+ Image *string

+ ResourceConfiguration *ResourceConfiguration

+ Variables []Variable

+ func (s *ContainerDatasetAction) Validate() error

+ func (s ContainerDatasetAction) GoString() string

+ func (s ContainerDatasetAction) MarshalFields(e protocol.FieldEncoder) error

+ func (s ContainerDatasetAction) String() string

type CreateChannelInput

+ Tags []Tag

type CreateDatasetContentOutput

+ VersionId *string

type CreateDatasetInput

+ RetentionPeriod *RetentionPeriod

+ Tags []Tag

type CreateDatasetOutput

+ RetentionPeriod *RetentionPeriod

type CreateDatastoreInput

+ Tags []Tag

type CreatePipelineInput

+ Tags []Tag

type Dataset

+ RetentionPeriod *RetentionPeriod

type DatasetAction

+ ContainerAction *ContainerDatasetAction

+ type DatasetActionSummary struct

+ ActionName *string

+ ActionType DatasetActionType

+ func (s DatasetActionSummary) GoString() string

+ func (s DatasetActionSummary) MarshalFields(e protocol.FieldEncoder) error

+ func (s DatasetActionSummary) String() string

+ type DatasetActionType string

+ const DatasetActionTypeContainer

+ const DatasetActionTypeQuery

+ func (enum DatasetActionType) MarshalValue() (string, error)

+ func (enum DatasetActionType) MarshalValueBuf(b []byte) ([]byte, error)

+ type DatasetContentSummary struct

+ CreationTime *time.Time

+ ScheduleTime *time.Time

+ Status *DatasetContentStatus

+ Version *string

+ func (s DatasetContentSummary) GoString() string

+ func (s DatasetContentSummary) MarshalFields(e protocol.FieldEncoder) error

+ func (s DatasetContentSummary) String() string

+ type DatasetContentVersionValue struct

+ DatasetName *string

+ func (s *DatasetContentVersionValue) Validate() error

+ func (s DatasetContentVersionValue) GoString() string

+ func (s DatasetContentVersionValue) MarshalFields(e protocol.FieldEncoder) error

+ func (s DatasetContentVersionValue) String() string

type DatasetSummary

+ Actions []DatasetActionSummary

+ Triggers []DatasetTrigger

type DatasetTrigger

+ Dataset *TriggeringDataset

+ func (s *DatasetTrigger) Validate() error

+ type DatastoreStatistics struct

+ Size *EstimatedResourceSize

+ func (s DatastoreStatistics) GoString() string

+ func (s DatastoreStatistics) MarshalFields(e protocol.FieldEncoder) error

+ func (s DatastoreStatistics) String() string

+ type DeltaTime struct

+ OffsetSeconds *int64

+ TimeExpression *string

+ func (s *DeltaTime) Validate() error

+ func (s DeltaTime) GoString() string

+ func (s DeltaTime) MarshalFields(e protocol.FieldEncoder) error

+ func (s DeltaTime) String() string

type DescribeChannelInput

+ IncludeStatistics *bool

type DescribeChannelOutput

+ Statistics *ChannelStatistics

type DescribeDatastoreInput

+ IncludeStatistics *bool

type DescribeDatastoreOutput

+ Statistics *DatastoreStatistics

+ type EstimatedResourceSize struct

+ EstimatedOn *time.Time

+ EstimatedSizeInBytes *float64

+ func (s EstimatedResourceSize) GoString() string

+ func (s EstimatedResourceSize) MarshalFields(e protocol.FieldEncoder) error

+ func (s EstimatedResourceSize) String() string

type IoTAnalytics

+ func (c *IoTAnalytics) ListDatasetContentsRequest(input *ListDatasetContentsInput) ListDatasetContentsRequest

+ func (c *IoTAnalytics) ListTagsForResourceRequest(input *ListTagsForResourceInput) ListTagsForResourceRequest

+ func (c *IoTAnalytics) TagResourceRequest(input *TagResourceInput) TagResourceRequest

+ func (c *IoTAnalytics) UntagResourceRequest(input *UntagResourceInput) UntagResourceRequest

+ type ListDatasetContentsInput struct

+ DatasetName *string

+ MaxResults *int64

+ NextToken *string

+ func (s *ListDatasetContentsInput) Validate() error

+ func (s ListDatasetContentsInput) GoString() string

+ func (s ListDatasetContentsInput) MarshalFields(e protocol.FieldEncoder) error

+ func (s ListDatasetContentsInput) String() string

+ type ListDatasetContentsOutput struct

+ DatasetContentSummaries []DatasetContentSummary

+ NextToken *string

+ func (s ListDatasetContentsOutput) GoString() string

+ func (s ListDatasetContentsOutput) MarshalFields(e protocol.FieldEncoder) error

+ func (s ListDatasetContentsOutput) SDKResponseMetadata() aws.Response

+ func (s ListDatasetContentsOutput) String() string

+ type ListDatasetContentsPager struct

+ func (p *ListDatasetContentsPager) CurrentPage() *ListDatasetContentsOutput

+ type ListDatasetContentsRequest struct

+ Copy func(*ListDatasetContentsInput) ListDatasetContentsRequest

+ Input *ListDatasetContentsInput

+ func (p *ListDatasetContentsRequest) Paginate(opts ...aws.Option) ListDatasetContentsPager

+ func (r ListDatasetContentsRequest) Send() (*ListDatasetContentsOutput, error)

+ type ListTagsForResourceInput struct

+ ResourceArn *string

+ func (s *ListTagsForResourceInput) Validate() error

+ func (s ListTagsForResourceInput) GoString() string

+ func (s ListTagsForResourceInput) MarshalFields(e protocol.FieldEncoder) error

+ func (s ListTagsForResourceInput) String() string

+ type ListTagsForResourceOutput struct

+ Tags []Tag

+ func (s ListTagsForResourceOutput) GoString() string

+ func (s ListTagsForResourceOutput) MarshalFields(e protocol.FieldEncoder) error

+ func (s ListTagsForResourceOutput) SDKResponseMetadata() aws.Response

+ func (s ListTagsForResourceOutput) String() string

+ type ListTagsForResourceRequest struct

+ Copy func(*ListTagsForResourceInput) ListTagsForResourceRequest

+ Input *ListTagsForResourceInput

+ func (r ListTagsForResourceRequest) Send() (*ListTagsForResourceOutput, error)

+ type OutputFileUriValue struct

+ FileName *string

+ func (s *OutputFileUriValue) Validate() error

+ func (s OutputFileUriValue) GoString() string

+ func (s OutputFileUriValue) MarshalFields(e protocol.FieldEncoder) error

+ func (s OutputFileUriValue) String() string

+ type QueryFilter struct

+ DeltaTime *DeltaTime

+ func (s *QueryFilter) Validate() error

+ func (s QueryFilter) GoString() string

+ func (s QueryFilter) MarshalFields(e protocol.FieldEncoder) error

+ func (s QueryFilter) String() string

+ type ResourceConfiguration struct

+ ComputeType ComputeType

+ VolumeSizeInGB *int64

+ func (s *ResourceConfiguration) Validate() error

+ func (s ResourceConfiguration) GoString() string

+ func (s ResourceConfiguration) MarshalFields(e protocol.FieldEncoder) error

+ func (s ResourceConfiguration) String() string

type SqlQueryDatasetAction

+ Filters []QueryFilter

+ type Tag struct

+ Key *string

+ Value *string

+ func (s *Tag) Validate() error

+ func (s Tag) GoString() string

+ func (s Tag) MarshalFields(e protocol.FieldEncoder) error

+ func (s Tag) String() string

+ type TagResourceInput struct

+ ResourceArn *string

+ Tags []Tag

+ func (s *TagResourceInput) Validate() error

+ func (s TagResourceInput) GoString() string

+ func (s TagResourceInput) MarshalFields(e protocol.FieldEncoder) error

+ func (s TagResourceInput) String() string

+ type TagResourceOutput struct

+ func (s TagResourceOutput) GoString() string

+ func (s TagResourceOutput) MarshalFields(e protocol.FieldEncoder) error

+ func (s TagResourceOutput) SDKResponseMetadata() aws.Response

+ func (s TagResourceOutput) String() string

+ type TagResourceRequest struct

+ Copy func(*TagResourceInput) TagResourceRequest

+ Input *TagResourceInput

+ func (r TagResourceRequest) Send() (*TagResourceOutput, error)

+ type TriggeringDataset struct

+ Name *string

+ func (s *TriggeringDataset) Validate() error

+ func (s TriggeringDataset) GoString() string

+ func (s TriggeringDataset) MarshalFields(e protocol.FieldEncoder) error

+ func (s TriggeringDataset) String() string

+ type UntagResourceInput struct

+ ResourceArn *string

+ TagKeys []string

+ func (s *UntagResourceInput) Validate() error

+ func (s UntagResourceInput) GoString() string

+ func (s UntagResourceInput) MarshalFields(e protocol.FieldEncoder) error

+ func (s UntagResourceInput) String() string

+ type UntagResourceOutput struct

+ func (s UntagResourceOutput) GoString() string

+ func (s UntagResourceOutput) MarshalFields(e protocol.FieldEncoder) error

+ func (s UntagResourceOutput) SDKResponseMetadata() aws.Response

+ func (s UntagResourceOutput) String() string

+ type UntagResourceRequest struct

+ Copy func(*UntagResourceInput) UntagResourceRequest

+ Input *UntagResourceInput

+ func (r UntagResourceRequest) Send() (*UntagResourceOutput, error)

type UpdateDatasetInput

+ RetentionPeriod *RetentionPeriod

+ type Variable struct

+ DatasetContentVersionValue *DatasetContentVersionValue

+ DoubleValue *float64

+ Name *string

+ OutputFileUriValue *OutputFileUriValue

+ StringValue *string

+ func (s *Variable) Validate() error

+ func (s Variable) GoString() string

+ func (s Variable) MarshalFields(e protocol.FieldEncoder) error

+ func (s Variable) String() string

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)

Incompatible versions in this module

v2.0.0-preview.4+incompatible

May 26, 2018

Other modules containing this package

github.com/aws/aws-sdk-go-v2/service/iotanalytics

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