awsclient

Documentation

Index

• type CloudWatchLogs
• type DynamoDB
• type Factory
  • func NewFactory() (*Factory, error)
  • func (f *Factory) CloudWatchLogs() CloudWatchLogs
  • func (f *Factory) DynamoDB() DynamoDB
  • func (f *Factory) Kinesis() Kinesis
  • func (f *Factory) Region() string
  • func (f *Factory) S3() S3
  • func (f *Factory) SSM() SSM
• type Kinesis
• type S3
• type SSM

Types

type CloudWatchLogs

type CloudWatchLogs interface {
	DescribeLogStreamsPages(*cloudwatchlogs.DescribeLogStreamsInput, func(*cloudwatchlogs.DescribeLogStreamsOutput, bool) bool) error
	GetLogEventsPages(*cloudwatchlogs.GetLogEventsInput, func(*cloudwatchlogs.GetLogEventsOutput, bool) bool) error
}

type DynamoDB

type DynamoDB interface {
	CreateTable(*dynamodb.CreateTableInput) (*dynamodb.CreateTableOutput, error)
	PutItem(*dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)
	GetItem(*dynamodb.GetItemInput) (*dynamodb.GetItemOutput, error)
	ListTablesPages(*dynamodb.ListTablesInput, func(*dynamodb.ListTablesOutput, bool) bool) error
}

type Factory

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

func NewFactory

func NewFactory() (*Factory, error)

func (*Factory) CloudWatchLogs

func (f *Factory) CloudWatchLogs() CloudWatchLogs

func (*Factory) DynamoDB

func (f *Factory) DynamoDB() DynamoDB

func (*Factory) Kinesis

func (f *Factory) Kinesis() Kinesis

func (*Factory) Region

func (f *Factory) Region() string

func (*Factory) S3

func (f *Factory) S3() S3

func (*Factory) SSM

func (f *Factory) SSM() SSM

type Kinesis

type Kinesis interface {
	GetRecords(*kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)
	GetShardIterator(*kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)
	DescribeStream(*kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
}

type S3

type S3 interface {
	PutObject(*s3.PutObjectInput) (*s3.PutObjectOutput, error)
}

type SSM

type SSM interface {
	CreateDocument(*ssm.CreateDocumentInput) (*ssm.CreateDocumentOutput, error)
	DescribeDocument(*ssm.DescribeDocumentInput) (*ssm.DescribeDocumentOutput, error)
	UpdateDocument(*ssm.UpdateDocumentInput) (*ssm.UpdateDocumentOutput, error)
	UpdateDocumentDefaultVersion(*ssm.UpdateDocumentDefaultVersionInput) (*ssm.UpdateDocumentDefaultVersionOutput, error)
	SendCommand(*ssm.SendCommandInput) (*ssm.SendCommandOutput, error)
	ListCommands(*ssm.ListCommandsInput) (*ssm.ListCommandsOutput, error)
	ListCommandInvocationsPages(*ssm.ListCommandInvocationsInput, func(*ssm.ListCommandInvocationsOutput, bool) bool) error
	DescribeInstanceInformationPages(*ssm.DescribeInstanceInformationInput, func(*ssm.DescribeInstanceInformationOutput, bool) bool) error
	ListDocumentsPages(*ssm.ListDocumentsInput, func(*ssm.ListDocumentsOutput, bool) bool) error
}