Help us shape the future of Go! Take the 2026 Go Developer Survey

kinesisanalytics

package
v1.8.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 20, 2026 License: MIT Imports: 24 Imported by: 0

README

Kinesis Analytics

Parity grade: A · SDK aws-sdk-go-v2/service/kinesisanalytics@v1.33.4 · last audited 2026-10-11 (49cff86c4)

Coverage

Metric Value
PARITY entries audited 20 (20 ok)
Feature families 2 (2 ok)
Known gaps none
Deferred items 0
Resource leaks clean

More

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ErrNotFound is returned when an application does not exist.
	ErrNotFound = awserr.New("ResourceNotFoundException", awserr.ErrNotFound)
	// ErrAlreadyExists is returned when an application already exists.
	ErrAlreadyExists = awserr.New("ResourceInUseException", awserr.ErrAlreadyExists)
	// ErrConcurrentUpdate is returned when the application version does not match.
	ErrConcurrentUpdate = errors.New("ConcurrentModificationException: application version mismatch")
	// ErrValidation is returned for invalid input parameters.
	ErrValidation = awserr.New("InvalidArgumentException", awserr.ErrInvalidParameter)
	// ErrLimitExceeded is returned when a resource limit is reached.
	ErrLimitExceeded = awserr.New("LimitExceededException", awserr.ErrConflict)
	// ErrTooManyTags is returned when tagging an application would exceed the maximum tag
	// count. AWS models this as a dedicated TooManyTagsException on CreateApplication and
	// TagResource, distinct from the generic LimitExceededException (verified against
	// aws-sdk-go-v2/service/kinesisanalytics deserializers.go per-operation error lists).
	ErrTooManyTags = errors.New("TooManyTagsException: application tag limit exceeded")
	// ErrResourceInUse is returned when the app is in an incompatible state for the requested operation.
	ErrResourceInUse = awserr.New("ResourceInUseException", awserr.ErrAlreadyExists)
	// ErrUnableToDetectSchema is returned by DiscoverInputSchema when no sample data can be
	// obtained from the requested source. Real AWS has no ResourceNotFoundException on this op
	// (verified: aws-sdk-go-v2/service/kinesisanalytics@v1.33.4 deserializers.go
	// awsAwsjson11_deserializeOpErrorDiscoverInputSchema only switches on InvalidArgumentException,
	// ResourceProvisionedThroughputExceededException, ServiceUnavailableException, and
	// UnableToDetectSchemaException) -- a source that doesn't exist or has no data surfaces here.
	ErrUnableToDetectSchema = errors.New(
		"UnableToDetectSchemaException: unable to sample data from the requested source",
	)
)
View Source 
var ErrNilAppContext = errors.New("kinesisanalytics: AppContext must not be nil")

ErrNilAppContext is returned by Provider.Init when a nil AppContext is supplied.

Functions

This section is empty.

Types

type Application 

type Application struct {
	LastUpdateTimestamp      *time.Time                       `json:"LastUpdateTimestamp,omitempty"`
	Tags                     map[string]string                `json:"Tags,omitempty"`
	CreateTimestamp          *time.Time                       `json:"CreateTimestamp,omitempty"`
	ApplicationARN           string                           `json:"ApplicationARN"`
	ApplicationStatus        string                           `json:"ApplicationStatus"`
	ApplicationDescription   string                           `json:"ApplicationDescription,omitempty"`
	ApplicationCode          string                           `json:"ApplicationCode,omitempty"`
	ApplicationName          string                           `json:"ApplicationName"`
	Region                   string                           `json:"region,omitempty"`
	CloudWatchLoggingOptions []CloudWatchLoggingOptionDesc    `json:"CloudWatchLoggingOptions,omitempty"`
	ReferenceDataSources     []ReferenceDataSourceDescription `json:"ReferenceDataSources,omitempty"`
	Outputs                  []OutputDescription              `json:"Outputs,omitempty"`
	Inputs                   []InputDescription               `json:"Inputs,omitempty"`
	ApplicationVersionID     int64                            `json:"ApplicationVersionId"`
}

Application represents a Kinesis Analytics v1 application.

Region is additive: it is never part of the AWS wire format (Application is always converted to applicationDetail/applicationSummary before being marshaled for a response -- see toApplicationDetail in handler.go), so it carries a lowercase JSON tag to distinguish it from the AWS-named fields above. It exists purely so the store.Table keyFn and byRegion/byARN [store.Index]es (see store_setup.go) can derive both halves of the region-scoped identity from the value itself, mirroring how ApplicationName was already a real field. It must still round-trip through JSON (not json:"-") because it is part of the primary key store.Table.Restore rebuilds from a persisted snapshot.

type CSVMappingParameters 

type CSVMappingParameters struct {
	RecordColumnDelimiter string `json:"RecordColumnDelimiter"`
	RecordRowDelimiter    string `json:"RecordRowDelimiter"`
}

CSVMappingParameters holds CSV delimiters.

type CloudWatchLoggingOptionDesc 

type CloudWatchLoggingOptionDesc struct {
	CloudWatchLoggingOptionID string `json:"CloudWatchLoggingOptionId"`
	LogStreamARN              string `json:"LogStreamARN"`
	RoleARN                   string `json:"RoleARN,omitempty"`
}

CloudWatchLoggingOptionDesc describes a CloudWatch logging option.

type DestinationSchemaDesc 

type DestinationSchemaDesc struct {
	RecordFormatType string `json:"RecordFormatType"`
}

DestinationSchemaDesc describes the destination record format.

type ExportedApplication 

type ExportedApplication = Application

ExportedApplication is a compatibility alias used by the dashboard package.

type FirehoseSampleReader 

type FirehoseSampleReader interface {
	SampleRecords(streamRef string, limit int) ([][]byte, error)
}

FirehoseSampleReader returns recently ingested records of a delivery stream (ARN or name).

type Handler 

type Handler struct {
	Backend       StorageBackend
	AccountID     string
	DefaultRegion string
	// contains filtered or unexported fields
}

Handler is the HTTP handler for the Kinesis Analytics v1 API.

func NewHandler 

func NewHandler(backend StorageBackend) *Handler

NewHandler creates a new Kinesis Analytics handler.

func (*Handler) ChaosOperations 

func (h *Handler) ChaosOperations() []string

ChaosOperations returns all operations that can be fault-injected.

func (*Handler) ChaosRegions 

func (h *Handler) ChaosRegions() []string

ChaosRegions returns all regions this handler handles.

func (*Handler) ChaosServiceName 

func (h *Handler) ChaosServiceName() string

ChaosServiceName returns the lowercase AWS service name for fault rule matching.

func (*Handler) ExtractOperation 

func (h *Handler) ExtractOperation(c *echo.Context) string

ExtractOperation extracts the Kinesis Analytics action from the X-Amz-Target header.

func (*Handler) ExtractResource 

func (h *Handler) ExtractResource(c *echo.Context) string

ExtractResource extracts the application name from the request body.

func (*Handler) GetSupportedOperations 

func (h *Handler) GetSupportedOperations() []string

GetSupportedOperations returns the list of supported Kinesis Analytics operations.

func (*Handler) Handler 

func (h *Handler) Handler() echo.HandlerFunc

Handler returns the Echo handler function.

func (*Handler) MatchPriority 

func (h *Handler) MatchPriority() int

MatchPriority returns the routing priority for header-based matching.

func (*Handler) Name 

func (h *Handler) Name() string

Name returns the service name.

func (*Handler) Reset 

func (h *Handler) Reset()

Reset clears handler state (delegates to backend if supported).

func (*Handler) Restore 

func (h *Handler) Restore(ctx context.Context, data []byte) error

Restore implements persistence.Persistable by delegating to the backend.

func (*Handler) RouteMatcher 

func (h *Handler) RouteMatcher() service.Matcher

RouteMatcher returns a function that matches Kinesis Analytics requests by X-Amz-Target header.

func (*Handler) Snapshot 

func (h *Handler) Snapshot(ctx context.Context) []byte

Snapshot implements persistence.Persistable by delegating to the backend.

type InMemoryBackend 

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

InMemoryBackend is the in-memory implementation of StorageBackend.

Applications are keyed by a composite "region#name" key (see applicationKey) inside a single flat store.Table, with secondary [store.Index]es grouping them by region (byRegion, replacing the old per-region map iteration) and by ARN (byARN, replacing the old map[region]map[arn]*Application reverse index) -- see store_setup.go for the full rationale.

func NewInMemoryBackend 

func NewInMemoryBackend(region, accountID string) *InMemoryBackend

NewInMemoryBackend creates a new in-memory Kinesis Analytics backend with a background service context.

func NewInMemoryBackendWithContext 

func NewInMemoryBackendWithContext(svcCtx context.Context, region, accountID string) *InMemoryBackend

NewInMemoryBackendWithContext creates a new in-memory Kinesis Analytics backend whose background goroutines are bounded by svcCtx. If svcCtx is nil, context.Background is used.

func (*InMemoryBackend) AddApplicationCloudWatchLoggingOption 

func (b *InMemoryBackend) AddApplicationCloudWatchLoggingOption(
	ctx context.Context, name string, versionID int64, option CloudWatchLoggingOptionDesc,
) error

AddApplicationCloudWatchLoggingOption adds a CloudWatch logging option to an application.

func (*InMemoryBackend) AddApplicationInput 

func (b *InMemoryBackend) AddApplicationInput(
	ctx context.Context, name string, versionID int64, input InputDescription,
) error

AddApplicationInput adds an input configuration to an application.

func (*InMemoryBackend) AddApplicationInputProcessingConfiguration 

func (b *InMemoryBackend) AddApplicationInputProcessingConfiguration(
	ctx context.Context, name string, versionID int64, inputID string, config *InputProcessingConfigurationDesc,
) error

AddApplicationInputProcessingConfiguration sets a processing configuration on an existing input.

func (*InMemoryBackend) AddApplicationInternal 

func (b *InMemoryBackend) AddApplicationInternal(app *Application)

AddApplicationInternal is a test-only seed helper that stores an application directly. The region is extracted from the application ARN.

func (*InMemoryBackend) AddApplicationOutput 

func (b *InMemoryBackend) AddApplicationOutput(
	ctx context.Context, name string, versionID int64, output OutputDescription,
) error

AddApplicationOutput adds an output configuration to an application.

func (*InMemoryBackend) AddApplicationReferenceDataSource 

func (b *InMemoryBackend) AddApplicationReferenceDataSource(
	ctx context.Context, name string, versionID int64, ref ReferenceDataSourceDescription,
) error

AddApplicationReferenceDataSource adds a reference data source to an application.

func (*InMemoryBackend) CreateApplication 

func (b *InMemoryBackend) CreateApplication(
	ctx context.Context,
	name, description, code string,
	inputs []InputDescription,
	outputs []OutputDescription,
	cwlOptions []CloudWatchLoggingOptionDesc,
	tags map[string]string,
) (*Application, error)

CreateApplication creates a new Kinesis Analytics application.

func (*InMemoryBackend) DeleteApplication 

func (b *InMemoryBackend) DeleteApplication(ctx context.Context, name string, createTimestamp *time.Time) error

DeleteApplication marks an application for deletion (DELETING state) then removes it after a delay.

func (*InMemoryBackend) DeleteApplicationCloudWatchLoggingOption 

func (b *InMemoryBackend) DeleteApplicationCloudWatchLoggingOption(
	ctx context.Context, name string, versionID int64, loggingOptionID string,
) error

DeleteApplicationCloudWatchLoggingOption removes a CloudWatch logging option from an application.

func (*InMemoryBackend) DeleteApplicationInputProcessingConfiguration 

func (b *InMemoryBackend) DeleteApplicationInputProcessingConfiguration(
	ctx context.Context, name string, versionID int64, inputID string,
) error

DeleteApplicationInputProcessingConfiguration removes the processing config from an input.

func (*InMemoryBackend) DeleteApplicationOutput 

func (b *InMemoryBackend) DeleteApplicationOutput(
	ctx context.Context, name string, versionID int64, outputID string,
) error

DeleteApplicationOutput removes an output configuration from an application.

func (*InMemoryBackend) DeleteApplicationReferenceDataSource 

func (b *InMemoryBackend) DeleteApplicationReferenceDataSource(
	ctx context.Context, name string, versionID int64, referenceID string,
) error

DeleteApplicationReferenceDataSource removes a reference data source from an application.

func (*InMemoryBackend) DescribeApplication 

func (b *InMemoryBackend) DescribeApplication(ctx context.Context, name string) (*Application, error)

DescribeApplication returns a copy of the details for a Kinesis Analytics application.

func (*InMemoryBackend) DiscoverInputSchema added in v1.3.1 

func (b *InMemoryBackend) DiscoverInputSchema(
	ctx context.Context,
	resourceARN string,
	s3cfg *s3ConfigurationInput,
) (*SourceSchema, []string, [][]string, error)

DiscoverInputSchema samples real records from the requested source and infers a SourceSchema from them. A source whose reader is unwired or has nothing to sample yields ErrUnableToDetectSchema, as the operation's error set has no ResourceNotFoundException.

func (*InMemoryBackend) ListApplications 

func (b *InMemoryBackend) ListApplications(
	ctx context.Context,
	exclusiveStart string,
	limit int,
) ([]*Application, bool, error)

ListApplications returns paginated applications.

func (*InMemoryBackend) ListTagsForResource 

func (b *InMemoryBackend) ListTagsForResource(ctx context.Context, resourceARN string) (map[string]string, error)

ListTagsForResource returns tags for a resource identified by ARN.

func (*InMemoryBackend) Region 

func (b *InMemoryBackend) Region() string

Region returns the default region for this backend.

func (*InMemoryBackend) Reset 

func (b *InMemoryBackend) Reset()

Reset clears all state and resets the ID counter.

func (*InMemoryBackend) Restore 

func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

Restore loads backend state from a JSON snapshot. It implements persistence.Persistable.

func (*InMemoryBackend) SetFirehoseSampleReader 

func (b *InMemoryBackend) SetFirehoseSampleReader(r FirehoseSampleReader)

SetFirehoseSampleReader wires the Firehose backend DiscoverInputSchema samples records from when ResourceARN names a delivery stream.

func (*InMemoryBackend) SetKinesisStreamReader added in v1.3.1 

func (b *InMemoryBackend) SetKinesisStreamReader(r KinesisStreamReader)

SetKinesisStreamReader wires the Kinesis backend DiscoverInputSchema samples records from when ResourceARN names a Kinesis stream. Not wired by cli.go today -- see README.

func (*InMemoryBackend) SetS3ObjectReader added in v1.3.1 

func (b *InMemoryBackend) SetS3ObjectReader(r S3ObjectReader)

SetS3ObjectReader wires the S3 backend DiscoverInputSchema samples object content from when S3Configuration is set. Not wired by cli.go today -- see README.

func (*InMemoryBackend) Snapshot 

func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

Snapshot serialises the backend state to JSON. It implements persistence.Persistable.

func (*InMemoryBackend) StartApplication 

func (b *InMemoryBackend) StartApplication(ctx context.Context, name string, inputConfigs []inputConfiguration) error

StartApplication transitions an application to RUNNING via a STARTING transient state.

func (*InMemoryBackend) StopApplication 

func (b *InMemoryBackend) StopApplication(ctx context.Context, name string) error

StopApplication transitions an application to READY via a STOPPING transient state.

func (*InMemoryBackend) TagResource 

func (b *InMemoryBackend) TagResource(ctx context.Context, resourceARN string, tags map[string]string) error

TagResource adds or updates tags on a resource.

func (*InMemoryBackend) UntagResource 

func (b *InMemoryBackend) UntagResource(ctx context.Context, resourceARN string, tagKeys []string) error

UntagResource removes tags from a resource.

func (*InMemoryBackend) UpdateApplication 

func (b *InMemoryBackend) UpdateApplication(
	ctx context.Context,
	name string,
	currentVersionID int64,
	update *applicationUpdate,
) (*Application, error)

UpdateApplication updates the application with the full update payload and bumps the version.

type InputDescription 

type InputDescription struct {
	InputProcessingConfigurationDescription *InputProcessingConfigurationDesc   `json:"InputProcessingConfigurationDescription,omitempty"`
	InputStartingPositionConfiguration      *InputStartingPositionConfiguration `json:"InputStartingPositionConfiguration,omitempty"`
	InputSchema                             *SourceSchema                       `json:"InputSchema,omitempty"`
	InputParallelism                        *InputParallelism                   `json:"InputParallelism,omitempty"`
	KinesisStreamsInputDescription          *KinesisStreamsInputDesc            `json:"KinesisStreamsInputDescription,omitempty"`
	KinesisFirehoseInputDescription         *KinesisFirehoseInputDesc           `json:"KinesisFirehoseInputDescription,omitempty"`
	InputID                                 string                              `json:"InputId"`
	NamePrefix                              string                              `json:"NamePrefix,omitempty"`
	InAppStreamNames                        []string                            `json:"InAppStreamNames,omitempty"`
}

InputDescription describes an application input configuration.

type InputParallelism 

type InputParallelism struct {
	Count int `json:"Count"`
}

InputParallelism describes the in-application stream count for an input.

type InputProcessingConfigurationDesc 

type InputProcessingConfigurationDesc struct {
	InputLambdaProcessorDescription *LambdaProcessorDesc `json:"InputLambdaProcessorDescription,omitempty"`
}

InputProcessingConfigurationDesc describes an input processing configuration.

The wire key is "InputLambdaProcessorDescription", not "InputLambdaProcessor" -- distinct from the request-side InputProcessingConfiguration.InputLambdaProcessor, verified against aws-sdk-go-v2/service/kinesisanalytics/types.InputProcessingConfigurationDescription.

type InputStartingPositionConfiguration 

type InputStartingPositionConfiguration struct {
	InputStartingPosition string `json:"InputStartingPosition,omitempty"`
}

InputStartingPositionConfiguration describes where to start reading from an input stream.

type JSONMappingParameters 

type JSONMappingParameters struct {
	RecordRowPath string `json:"RecordRowPath"`
}

JSONMappingParameters holds the JSON row path.

type KinesisFirehoseInputDesc 

type KinesisFirehoseInputDesc struct {
	ResourceARN string `json:"ResourceARN"`
	RoleARN     string `json:"RoleARN,omitempty"`
}

KinesisFirehoseInputDesc describes a Kinesis Firehose input.

type KinesisFirehoseOutputDesc 

type KinesisFirehoseOutputDesc struct {
	ResourceARN string `json:"ResourceARN"`
	RoleARN     string `json:"RoleARN,omitempty"`
}

KinesisFirehoseOutputDesc describes a Kinesis Firehose output.

type KinesisStreamReader added in v1.3.1 

type KinesisStreamReader interface {
	ListShards(streamName string) ([]string, error)
	GetShardIterator(streamName, shardID string) (string, error)
	GetRecords(shardIterator string, limit int) (records [][]byte, nextIterator string, err error)
}

KinesisStreamReader is the subset of Kinesis operations DiscoverInputSchema needs to sample records from a live Kinesis stream. Same narrow shape as services/firehose's own KinesisReader (services/firehose/interfaces.go): a sibling backend implements it, and cli.go wires the two together. Like firehose's KinesisReader, kinesis.InMemoryBackend does not satisfy this directly (its real methods are ctx+typed-struct shaped, e.g. GetRecords(ctx, *GetRecordsInput) (*GetRecordsOutput, error) -- see services/kinesis/records.go) so an adapter is needed at the wiring site.

type KinesisStreamsInputDesc 

type KinesisStreamsInputDesc struct {
	ResourceARN string `json:"ResourceARN"`
	RoleARN     string `json:"RoleARN,omitempty"`
}

KinesisStreamsInputDesc describes a Kinesis Streams input.

type KinesisStreamsOutputDesc 

type KinesisStreamsOutputDesc struct {
	ResourceARN string `json:"ResourceARN"`
	RoleARN     string `json:"RoleARN,omitempty"`
}

KinesisStreamsOutputDesc describes a Kinesis Streams output.

type LambdaOutputDesc 

type LambdaOutputDesc struct {
	ResourceARN string `json:"ResourceARN"`
	RoleARN     string `json:"RoleARN,omitempty"`
}

LambdaOutputDesc describes a Lambda output.

type LambdaProcessorDesc 

type LambdaProcessorDesc struct {
	ResourceARN string `json:"ResourceARN"`
	RoleARN     string `json:"RoleARN,omitempty"`
}

LambdaProcessorDesc describes a Lambda input processor.

type MappingParameters 

type MappingParameters struct {
	JSONMappingParameters *JSONMappingParameters `json:"JSONMappingParameters,omitempty"`
	CSVMappingParameters  *CSVMappingParameters  `json:"CSVMappingParameters,omitempty"`
}

MappingParameters holds format-specific mapping parameters.

type OutputDescription 

type OutputDescription struct {
	KinesisStreamsOutputDescription  *KinesisStreamsOutputDesc  `json:"KinesisStreamsOutputDescription,omitempty"`
	KinesisFirehoseOutputDescription *KinesisFirehoseOutputDesc `json:"KinesisFirehoseOutputDescription,omitempty"`
	LambdaOutputDescription          *LambdaOutputDesc          `json:"LambdaOutputDescription,omitempty"`
	DestinationSchema                *DestinationSchemaDesc     `json:"DestinationSchema,omitempty"`
	OutputID                         string                     `json:"OutputId"`
	Name                             string                     `json:"Name,omitempty"`
}

OutputDescription describes an application output configuration.

type Provider 

type Provider struct{}

Provider implements service.Provider for the Kinesis Analytics service.

func (*Provider) Init 

func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

Init initializes the Kinesis Analytics service backend and handler.

func (*Provider) Name 

func (p *Provider) Name() string

Name returns the provider name.

type RecordColumn 

type RecordColumn struct {
	Name    string `json:"Name"`
	SQLType string `json:"SqlType"`
	Mapping string `json:"Mapping,omitempty"`
}

RecordColumn describes a column mapping in the schema.

type RecordFormat 

type RecordFormat struct {
	MappingParameters *MappingParameters `json:"MappingParameters,omitempty"`
	RecordFormatType  string             `json:"RecordFormatType"`
}

RecordFormat describes the record format type and mapping.

type ReferenceDataSourceDescription 

type ReferenceDataSourceDescription struct {
	S3ReferenceDataSourceDescription *S3ReferenceDataSourceDesc `json:"S3ReferenceDataSourceDescription,omitempty"`
	ReferenceSchema                  *SourceSchema              `json:"ReferenceSchema,omitempty"`
	ReferenceID                      string                     `json:"ReferenceId"`
	TableName                        string                     `json:"TableName,omitempty"`
}

ReferenceDataSourceDescription describes a reference data source.

type S3ObjectReader added in v1.3.1 

type S3ObjectReader interface {
	GetObject(ctx context.Context, input *sdk_s3.GetObjectInput) (*sdk_s3.GetObjectOutput, error)
}

S3ObjectReader is the subset of S3 operations DiscoverInputSchema needs to sample an object's content. Uses the real SDK request/response shapes directly, so s3.InMemoryBackend.GetObject (services/s3/objects.go) satisfies this interface with no adapter needed -- the same pattern as services/firehose's S3Storer (services/firehose/interfaces.go).

type S3ReferenceDataSourceDesc 

type S3ReferenceDataSourceDesc struct {
	BucketARN        string `json:"BucketARN"`
	FileKey          string `json:"FileKey"`
	ReferenceRoleARN string `json:"ReferenceRoleARN,omitempty"`
}

S3ReferenceDataSourceDesc describes the S3 source for reference data.

The IAM role field is wired as "ReferenceRoleARN" on the wire, not "RoleARN" -- unlike every other role-ARN-bearing shape in this API, S3ReferenceDataSource(Description) uses the ReferenceRoleARN name (verified against aws-sdk-go-v2/service/kinesisanalytics deserializers.go / types.go).

type SourceSchema 

type SourceSchema struct {
	RecordFormat   RecordFormat   `json:"RecordFormat"`
	RecordEncoding string         `json:"RecordEncoding,omitempty"`
	RecordColumns  []RecordColumn `json:"RecordColumns"`
}

SourceSchema describes the schema of the input records.

type StorageBackend 

type StorageBackend interface {
	CreateApplication(ctx context.Context, name, description, code string,
		inputs []InputDescription, outputs []OutputDescription,
		cwlOptions []CloudWatchLoggingOptionDesc, tags map[string]string) (*Application, error)
	DeleteApplication(ctx context.Context, name string, createTimestamp *time.Time) error
	DescribeApplication(ctx context.Context, name string) (*Application, error)
	ListApplications(ctx context.Context, exclusiveStart string, limit int) ([]*Application, bool, error)
	StartApplication(ctx context.Context, name string, inputConfigs []inputConfiguration) error
	StopApplication(ctx context.Context, name string) error
	UpdateApplication(
		ctx context.Context,
		name string,
		currentVersionID int64,
		update *applicationUpdate,
	) (*Application, error)
	ListTagsForResource(ctx context.Context, resourceARN string) (map[string]string, error)
	TagResource(ctx context.Context, resourceARN string, tags map[string]string) error
	UntagResource(ctx context.Context, resourceARN string, tagKeys []string) error
	AddApplicationCloudWatchLoggingOption(
		ctx context.Context,
		name string,
		versionID int64,
		option CloudWatchLoggingOptionDesc,
	) error
	AddApplicationInput(ctx context.Context, name string, versionID int64, input InputDescription) error
	AddApplicationInputProcessingConfiguration(
		ctx context.Context,
		name string,
		versionID int64,
		inputID string,
		config *InputProcessingConfigurationDesc,
	) error
	AddApplicationOutput(ctx context.Context, name string, versionID int64, output OutputDescription) error
	AddApplicationReferenceDataSource(
		ctx context.Context,
		name string,
		versionID int64,
		ref ReferenceDataSourceDescription,
	) error
	DeleteApplicationCloudWatchLoggingOption(
		ctx context.Context,
		name string,
		versionID int64,
		loggingOptionID string,
	) error
	DeleteApplicationInputProcessingConfiguration(
		ctx context.Context,
		name string,
		versionID int64,
		inputID string,
	) error
	DeleteApplicationOutput(ctx context.Context, name string, versionID int64, outputID string) error
	DeleteApplicationReferenceDataSource(ctx context.Context, name string, versionID int64, referenceID string) error
	DiscoverInputSchema(
		ctx context.Context,
		resourceARN string,
		s3cfg *s3ConfigurationInput,
	) (schema *SourceSchema, raw []string, parsed [][]string, err error)
}

StorageBackend is the interface for the Kinesis Analytics in-memory backend.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.