gq

README

=====
gq
=====

Message queue for experiments written in Go.

Documentation

Index

• type ConsumerMessage
• type MQ
• type Message
• type Receipt

Types

type ConsumerMessage

type ConsumerMessage struct {
	Message
	Id int64
}

ConsumerMessage message for a consumer

type MQ

type MQ interface {
	// Initialization
	Create() error
	// Destruction
	Destroy() error
	// Simple send message
	Publish(messages []*Message) error
	// Request a batch of messages
	ConsumeBatch(size int) ([]*ConsumerMessage, error)
	// Way to consume a stream of messages
	Stream(size int, messages chan []*ConsumerMessage, pause time.Duration)
	// End the stream
	StopConsumer()
	// Commit that a messages has been processed
	Commit(recipts []*Receipt) error
}

MQ Implemented message queue interface

type Message

type Message struct {
	Payload []byte
}

Message minimal message definition

type Receipt

type Receipt struct {
	Id      int64
	Success bool
}

Receipt to commit