kinesisanalyticsv2

Documentation

Index

• type Activities
  • func NewActivities(sess *session.Session, config ...*aws.Config) *Activities
  • func NewActivitiesWithSessionFactory(sessionFactory SessionFactory) *Activities
  • func (a *Activities) AddApplicationCloudWatchLoggingOption(ctx context.Context, ...) (*kinesisanalyticsv2.AddApplicationCloudWatchLoggingOptionOutput, error)
  • func (a *Activities) AddApplicationInput(ctx context.Context, input *kinesisanalyticsv2.AddApplicationInputInput) (*kinesisanalyticsv2.AddApplicationInputOutput, error)
  • func (a *Activities) AddApplicationInputProcessingConfiguration(ctx context.Context, ...) (*kinesisanalyticsv2.AddApplicationInputProcessingConfigurationOutput, error)
  • func (a *Activities) AddApplicationOutput(ctx context.Context, input *kinesisanalyticsv2.AddApplicationOutputInput) (*kinesisanalyticsv2.AddApplicationOutputOutput, error)
  • func (a *Activities) AddApplicationReferenceDataSource(ctx context.Context, ...) (*kinesisanalyticsv2.AddApplicationReferenceDataSourceOutput, error)
  • func (a *Activities) AddApplicationVpcConfiguration(ctx context.Context, ...) (*kinesisanalyticsv2.AddApplicationVpcConfigurationOutput, error)
  • func (a *Activities) CreateApplication(ctx context.Context, input *kinesisanalyticsv2.CreateApplicationInput) (*kinesisanalyticsv2.CreateApplicationOutput, error)
  • func (a *Activities) CreateApplicationPresignedUrl(ctx context.Context, ...) (*kinesisanalyticsv2.CreateApplicationPresignedUrlOutput, error)
  • func (a *Activities) CreateApplicationSnapshot(ctx context.Context, input *kinesisanalyticsv2.CreateApplicationSnapshotInput) (*kinesisanalyticsv2.CreateApplicationSnapshotOutput, error)
  • func (a *Activities) DeleteApplication(ctx context.Context, input *kinesisanalyticsv2.DeleteApplicationInput) (*kinesisanalyticsv2.DeleteApplicationOutput, error)
  • func (a *Activities) DeleteApplicationCloudWatchLoggingOption(ctx context.Context, ...) (*kinesisanalyticsv2.DeleteApplicationCloudWatchLoggingOptionOutput, error)
  • func (a *Activities) DeleteApplicationInputProcessingConfiguration(ctx context.Context, ...) (*kinesisanalyticsv2.DeleteApplicationInputProcessingConfigurationOutput, error)
  • func (a *Activities) DeleteApplicationOutput(ctx context.Context, input *kinesisanalyticsv2.DeleteApplicationOutputInput) (*kinesisanalyticsv2.DeleteApplicationOutputOutput, error)
  • func (a *Activities) DeleteApplicationReferenceDataSource(ctx context.Context, ...) (*kinesisanalyticsv2.DeleteApplicationReferenceDataSourceOutput, error)
  • func (a *Activities) DeleteApplicationSnapshot(ctx context.Context, input *kinesisanalyticsv2.DeleteApplicationSnapshotInput) (*kinesisanalyticsv2.DeleteApplicationSnapshotOutput, error)
  • func (a *Activities) DeleteApplicationVpcConfiguration(ctx context.Context, ...) (*kinesisanalyticsv2.DeleteApplicationVpcConfigurationOutput, error)
  • func (a *Activities) DescribeApplication(ctx context.Context, input *kinesisanalyticsv2.DescribeApplicationInput) (*kinesisanalyticsv2.DescribeApplicationOutput, error)
  • func (a *Activities) DescribeApplicationSnapshot(ctx context.Context, ...) (*kinesisanalyticsv2.DescribeApplicationSnapshotOutput, error)
  • func (a *Activities) DiscoverInputSchema(ctx context.Context, input *kinesisanalyticsv2.DiscoverInputSchemaInput) (*kinesisanalyticsv2.DiscoverInputSchemaOutput, error)
  • func (a *Activities) ListApplicationSnapshots(ctx context.Context, input *kinesisanalyticsv2.ListApplicationSnapshotsInput) (*kinesisanalyticsv2.ListApplicationSnapshotsOutput, error)
  • func (a *Activities) ListApplications(ctx context.Context, input *kinesisanalyticsv2.ListApplicationsInput) (*kinesisanalyticsv2.ListApplicationsOutput, error)
  • func (a *Activities) ListTagsForResource(ctx context.Context, input *kinesisanalyticsv2.ListTagsForResourceInput) (*kinesisanalyticsv2.ListTagsForResourceOutput, error)
  • func (a *Activities) StartApplication(ctx context.Context, input *kinesisanalyticsv2.StartApplicationInput) (*kinesisanalyticsv2.StartApplicationOutput, error)
  • func (a *Activities) StopApplication(ctx context.Context, input *kinesisanalyticsv2.StopApplicationInput) (*kinesisanalyticsv2.StopApplicationOutput, error)
  • func (a *Activities) TagResource(ctx context.Context, input *kinesisanalyticsv2.TagResourceInput) (*kinesisanalyticsv2.TagResourceOutput, error)
  • func (a *Activities) UntagResource(ctx context.Context, input *kinesisanalyticsv2.UntagResourceInput) (*kinesisanalyticsv2.UntagResourceOutput, error)
  • func (a *Activities) UpdateApplication(ctx context.Context, input *kinesisanalyticsv2.UpdateApplicationInput) (*kinesisanalyticsv2.UpdateApplicationOutput, error)
• type SessionFactory

Types

type Activities

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

func NewActivities

func NewActivities(sess *session.Session, config ...*aws.Config) *Activities

func NewActivitiesWithSessionFactory

func NewActivitiesWithSessionFactory(sessionFactory SessionFactory) *Activities

func (*Activities) AddApplicationCloudWatchLoggingOption

func (a *Activities) AddApplicationCloudWatchLoggingOption(ctx context.Context, input *kinesisanalyticsv2.AddApplicationCloudWatchLoggingOptionInput) (*kinesisanalyticsv2.AddApplicationCloudWatchLoggingOptionOutput, error)

func (*Activities) AddApplicationInput

func (a *Activities) AddApplicationInput(ctx context.Context, input *kinesisanalyticsv2.AddApplicationInputInput) (*kinesisanalyticsv2.AddApplicationInputOutput, error)

func (*Activities) AddApplicationInputProcessingConfiguration

func (a *Activities) AddApplicationInputProcessingConfiguration(ctx context.Context, input *kinesisanalyticsv2.AddApplicationInputProcessingConfigurationInput) (*kinesisanalyticsv2.AddApplicationInputProcessingConfigurationOutput, error)

func (*Activities) AddApplicationOutput

func (a *Activities) AddApplicationOutput(ctx context.Context, input *kinesisanalyticsv2.AddApplicationOutputInput) (*kinesisanalyticsv2.AddApplicationOutputOutput, error)

func (*Activities) AddApplicationReferenceDataSource

func (a *Activities) AddApplicationReferenceDataSource(ctx context.Context, input *kinesisanalyticsv2.AddApplicationReferenceDataSourceInput) (*kinesisanalyticsv2.AddApplicationReferenceDataSourceOutput, error)

func (*Activities) AddApplicationVpcConfiguration

func (a *Activities) AddApplicationVpcConfiguration(ctx context.Context, input *kinesisanalyticsv2.AddApplicationVpcConfigurationInput) (*kinesisanalyticsv2.AddApplicationVpcConfigurationOutput, error)

func (*Activities) CreateApplication

func (a *Activities) CreateApplication(ctx context.Context, input *kinesisanalyticsv2.CreateApplicationInput) (*kinesisanalyticsv2.CreateApplicationOutput, error)

func (*Activities) CreateApplicationPresignedUrl

func (a *Activities) CreateApplicationPresignedUrl(ctx context.Context, input *kinesisanalyticsv2.CreateApplicationPresignedUrlInput) (*kinesisanalyticsv2.CreateApplicationPresignedUrlOutput, error)

func (*Activities) CreateApplicationSnapshot

func (a *Activities) CreateApplicationSnapshot(ctx context.Context, input *kinesisanalyticsv2.CreateApplicationSnapshotInput) (*kinesisanalyticsv2.CreateApplicationSnapshotOutput, error)

func (*Activities) DeleteApplication

func (a *Activities) DeleteApplication(ctx context.Context, input *kinesisanalyticsv2.DeleteApplicationInput) (*kinesisanalyticsv2.DeleteApplicationOutput, error)

func (*Activities) DeleteApplicationCloudWatchLoggingOption

func (a *Activities) DeleteApplicationCloudWatchLoggingOption(ctx context.Context, input *kinesisanalyticsv2.DeleteApplicationCloudWatchLoggingOptionInput) (*kinesisanalyticsv2.DeleteApplicationCloudWatchLoggingOptionOutput, error)

func (*Activities) DeleteApplicationInputProcessingConfiguration

func (a *Activities) DeleteApplicationInputProcessingConfiguration(ctx context.Context, input *kinesisanalyticsv2.DeleteApplicationInputProcessingConfigurationInput) (*kinesisanalyticsv2.DeleteApplicationInputProcessingConfigurationOutput, error)

func (*Activities) DeleteApplicationOutput

func (a *Activities) DeleteApplicationOutput(ctx context.Context, input *kinesisanalyticsv2.DeleteApplicationOutputInput) (*kinesisanalyticsv2.DeleteApplicationOutputOutput, error)

func (*Activities) DeleteApplicationReferenceDataSource

func (a *Activities) DeleteApplicationReferenceDataSource(ctx context.Context, input *kinesisanalyticsv2.DeleteApplicationReferenceDataSourceInput) (*kinesisanalyticsv2.DeleteApplicationReferenceDataSourceOutput, error)

func (*Activities) DeleteApplicationSnapshot

func (a *Activities) DeleteApplicationSnapshot(ctx context.Context, input *kinesisanalyticsv2.DeleteApplicationSnapshotInput) (*kinesisanalyticsv2.DeleteApplicationSnapshotOutput, error)

func (*Activities) DeleteApplicationVpcConfiguration

func (a *Activities) DeleteApplicationVpcConfiguration(ctx context.Context, input *kinesisanalyticsv2.DeleteApplicationVpcConfigurationInput) (*kinesisanalyticsv2.DeleteApplicationVpcConfigurationOutput, error)

func (*Activities) DescribeApplication

func (a *Activities) DescribeApplication(ctx context.Context, input *kinesisanalyticsv2.DescribeApplicationInput) (*kinesisanalyticsv2.DescribeApplicationOutput, error)

func (*Activities) DescribeApplicationSnapshot

func (a *Activities) DescribeApplicationSnapshot(ctx context.Context, input *kinesisanalyticsv2.DescribeApplicationSnapshotInput) (*kinesisanalyticsv2.DescribeApplicationSnapshotOutput, error)

func (*Activities) DiscoverInputSchema

func (a *Activities) DiscoverInputSchema(ctx context.Context, input *kinesisanalyticsv2.DiscoverInputSchemaInput) (*kinesisanalyticsv2.DiscoverInputSchemaOutput, error)

func (*Activities) ListApplicationSnapshots

func (a *Activities) ListApplicationSnapshots(ctx context.Context, input *kinesisanalyticsv2.ListApplicationSnapshotsInput) (*kinesisanalyticsv2.ListApplicationSnapshotsOutput, error)

func (*Activities) ListApplications

func (a *Activities) ListApplications(ctx context.Context, input *kinesisanalyticsv2.ListApplicationsInput) (*kinesisanalyticsv2.ListApplicationsOutput, error)

func (*Activities) ListTagsForResource

func (a *Activities) ListTagsForResource(ctx context.Context, input *kinesisanalyticsv2.ListTagsForResourceInput) (*kinesisanalyticsv2.ListTagsForResourceOutput, error)

func (*Activities) StartApplication

func (a *Activities) StartApplication(ctx context.Context, input *kinesisanalyticsv2.StartApplicationInput) (*kinesisanalyticsv2.StartApplicationOutput, error)

func (*Activities) StopApplication

func (a *Activities) StopApplication(ctx context.Context, input *kinesisanalyticsv2.StopApplicationInput) (*kinesisanalyticsv2.StopApplicationOutput, error)

func (*Activities) TagResource

func (a *Activities) TagResource(ctx context.Context, input *kinesisanalyticsv2.TagResourceInput) (*kinesisanalyticsv2.TagResourceOutput, error)

func (*Activities) UntagResource

func (a *Activities) UntagResource(ctx context.Context, input *kinesisanalyticsv2.UntagResourceInput) (*kinesisanalyticsv2.UntagResourceOutput, error)

func (*Activities) UpdateApplication

func (a *Activities) UpdateApplication(ctx context.Context, input *kinesisanalyticsv2.UpdateApplicationInput) (*kinesisanalyticsv2.UpdateApplicationOutput, error)

type SessionFactory

type SessionFactory interface {
	Session(ctx context.Context) (*session.Session, error)
}

SessionFactory returns an aws.Session based on the activity context.