amqp

package

v0.0.0-...-1d26606 Latest Latest Go to latest Published: Dec 11, 2022 License: MIT Imports: 10 Imported by: 0

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/teamnsrg/mida

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DecodeAMQPMessageToRawTask(delivery amqp.Delivery) (b.RawTask, error)
func LoadSummaryPost(summary b.TaskSummary, params ConnParams, queue string, priority uint8) error
func LoadTasks(tasks b.TaskSet, params ConnParams, queue string, priority uint8, shuffle bool) (int, error)
type ConnParams
type Consumer
- func NewAMQPBroadcastConsumer(params ConnParams, queue string) (*Consumer, <-chan amqp.Delivery, error)
- func NewAMQPTasksConsumer(params ConnParams, queue string) (*Consumer, <-chan amqp.Delivery, error)
- func (c *Consumer) Shutdown() error

Constants ¶

View Source

const (
	DefaultTls               = false // Whether to use TLS connection by default
	DefaultPort              = 5672
	DefaultPriority          = 5 // Default priority of tasks loaded into queue
	DefaultTaskQueue         = "mida-tasks"
	DefaultBroadcastExchange = "mida-broadcast"
	DefaultPostQueue         = "mida-complete"
)

Variables ¶

This section is empty.

Functions ¶

func DecodeAMQPMessageToRawTask ¶

func DecodeAMQPMessageToRawTask(delivery amqp.Delivery) (b.RawTask, error)

Takes an AMQP message (which is expected to be a MIDATask, in JSON format) and converts it into an actual MIDATask struct

func LoadSummaryPost ¶

func LoadSummaryPost(summary b.TaskSummary, params ConnParams, queue string, priority uint8) error

LoadSummaryPost loads task summary data into AMQP queue. Creates and tears down a new connections each time.

func LoadTasks ¶

func LoadTasks(tasks b.TaskSet, params ConnParams, queue string, priority uint8, shuffle bool) (int, error)

LoadTasks handles loading MIDA tasks in to AMQP (probably RabbitMQ) queue.

Types ¶

type ConnParams ¶

type ConnParams struct {
	User string
	Pass string
	Uri  string
}

type Consumer ¶

type Consumer struct {
	// contains filtered or unexported fields
}

func NewAMQPBroadcastConsumer ¶

func NewAMQPBroadcastConsumer(params ConnParams, queue string) (*Consumer, <-chan amqp.Delivery, error)

NewAMQPControlConsumer connects to a AMQP which will be used for control messages rather than tasks

func NewAMQPTasksConsumer ¶

func NewAMQPTasksConsumer(params ConnParams, queue string) (*Consumer, <-chan amqp.Delivery, error)

func (*Consumer) Shutdown ¶

func (c *Consumer) Shutdown() error

Graceful shutdown of a connection to AMQP

Source Files ¶

View all Source files

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