gf_aws

package

v0.0.0-...-a1b0e2b Latest Latest Go to latest Published: Apr 26, 2024 License: GPL-2.0 Imports: 25 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gloflow/gloflow

Links

Open Source Insights

Documentation ¶

Index ¶

func AWSsecretsMngrCreateSecret(pSecretNameStr string, pDataMap map[string]interface{}, pDescriptionStr string, ...) *gf_core.GFerror
func AWSsecretsMngrGetSecret(pSecretNameStr string, pRuntimeSys *gf_core.RuntimeSys) (map[string]interface{}, *gf_core.GFerror)
func EC2describeInstancesByTags(p_tags_lst []map[string]string, pRuntimeSys *gf_core.RuntimeSys) ([]*ec2.Instance, *gf_core.GFerror)
func EC2getInfoOnAutoscalingGroup(pAutscalingGroupNameStr string, pRuntimeSys *gf_core.RuntimeSys) (int, *gf_core.GFerror)
func EC2scaleAutoscalingGroup(pAutscalingGroupNameStr string, pDesiredCapacityInt int, ...) *gf_core.GFerror
func ECSupdateService(pServiceNameStr string, pClusterNameStr string, pHealthyPercentMinInt int, ...) *gf_core.GFerror
func S3copyFile(pSourceBucketStr string, pSourceFileS3pathStr string, ...) *gf_core.GFerror
func S3generatePresignedUploadURL(pTargetFileS3pathStr string, pS3bucketNameStr string, pS3info *GFs3Info, ...) (string, *gf_core.GFerror)
func S3getFile(pTargetFileS3pathStr string, pTargetFileLocalPathStr string, ...) *gf_core.GFerror
func S3putFile(pTargetFileLocalPathStr string, pTargetFileS3pathStr string, ...) (string, *gf_core.GFerror)
func SESsendMessage(pRecipiendAddressStr string, pSenderAddressStr string, pSubjectStr string, ...) *gf_core.GFerror
func SESverifyAddress(pRecipiendAddressStr string, pRuntimeSys *gf_core.RuntimeSys) *gf_core.GFerror
func SQSinit(pRuntimeSys *gf_core.RuntimeSys) (*sqs.Client, *gf_core.GFerror)
func SQSmsgPull(pQueueInfo *GF_SQS_queue, pAWSclient *sqs.Client, pCtx context.Context, ...) (map[string]interface{}, *gf_core.GFerror)
func SQSmsgPush(p_msg interface{}, pQueueInfo *GF_SQS_queue, pAWSclient *sqs.Client, ...) *gf_core.GFerror
func SQSqueueDelete(pSQSqueueNameStr string, pAWSclient *sqs.Client, pCtx context.Context, ...) *gf_core.GFerror
func SQSqueueGetURL(pSQSqueueNameStr string, pSQSclient *sqs.Client, pCtx context.Context, ...) (string, *gf_core.GFerror)
type GF_SQS_queue
- func SQSgetQueueInfo(pSQSqueueNameStr string, pSQSclient *sqs.Client, pCtx context.Context, ...) (*GF_SQS_queue, *gf_core.GFerror)
- func SQSqueueCreate(pSQSqueueNameStr string, pSQSclient *sqs.Client, pCtx context.Context, ...) (*GF_SQS_queue, *gf_core.GFerror)
type GFs3Info
- func S3init(pRuntimeSys *gf_core.RuntimeSys) (*GFs3Info, *gf_core.GFerror)
type GFs3TestInfo
- func TgetS3info(pRuntimeSys *gf_core.RuntimeSys) *GFs3TestInfo

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AWSsecretsMngrCreateSecret ¶

func AWSsecretsMngrCreateSecret(pSecretNameStr string,
	pDataMap map[string]interface{},
	pDescriptionStr string,
	pRuntimeSys *gf_core.RuntimeSys) *gf_core.GFerror

func AWSsecretsMngrGetSecret ¶

func AWSsecretsMngrGetSecret(pSecretNameStr string,
	pRuntimeSys *gf_core.RuntimeSys) (map[string]interface{}, *gf_core.GFerror)

func EC2describeInstancesByTags ¶

func EC2describeInstancesByTags(p_tags_lst []map[string]string,
	pRuntimeSys *gf_core.RuntimeSys) ([]*ec2.Instance, *gf_core.GFerror)

func EC2getInfoOnAutoscalingGroup ¶

func EC2getInfoOnAutoscalingGroup(pAutscalingGroupNameStr string,
	pRuntimeSys *gf_core.RuntimeSys) (int, *gf_core.GFerror)

func EC2scaleAutoscalingGroup ¶

func EC2scaleAutoscalingGroup(pAutscalingGroupNameStr string,
	pDesiredCapacityInt int,
	pRuntimeSys *gf_core.RuntimeSys) *gf_core.GFerror

func ECSupdateService ¶

func ECSupdateService(pServiceNameStr string,
	pClusterNameStr string,
	pHealthyPercentMinInt int,
	pRuntimeSys *gf_core.RuntimeSys) *gf_core.GFerror

func S3copyFile ¶

func S3copyFile(pSourceBucketStr string,
	pSourceFileS3pathStr string,
	pTargetBucketNameStr string,
	pTargetFileS3pathStr string,
	pS3info *GFs3Info,
	pRuntimeSys *gf_core.RuntimeSys) *gf_core.GFerror

func S3generatePresignedUploadURL ¶

func S3generatePresignedUploadURL(pTargetFileS3pathStr string,
	pS3bucketNameStr string,
	pS3info *GFs3Info,
	pRuntimeSys *gf_core.RuntimeSys) (string, *gf_core.GFerror)

func S3getFile ¶

func S3getFile(pTargetFileS3pathStr string,
	pTargetFileLocalPathStr string,
	pS3bucketNameStr string,
	pS3info *GFs3Info,
	pRuntimeSys *gf_core.RuntimeSys) *gf_core.GFerror

func S3putFile ¶

func S3putFile(pTargetFileLocalPathStr string,
	pTargetFileS3pathStr string,
	pS3bucketNameStr string,
	pS3info *GFs3Info,
	pRuntimeSys *gf_core.RuntimeSys) (string, *gf_core.GFerror)

func SESsendMessage ¶

func SESsendMessage(pRecipiendAddressStr string,
	pSenderAddressStr string,
	pSubjectStr string,
	pHTMLbodyStr string,
	pTextBodyStr string,
	pRuntimeSys *gf_core.RuntimeSys) *gf_core.GFerror

func SESverifyAddress ¶

func SESverifyAddress(pRecipiendAddressStr string,
	pRuntimeSys *gf_core.RuntimeSys) *gf_core.GFerror

func SQSinit ¶

func SQSinit(pRuntimeSys *gf_core.RuntimeSys) (*sqs.Client, *gf_core.GFerror)

func SQSmsgPull ¶

func SQSmsgPull(pQueueInfo *GF_SQS_queue,
	pAWSclient *sqs.Client,
	pCtx context.Context,
	pRuntimeSys *gf_core.RuntimeSys) (map[string]interface{}, *gf_core.GFerror)

func SQSmsgPush ¶

func SQSmsgPush(p_msg interface{},
	pQueueInfo *GF_SQS_queue,
	pAWSclient *sqs.Client,
	pCtx context.Context,
	pRuntimeSys *gf_core.RuntimeSys) *gf_core.GFerror

func SQSqueueDelete ¶

func SQSqueueDelete(pSQSqueueNameStr string,
	pAWSclient *sqs.Client,
	pCtx context.Context,
	pRuntimeSys *gf_core.RuntimeSys) *gf_core.GFerror

func SQSqueueGetURL ¶

func SQSqueueGetURL(pSQSqueueNameStr string,
	pSQSclient *sqs.Client,
	pCtx context.Context,
	pRuntimeSys *gf_core.RuntimeSys) (string, *gf_core.GFerror)

Types ¶

type GF_SQS_queue ¶

type GF_SQS_queue struct {
	Name_str    string
	AWS_url_str string
}

func SQSgetQueueInfo ¶

func SQSgetQueueInfo(pSQSqueueNameStr string,
	pSQSclient *sqs.Client,
	pCtx context.Context,
	pRuntimeSys *gf_core.RuntimeSys) (*GF_SQS_queue, *gf_core.GFerror)

func SQSqueueCreate ¶

func SQSqueueCreate(pSQSqueueNameStr string,
	pSQSclient *sqs.Client,
	pCtx context.Context,
	pRuntimeSys *gf_core.RuntimeSys) (*GF_SQS_queue, *gf_core.GFerror)

type GFs3Info ¶

type GFs3Info struct {
	Client   *s3.S3
	Uploader *s3manager.Uploader
	Session  *session.Session
}

func S3init ¶

func S3init(pRuntimeSys *gf_core.RuntimeSys) (*GFs3Info, *gf_core.GFerror)

type GFs3TestInfo ¶

type GFs3TestInfo struct {
	GFs3Info *GFs3Info
}

func TgetS3info ¶

func TgetS3info(pRuntimeSys *gf_core.RuntimeSys) *GFs3TestInfo

Source Files ¶

View all Source files

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