kinesis

package
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Aug 3, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(p client.ConfigProvider, opts ...*aws.Config) api.Endpoint

New implements api.ServiceFunc

Types

type API

type API interface {
	ListStreamsPagesWithContext(context.Context, *kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool, ...request.Option) error
	DescribeStreamPagesWithContext(context.Context, *kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool, ...request.Option) error
}

API documents the subset of AWS API we actually call

type DescribeStreamOutput

type DescribeStreamOutput struct {
	*kinesis.DescribeStreamOutput
}

func (*DescribeStreamOutput) Records

func (o *DescribeStreamOutput) Records() (records []*api.Record)

type DescribeStreams

type DescribeStreams struct {
	API
}

func (*DescribeStreams) New

func (fn *DescribeStreams) New(name string, config interface{}) ([]api.Request, error)

New implements api.RequestBuilder

Jump to

Keyboard shortcuts

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