makeless_go_queue_amazon_sqs

package module
v1.0.0-beta.23 Latest Latest
Warning

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

Go to latest
Published: Jan 15, 2021 License: MIT Imports: 7 Imported by: 0

README

Makeless - Queue Amazon SQS

Makeless - SaaS Framework - Golang Queue Amazon SQS Implementation

Build Status

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Node

type Node struct {
	Data          []byte
	ReceiptHandle string

	*sync.RWMutex
	// contains filtered or unexported fields
}

func (*Node) GetData

func (node *Node) GetData() []byte

func (*Node) GetNext

func (node *Node) GetNext() makeless_go_queue.Node

func (*Node) GetReceiptHandle

func (node *Node) GetReceiptHandle() string

func (*Node) SetNext

func (node *Node) SetNext(next makeless_go_queue.Node)

type Queue

type Queue struct {
	Context context.Context
	Queue   string
	Config  aws.Config

	*sync.RWMutex
	// contains filtered or unexported fields
}

func (*Queue) Add

func (queue *Queue) Add(node makeless_go_queue.Node) error

func (*Queue) Delete

func (queue *Queue) Delete(node *Node) error

func (*Queue) Empty

func (queue *Queue) Empty() (bool, error)

func (*Queue) GetConfig

func (queue *Queue) GetConfig() aws.Config

func (*Queue) GetContext

func (queue *Queue) GetContext() context.Context

func (*Queue) GetQueue

func (queue *Queue) GetQueue() string

func (*Queue) Init

func (queue *Queue) Init() error

func (*Queue) Remove

func (queue *Queue) Remove() (makeless_go_queue.Node, error)

Jump to

Keyboard shortcuts

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