Documentation ¶
Index ¶
- type BatchPutMessageFuture
- type CancelPipelineReprocessingFuture
- type Client
- type CreateChannelFuture
- type CreateDatasetContentFuture
- type CreateDatasetFuture
- type CreateDatastoreFuture
- type CreatePipelineFuture
- type DeleteChannelFuture
- type DeleteDatasetContentFuture
- type DeleteDatasetFuture
- type DeleteDatastoreFuture
- type DeletePipelineFuture
- type DescribeChannelFuture
- type DescribeDatasetFuture
- type DescribeDatastoreFuture
- type DescribeLoggingOptionsFuture
- type DescribePipelineFuture
- type GetDatasetContentFuture
- type ListChannelsFuture
- type ListDatasetContentsFuture
- type ListDatasetsFuture
- type ListDatastoresFuture
- type ListPipelinesFuture
- type ListTagsForResourceFuture
- type PutLoggingOptionsFuture
- type RunPipelineActivityFuture
- type SampleChannelDataFuture
- type StartPipelineReprocessingFuture
- type TagResourceFuture
- type UntagResourceFuture
- type UpdateChannelFuture
- type UpdateDatasetFuture
- type UpdateDatastoreFuture
- type UpdatePipelineFuture
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchPutMessageFuture ¶
type BatchPutMessageFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*BatchPutMessageFuture) Get ¶
func (r *BatchPutMessageFuture) Get(ctx workflow.Context) (*iotanalytics.BatchPutMessageOutput, error)
type CancelPipelineReprocessingFuture ¶
type CancelPipelineReprocessingFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*CancelPipelineReprocessingFuture) Get ¶
func (r *CancelPipelineReprocessingFuture) Get(ctx workflow.Context) (*iotanalytics.CancelPipelineReprocessingOutput, error)
type Client ¶
type Client interface { BatchPutMessage(ctx workflow.Context, input *iotanalytics.BatchPutMessageInput) (*iotanalytics.BatchPutMessageOutput, error) BatchPutMessageAsync(ctx workflow.Context, input *iotanalytics.BatchPutMessageInput) *BatchPutMessageFuture CancelPipelineReprocessing(ctx workflow.Context, input *iotanalytics.CancelPipelineReprocessingInput) (*iotanalytics.CancelPipelineReprocessingOutput, error) CancelPipelineReprocessingAsync(ctx workflow.Context, input *iotanalytics.CancelPipelineReprocessingInput) *CancelPipelineReprocessingFuture CreateChannel(ctx workflow.Context, input *iotanalytics.CreateChannelInput) (*iotanalytics.CreateChannelOutput, error) CreateChannelAsync(ctx workflow.Context, input *iotanalytics.CreateChannelInput) *CreateChannelFuture CreateDataset(ctx workflow.Context, input *iotanalytics.CreateDatasetInput) (*iotanalytics.CreateDatasetOutput, error) CreateDatasetAsync(ctx workflow.Context, input *iotanalytics.CreateDatasetInput) *CreateDatasetFuture CreateDatasetContent(ctx workflow.Context, input *iotanalytics.CreateDatasetContentInput) (*iotanalytics.CreateDatasetContentOutput, error) CreateDatasetContentAsync(ctx workflow.Context, input *iotanalytics.CreateDatasetContentInput) *CreateDatasetContentFuture CreateDatastore(ctx workflow.Context, input *iotanalytics.CreateDatastoreInput) (*iotanalytics.CreateDatastoreOutput, error) CreateDatastoreAsync(ctx workflow.Context, input *iotanalytics.CreateDatastoreInput) *CreateDatastoreFuture CreatePipeline(ctx workflow.Context, input *iotanalytics.CreatePipelineInput) (*iotanalytics.CreatePipelineOutput, error) CreatePipelineAsync(ctx workflow.Context, input *iotanalytics.CreatePipelineInput) *CreatePipelineFuture DeleteChannel(ctx workflow.Context, input *iotanalytics.DeleteChannelInput) (*iotanalytics.DeleteChannelOutput, error) DeleteChannelAsync(ctx workflow.Context, input *iotanalytics.DeleteChannelInput) *DeleteChannelFuture DeleteDataset(ctx workflow.Context, input *iotanalytics.DeleteDatasetInput) (*iotanalytics.DeleteDatasetOutput, error) DeleteDatasetAsync(ctx workflow.Context, input *iotanalytics.DeleteDatasetInput) *DeleteDatasetFuture DeleteDatasetContent(ctx workflow.Context, input *iotanalytics.DeleteDatasetContentInput) (*iotanalytics.DeleteDatasetContentOutput, error) DeleteDatasetContentAsync(ctx workflow.Context, input *iotanalytics.DeleteDatasetContentInput) *DeleteDatasetContentFuture DeleteDatastore(ctx workflow.Context, input *iotanalytics.DeleteDatastoreInput) (*iotanalytics.DeleteDatastoreOutput, error) DeleteDatastoreAsync(ctx workflow.Context, input *iotanalytics.DeleteDatastoreInput) *DeleteDatastoreFuture DeletePipeline(ctx workflow.Context, input *iotanalytics.DeletePipelineInput) (*iotanalytics.DeletePipelineOutput, error) DeletePipelineAsync(ctx workflow.Context, input *iotanalytics.DeletePipelineInput) *DeletePipelineFuture DescribeChannel(ctx workflow.Context, input *iotanalytics.DescribeChannelInput) (*iotanalytics.DescribeChannelOutput, error) DescribeChannelAsync(ctx workflow.Context, input *iotanalytics.DescribeChannelInput) *DescribeChannelFuture DescribeDataset(ctx workflow.Context, input *iotanalytics.DescribeDatasetInput) (*iotanalytics.DescribeDatasetOutput, error) DescribeDatasetAsync(ctx workflow.Context, input *iotanalytics.DescribeDatasetInput) *DescribeDatasetFuture DescribeDatastore(ctx workflow.Context, input *iotanalytics.DescribeDatastoreInput) (*iotanalytics.DescribeDatastoreOutput, error) DescribeDatastoreAsync(ctx workflow.Context, input *iotanalytics.DescribeDatastoreInput) *DescribeDatastoreFuture DescribeLoggingOptions(ctx workflow.Context, input *iotanalytics.DescribeLoggingOptionsInput) (*iotanalytics.DescribeLoggingOptionsOutput, error) DescribeLoggingOptionsAsync(ctx workflow.Context, input *iotanalytics.DescribeLoggingOptionsInput) *DescribeLoggingOptionsFuture DescribePipeline(ctx workflow.Context, input *iotanalytics.DescribePipelineInput) (*iotanalytics.DescribePipelineOutput, error) DescribePipelineAsync(ctx workflow.Context, input *iotanalytics.DescribePipelineInput) *DescribePipelineFuture GetDatasetContent(ctx workflow.Context, input *iotanalytics.GetDatasetContentInput) (*iotanalytics.GetDatasetContentOutput, error) GetDatasetContentAsync(ctx workflow.Context, input *iotanalytics.GetDatasetContentInput) *GetDatasetContentFuture ListChannels(ctx workflow.Context, input *iotanalytics.ListChannelsInput) (*iotanalytics.ListChannelsOutput, error) ListChannelsAsync(ctx workflow.Context, input *iotanalytics.ListChannelsInput) *ListChannelsFuture ListDatasetContents(ctx workflow.Context, input *iotanalytics.ListDatasetContentsInput) (*iotanalytics.ListDatasetContentsOutput, error) ListDatasetContentsAsync(ctx workflow.Context, input *iotanalytics.ListDatasetContentsInput) *ListDatasetContentsFuture ListDatasets(ctx workflow.Context, input *iotanalytics.ListDatasetsInput) (*iotanalytics.ListDatasetsOutput, error) ListDatasetsAsync(ctx workflow.Context, input *iotanalytics.ListDatasetsInput) *ListDatasetsFuture ListDatastores(ctx workflow.Context, input *iotanalytics.ListDatastoresInput) (*iotanalytics.ListDatastoresOutput, error) ListDatastoresAsync(ctx workflow.Context, input *iotanalytics.ListDatastoresInput) *ListDatastoresFuture ListPipelines(ctx workflow.Context, input *iotanalytics.ListPipelinesInput) (*iotanalytics.ListPipelinesOutput, error) ListPipelinesAsync(ctx workflow.Context, input *iotanalytics.ListPipelinesInput) *ListPipelinesFuture ListTagsForResource(ctx workflow.Context, input *iotanalytics.ListTagsForResourceInput) (*iotanalytics.ListTagsForResourceOutput, error) ListTagsForResourceAsync(ctx workflow.Context, input *iotanalytics.ListTagsForResourceInput) *ListTagsForResourceFuture PutLoggingOptions(ctx workflow.Context, input *iotanalytics.PutLoggingOptionsInput) (*iotanalytics.PutLoggingOptionsOutput, error) PutLoggingOptionsAsync(ctx workflow.Context, input *iotanalytics.PutLoggingOptionsInput) *PutLoggingOptionsFuture RunPipelineActivity(ctx workflow.Context, input *iotanalytics.RunPipelineActivityInput) (*iotanalytics.RunPipelineActivityOutput, error) RunPipelineActivityAsync(ctx workflow.Context, input *iotanalytics.RunPipelineActivityInput) *RunPipelineActivityFuture SampleChannelData(ctx workflow.Context, input *iotanalytics.SampleChannelDataInput) (*iotanalytics.SampleChannelDataOutput, error) SampleChannelDataAsync(ctx workflow.Context, input *iotanalytics.SampleChannelDataInput) *SampleChannelDataFuture StartPipelineReprocessing(ctx workflow.Context, input *iotanalytics.StartPipelineReprocessingInput) (*iotanalytics.StartPipelineReprocessingOutput, error) StartPipelineReprocessingAsync(ctx workflow.Context, input *iotanalytics.StartPipelineReprocessingInput) *StartPipelineReprocessingFuture TagResource(ctx workflow.Context, input *iotanalytics.TagResourceInput) (*iotanalytics.TagResourceOutput, error) TagResourceAsync(ctx workflow.Context, input *iotanalytics.TagResourceInput) *TagResourceFuture UntagResource(ctx workflow.Context, input *iotanalytics.UntagResourceInput) (*iotanalytics.UntagResourceOutput, error) UntagResourceAsync(ctx workflow.Context, input *iotanalytics.UntagResourceInput) *UntagResourceFuture UpdateChannel(ctx workflow.Context, input *iotanalytics.UpdateChannelInput) (*iotanalytics.UpdateChannelOutput, error) UpdateChannelAsync(ctx workflow.Context, input *iotanalytics.UpdateChannelInput) *UpdateChannelFuture UpdateDataset(ctx workflow.Context, input *iotanalytics.UpdateDatasetInput) (*iotanalytics.UpdateDatasetOutput, error) UpdateDatasetAsync(ctx workflow.Context, input *iotanalytics.UpdateDatasetInput) *UpdateDatasetFuture UpdateDatastore(ctx workflow.Context, input *iotanalytics.UpdateDatastoreInput) (*iotanalytics.UpdateDatastoreOutput, error) UpdateDatastoreAsync(ctx workflow.Context, input *iotanalytics.UpdateDatastoreInput) *UpdateDatastoreFuture UpdatePipeline(ctx workflow.Context, input *iotanalytics.UpdatePipelineInput) (*iotanalytics.UpdatePipelineOutput, error) UpdatePipelineAsync(ctx workflow.Context, input *iotanalytics.UpdatePipelineInput) *UpdatePipelineFuture }
type CreateChannelFuture ¶
func (*CreateChannelFuture) Get ¶
func (r *CreateChannelFuture) Get(ctx workflow.Context) (*iotanalytics.CreateChannelOutput, error)
type CreateDatasetContentFuture ¶
type CreateDatasetContentFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*CreateDatasetContentFuture) Get ¶
func (r *CreateDatasetContentFuture) Get(ctx workflow.Context) (*iotanalytics.CreateDatasetContentOutput, error)
type CreateDatasetFuture ¶
func (*CreateDatasetFuture) Get ¶
func (r *CreateDatasetFuture) Get(ctx workflow.Context) (*iotanalytics.CreateDatasetOutput, error)
type CreateDatastoreFuture ¶
type CreateDatastoreFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*CreateDatastoreFuture) Get ¶
func (r *CreateDatastoreFuture) Get(ctx workflow.Context) (*iotanalytics.CreateDatastoreOutput, error)
type CreatePipelineFuture ¶
func (*CreatePipelineFuture) Get ¶
func (r *CreatePipelineFuture) Get(ctx workflow.Context) (*iotanalytics.CreatePipelineOutput, error)
type DeleteChannelFuture ¶
func (*DeleteChannelFuture) Get ¶
func (r *DeleteChannelFuture) Get(ctx workflow.Context) (*iotanalytics.DeleteChannelOutput, error)
type DeleteDatasetContentFuture ¶
type DeleteDatasetContentFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*DeleteDatasetContentFuture) Get ¶
func (r *DeleteDatasetContentFuture) Get(ctx workflow.Context) (*iotanalytics.DeleteDatasetContentOutput, error)
type DeleteDatasetFuture ¶
func (*DeleteDatasetFuture) Get ¶
func (r *DeleteDatasetFuture) Get(ctx workflow.Context) (*iotanalytics.DeleteDatasetOutput, error)
type DeleteDatastoreFuture ¶
type DeleteDatastoreFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*DeleteDatastoreFuture) Get ¶
func (r *DeleteDatastoreFuture) Get(ctx workflow.Context) (*iotanalytics.DeleteDatastoreOutput, error)
type DeletePipelineFuture ¶
func (*DeletePipelineFuture) Get ¶
func (r *DeletePipelineFuture) Get(ctx workflow.Context) (*iotanalytics.DeletePipelineOutput, error)
type DescribeChannelFuture ¶
type DescribeChannelFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*DescribeChannelFuture) Get ¶
func (r *DescribeChannelFuture) Get(ctx workflow.Context) (*iotanalytics.DescribeChannelOutput, error)
type DescribeDatasetFuture ¶
type DescribeDatasetFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*DescribeDatasetFuture) Get ¶
func (r *DescribeDatasetFuture) Get(ctx workflow.Context) (*iotanalytics.DescribeDatasetOutput, error)
type DescribeDatastoreFuture ¶
type DescribeDatastoreFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*DescribeDatastoreFuture) Get ¶
func (r *DescribeDatastoreFuture) Get(ctx workflow.Context) (*iotanalytics.DescribeDatastoreOutput, error)
type DescribeLoggingOptionsFuture ¶
type DescribeLoggingOptionsFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*DescribeLoggingOptionsFuture) Get ¶
func (r *DescribeLoggingOptionsFuture) Get(ctx workflow.Context) (*iotanalytics.DescribeLoggingOptionsOutput, error)
type DescribePipelineFuture ¶
type DescribePipelineFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*DescribePipelineFuture) Get ¶
func (r *DescribePipelineFuture) Get(ctx workflow.Context) (*iotanalytics.DescribePipelineOutput, error)
type GetDatasetContentFuture ¶
type GetDatasetContentFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*GetDatasetContentFuture) Get ¶
func (r *GetDatasetContentFuture) Get(ctx workflow.Context) (*iotanalytics.GetDatasetContentOutput, error)
type ListChannelsFuture ¶
func (*ListChannelsFuture) Get ¶
func (r *ListChannelsFuture) Get(ctx workflow.Context) (*iotanalytics.ListChannelsOutput, error)
type ListDatasetContentsFuture ¶
type ListDatasetContentsFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*ListDatasetContentsFuture) Get ¶
func (r *ListDatasetContentsFuture) Get(ctx workflow.Context) (*iotanalytics.ListDatasetContentsOutput, error)
type ListDatasetsFuture ¶
func (*ListDatasetsFuture) Get ¶
func (r *ListDatasetsFuture) Get(ctx workflow.Context) (*iotanalytics.ListDatasetsOutput, error)
type ListDatastoresFuture ¶
func (*ListDatastoresFuture) Get ¶
func (r *ListDatastoresFuture) Get(ctx workflow.Context) (*iotanalytics.ListDatastoresOutput, error)
type ListPipelinesFuture ¶
func (*ListPipelinesFuture) Get ¶
func (r *ListPipelinesFuture) Get(ctx workflow.Context) (*iotanalytics.ListPipelinesOutput, error)
type ListTagsForResourceFuture ¶
type ListTagsForResourceFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*ListTagsForResourceFuture) Get ¶
func (r *ListTagsForResourceFuture) Get(ctx workflow.Context) (*iotanalytics.ListTagsForResourceOutput, error)
type PutLoggingOptionsFuture ¶
type PutLoggingOptionsFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*PutLoggingOptionsFuture) Get ¶
func (r *PutLoggingOptionsFuture) Get(ctx workflow.Context) (*iotanalytics.PutLoggingOptionsOutput, error)
type RunPipelineActivityFuture ¶
type RunPipelineActivityFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*RunPipelineActivityFuture) Get ¶
func (r *RunPipelineActivityFuture) Get(ctx workflow.Context) (*iotanalytics.RunPipelineActivityOutput, error)
type SampleChannelDataFuture ¶
type SampleChannelDataFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*SampleChannelDataFuture) Get ¶
func (r *SampleChannelDataFuture) Get(ctx workflow.Context) (*iotanalytics.SampleChannelDataOutput, error)
type StartPipelineReprocessingFuture ¶
type StartPipelineReprocessingFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*StartPipelineReprocessingFuture) Get ¶
func (r *StartPipelineReprocessingFuture) Get(ctx workflow.Context) (*iotanalytics.StartPipelineReprocessingOutput, error)
type TagResourceFuture ¶
func (*TagResourceFuture) Get ¶
func (r *TagResourceFuture) Get(ctx workflow.Context) (*iotanalytics.TagResourceOutput, error)
type UntagResourceFuture ¶
func (*UntagResourceFuture) Get ¶
func (r *UntagResourceFuture) Get(ctx workflow.Context) (*iotanalytics.UntagResourceOutput, error)
type UpdateChannelFuture ¶
func (*UpdateChannelFuture) Get ¶
func (r *UpdateChannelFuture) Get(ctx workflow.Context) (*iotanalytics.UpdateChannelOutput, error)
type UpdateDatasetFuture ¶
func (*UpdateDatasetFuture) Get ¶
func (r *UpdateDatasetFuture) Get(ctx workflow.Context) (*iotanalytics.UpdateDatasetOutput, error)
type UpdateDatastoreFuture ¶
type UpdateDatastoreFuture struct { // public to support Selector.addFuture Future workflow.Future }
func (*UpdateDatastoreFuture) Get ¶
func (r *UpdateDatastoreFuture) Get(ctx workflow.Context) (*iotanalytics.UpdateDatastoreOutput, error)
type UpdatePipelineFuture ¶
func (*UpdatePipelineFuture) Get ¶
func (r *UpdatePipelineFuture) Get(ctx workflow.Context) (*iotanalytics.UpdatePipelineOutput, error)
Click to show internal directories.
Click to hide internal directories.