queue

package module
v0.0.0-...-37e8840 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2020 License: MIT Imports: 4 Imported by: 0

README

Queue Build Status godoc reference

Unified queue interface for several different backing technologies.

  • SQS (Amazon SQS backed store; production ready)
  • File (uses a local file for queue; intended for dev only)
  • Local (uses a memory based queue; intended for dev only)

Usage and Examples

go get -u gopkg.in/kyani-inc/queue.v1

You can write your application to use the queue interface and then choose which backing technology to use based on environment needs. For example, you could use SQS for a production sytem and Local for your development environment.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Queue 

type Queue interface {
	Next(queue string) (messageID, result string, err error)
	Append(queue, msg string) error
	Complete(queue, messageID string) error
}

func File 

func File(path string) Queue

func Local 

func Local() Queue

func SQS 

func SQS(secret, access, url, region string, messageTimeout int) Queue

func SQSNoCreds 

func SQSNoCreds(url, region string, messageTimeout int) Queue

func SQSWithSession 

func SQSWithSession(url, region string, timeout int, sess *session.Session) Queue

SQSWithSession returns an instance of SQS using a passed session

Source Files

View all Source files

Directories

Path Synopsis

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.