awsinteg

Documentation

Index

• type KinesisHoseClient
  • func NewKinesisHoseClient() (*KinesisHoseClient, error)
  • func (hoseClient *KinesisHoseClient) PutRecord(ctx context.Context, streamName string, recordData []byte) error
• type S3Client
  • func NewS3Client() (*S3Client, error)
  • func (s3Client *S3Client) Upload(ctx context.Context, bucketName, objectKey string, objectValue io.Reader) error
• type SNSClient
  • func NewSNSClient() (*SNSClient, error)
  • func (snsClient *SNSClient) Publish(ctx context.Context, topicARN, text string) error
• type SQSClient
  • func NewSQSClient() (*SQSClient, error)
  • func (sqsClient *SQSClient) SendMessage(ctx context.Context, queueURL, text string) error

Types

type KinesisHoseClient

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

func NewKinesisHoseClient

func NewKinesisHoseClient() (*KinesisHoseClient, error)

func (*KinesisHoseClient) PutRecord

func (hoseClient *KinesisHoseClient) PutRecord(ctx context.Context, streamName string, recordData []byte) error

type S3Client

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

func NewS3Client

func NewS3Client() (*S3Client, error)

func (*S3Client) Upload

func (s3Client *S3Client) Upload(ctx context.Context, bucketName, objectKey string, objectValue io.Reader) error

type SNSClient

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

func NewSNSClient

func NewSNSClient() (*SNSClient, error)

func (*SNSClient) Publish

func (snsClient *SNSClient) Publish(ctx context.Context, topicARN, text string) error

type SQSClient

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

func NewSQSClient

func NewSQSClient() (*SQSClient, error)

func (*SQSClient) SendMessage

func (sqsClient *SQSClient) SendMessage(ctx context.Context, queueURL, text string) error