awsinteg

package
v0.0.0-...-44b4573 Latest Latest
Warning

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

Go to latest
Published: Mar 31, 2024 License: MPL-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

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