cloud

package

v1.0.4 Latest Latest Go to latest Published: Feb 9, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sturdy-dev/sturdy

Links

Open Source Insights

Documentation ¶

Index ¶

func Module(c *di.Container)
func New(awsSession *session.Session, logger *zap.Logger, cfg *Configuration) (queue.Queue, error)
func NewSQS(logger *zap.Logger, awsSession *session.Session, hostname string, ...) (*sqsQueue, error)
func Sub(awsSession *session.Session, logger *zap.Logger, queueName names.QueueName, ...) error
func SubToBroadcast(awsSession *session.Session, logger *zap.Logger, ...) error
type Configuration
type PolicyDocument
type StatementEntry

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Module ¶

func Module(c *di.Container)

func New ¶

func New(awsSession *session.Session, logger *zap.Logger, cfg *Configuration) (queue.Queue, error)

func NewSQS ¶

func NewSQS(
	logger *zap.Logger,
	awsSession *session.Session,
	hostname string,
	queuePrefix string,
) (*sqsQueue, error)

func Sub ¶

func Sub(awsSession *session.Session, logger *zap.Logger, queueName names.QueueName, output chan queue.Message) error

func SubToBroadcast ¶

func SubToBroadcast(awsSession *session.Session, logger *zap.Logger, queueName names.BroadcastQueueSubscriberName, snsTopicArn string, output chan queue.Message) error

Types ¶

type Configuration ¶

type Configuration struct {
	Local    bool   `long:"local" description:"Use in-memory queue instead of SQS"`
	Hostname string `long:"hostname" description:"Hostname of the queue"`
	Prefix   string `long:"prefix" description:"Prefix for queue names"`
}

type PolicyDocument ¶

type PolicyDocument struct {
	Version   string
	Statement []StatementEntry
}

type StatementEntry ¶

type StatementEntry struct {
	Effect    string
	Principal map[string]string
	Action    []string
	Resource  string
	Condition map[string]map[string]string `json:"Condition,omitempty"`
}

Source Files ¶

View all Source files

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