AWS SDK for Go (PILOT)
API Reference

PREVIEW DOCUMENTATION - This is a preview of a new format for the AWS SDK for Go API Reference documentation. For the current AWS SDK for Go API Reference, see https://docs.aws.amazon.com/sdk-for-go/api/.

We welcome your feedback on this new version of the documentation. Send your comments to aws-sdkdocs-feedback@amazon.com.

InputDescription

import "github.com/aws/aws-sdk-go/service/kinesisanalytics"

type InputDescription struct { InAppStreamNames []*string `type:"list"` InputId *string `min:"1" type:"string"` InputParallelism *InputParallelism `type:"structure"` InputProcessingConfigurationDescription *InputProcessingConfigurationDescription `type:"structure"` InputSchema *SourceSchema `type:"structure"` InputStartingPositionConfiguration *InputStartingPositionConfiguration `type:"structure"` KinesisFirehoseInputDescription *KinesisFirehoseInputDescription `type:"structure"` KinesisStreamsInputDescription *KinesisStreamsInputDescription `type:"structure"` NamePrefix *string `min:"1" type:"string"` }

Describes the application input configuration. For more information, see Configuring Application Input (https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html).

InAppStreamNames

Type: []*string

Returns the in-application stream names that are mapped to the stream source.

InputId

Type: *string

Input ID associated with the application input. This is the ID that Amazon Kinesis Analytics assigns to each input configuration you add to your application.

InputParallelism

Describes the number of in-application streams to create for a given streaming source. For information about parallelism, see Configuring Application Input (https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html).

InputProcessingConfigurationDescription

Provides configuration information about an input processor. Currently, the only input processor available is AWS Lambda (https://aws.amazon.com/documentation/lambda/).

InputSchema

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

InputStartingPositionConfiguration

Describes the point at which the application reads from the streaming source.

KinesisFirehoseInputDescription

Describes the Amazon Kinesis Firehose delivery stream that is configured as the streaming source in the application input configuration.

KinesisStreamsInputDescription

Describes the Amazon Kinesis stream that is configured as the streaming source in the application input configuration.

NamePrefix

Type: *string

In-application name prefix.

Method

GoString

func (s InputDescription) GoString() string

GoString returns the string representation

SetInAppStreamNames

func (s *InputDescription) SetInAppStreamNames(v []*string) *InputDescription

SetInAppStreamNames sets the InAppStreamNames field's value.

SetInputId

func (s *InputDescription) SetInputId(v string) *InputDescription

SetInputId sets the InputId field's value.

SetInputParallelism

func (s *InputDescription) SetInputParallelism(v *InputParallelism) *InputDescription

SetInputParallelism sets the InputParallelism field's value.

SetInputProcessingConfigurationDescription

func (s *InputDescription) SetInputProcessingConfigurationDescription(v *InputProcessingConfigurationDescription) *InputDescription

SetInputProcessingConfigurationDescription sets the InputProcessingConfigurationDescription field's value.

SetInputSchema

func (s *InputDescription) SetInputSchema(v *SourceSchema) *InputDescription

SetInputSchema sets the InputSchema field's value.

SetInputStartingPositionConfiguration

func (s *InputDescription) SetInputStartingPositionConfiguration(v *InputStartingPositionConfiguration) *InputDescription

SetInputStartingPositionConfiguration sets the InputStartingPositionConfiguration field's value.

SetKinesisFirehoseInputDescription

func (s *InputDescription) SetKinesisFirehoseInputDescription(v *KinesisFirehoseInputDescription) *InputDescription

SetKinesisFirehoseInputDescription sets the KinesisFirehoseInputDescription field's value.

SetKinesisStreamsInputDescription

func (s *InputDescription) SetKinesisStreamsInputDescription(v *KinesisStreamsInputDescription) *InputDescription

SetKinesisStreamsInputDescription sets the KinesisStreamsInputDescription field's value.

SetNamePrefix

func (s *InputDescription) SetNamePrefix(v string) *InputDescription

SetNamePrefix sets the NamePrefix field's value.

String

func (s InputDescription) String() string

String returns the string representation

On this page: