libaws

Documentation

Index

• type Aws
  • func AwsHAndler() *Aws
  • func (aw *Aws) Consumer(data *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)
  • func (aw *Aws) Describe(data *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
  • func (aw *Aws) GetDescribeInput() *kinesis.DescribeStreamInput
  • func (aw *Aws) GetDynamoDB() *dynamodb.DynamoDB
  • func (aw *Aws) GetDynamoData(ID string) (*dynamodb.GetItemOutput, error)
  • func (aw *Aws) GetDynamoHistory(receiverAddress string) (*dynamodb.ScanOutput, error)
  • func (aw *Aws) GetKinesis() *kinesis.Kinesis
  • func (aw *Aws) GetShardIterator() (string, error)
  • func (aw *Aws) InputDynamo(itemDynamo *dynamoEntyty.DynamoItem, wg *sync.WaitGroup) (*dynamodb.PutItemOutput, error)
  • func (aw *Aws) Send(data []byte, stack string, wg *sync.WaitGroup) (*kinesis.PutRecordOutput, error)
  • func (aw *Aws) SendStart(ID string, itemDynamo *entity.DynamoItem, stack string, wg *sync.WaitGroup)
  • func (aw *Aws) Sessions() *aws.Config
  • func (aw *Aws) SessionsKinesis() *aws.Config
  • func (aw *Aws) UpdateDynamo(ID, status, data string, history *dynamoEntyty.HistoryItem) (*dynamodb.UpdateItemOutput, error)
  • func (aw *Aws) WaitUntil(data *kinesis.DescribeStreamInput) error
  • func (aw *Aws) WaitUntilNotExist(data *kinesis.DescribeStreamInput) error
• type AwsInterface

Types

type Aws

type Aws struct {
}

Aws ...

func AwsHAndler

func AwsHAndler() *Aws

AwsHAndler ..

func (*Aws) Consumer

func (aw *Aws) Consumer(data *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)

Consumer ...

func (*Aws) Describe

func (aw *Aws) Describe(data *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)

Describe ...

func (*Aws) GetDescribeInput

func (aw *Aws) GetDescribeInput() *kinesis.DescribeStreamInput

GetDescribeInput ...

func (*Aws) GetDynamoDB

func (aw *Aws) GetDynamoDB() *dynamodb.DynamoDB

GetDynamoDB get dynamodb service return *dynamodb.DynamoDB

func (*Aws) GetDynamoData

func (aw *Aws) GetDynamoData(ID string) (*dynamodb.GetItemOutput, error)

GetDynamoData ..

func (*Aws) GetDynamoHistory

func (aw *Aws) GetDynamoHistory(receiverAddress string) (*dynamodb.ScanOutput, error)

GetDynamoHistory ..

func (*Aws) GetKinesis

func (aw *Aws) GetKinesis() *kinesis.Kinesis

GetKinesis get dynamodb service return *kinesis.Kinesis

func (*Aws) GetShardIterator

func (aw *Aws) GetShardIterator() (string, error)

GetShardIterator ...

func (*Aws) InputDynamo

func (aw *Aws) InputDynamo(itemDynamo *dynamoEntyty.DynamoItem, wg *sync.WaitGroup) (*dynamodb.PutItemOutput, error)

InputDynamo ...

func (*Aws) Send

func (aw *Aws) Send(data []byte, stack string, wg *sync.WaitGroup) (*kinesis.PutRecordOutput, error)

Send ...

func (*Aws) SendStart

func (aw *Aws) SendStart(ID string, itemDynamo *entity.DynamoItem, stack string, wg *sync.WaitGroup)

SendStart ...

func (*Aws) Sessions

func (aw *Aws) Sessions() *aws.Config

Sessions ... @cfg: *entity.AwsConfig

func (*Aws) SessionsKinesis

func (aw *Aws) SessionsKinesis() *aws.Config

SessionsKinesis ... @cfg: *entity.AwsConfig

func (*Aws) UpdateDynamo

func (aw *Aws) UpdateDynamo(ID, status, data string, history *dynamoEntyty.HistoryItem) (*dynamodb.UpdateItemOutput, error)

UpdateDynamo ...

func (*Aws) WaitUntil

func (aw *Aws) WaitUntil(data *kinesis.DescribeStreamInput) error

WaitUntil ...

func (*Aws) WaitUntilNotExist

func (aw *Aws) WaitUntilNotExist(data *kinesis.DescribeStreamInput) error

WaitUntilNotExist ...

type AwsInterface

type AwsInterface interface {
	// dynamo
	InputDynamo(itemDynamo *dynamoEntyty.DynamoItem, wg *sync.WaitGroup) (*dynamodb.PutItemOutput, error)
	UpdateDynamo(ID, status, data string, history *dynamoEntyty.HistoryItem) (*dynamodb.UpdateItemOutput, error)
	GetDynamoData(ID string) (*dynamodb.GetItemOutput, error)
	GetDynamoHistory(receiverAddress string) (*dynamodb.ScanOutput, error)

	// kinesis
	WaitUntil(*kinesis.DescribeStreamInput) error
	WaitUntilNotExist(data *kinesis.DescribeStreamInput) error
	SendStart(ID string, itemDynamo *dynamoEntyty.DynamoItem, stack string, wg *sync.WaitGroup)
	Send(data []byte, stack string, wg *sync.WaitGroup) (*kinesis.PutRecordOutput, error)
	GetShardIterator() (string, error)
	Consumer(data *kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)
	GetDescribeInput() *kinesis.DescribeStreamInput
	Describe(data *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
}

AwsInterface ...