aws

package
v0.0.0-...-3997d68 Latest Latest
Warning

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

 Go to latest Published: Feb 23, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AWS 

type AWS struct {
	AccountId string
	Config    *AWSConfig
}

func NewAWS 

func NewAWS(config *AWSConfig) (aws *AWS)

func (*AWS) GetAccountId 

func (a *AWS) GetAccountId() string

func (*AWS) GetSession 

func (a *AWS) GetSession() *session.Session

type AWSConfig 

type AWSConfig struct {
	AwsRegion          string
	AwsAccessKeyId     string
	AwsSecretAccessKey string
	AwsSessionToken    string
}

type SNS 

type SNS struct {
	Name   string
	AWS    *AWS
	Client *sns.SNS
	Errors chan error
}

func NewSNS 

func NewSNS(name string, aws *AWS) *SNS

func (*SNS) Ack 

func (s *SNS) Ack(message *brk.Message) error

func (*SNS) Connect 

func (s *SNS) Connect(chan error) bool

func (*SNS) GetName 

func (s *SNS) GetName() string

func (*SNS) Publish 

func (s *SNS) Publish(
	target string, message *brk.Message, options map[string]interface{},
) (string, error)

func (*SNS) Subscribe 

func (s *SNS) Subscribe(ctx context.Context, source string, chErr chan error) <-chan brk.Message

func (*SNS) ToTopicArn 

func (s *SNS) ToTopicArn(topic string) string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.