qcat

package module
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2018 License: MIT Imports: 15 Imported by: 0

README

qcat GoDoc

A utility for publishing and consuming data from an AMQP message broker

Documentation

Index

Constants

View Source 
const Version = `1.0.1`

Variables

View Source 
var DefaultQueueName = `qcat`
View Source 
var DefaultServerAddress = `:17684`

Functions

This section is empty.

Types

type AmqpClient 

type AmqpClient struct {
	ID           string
	Host         string
	Port         int
	Username     string
	Password     string
	Vhost        string
	ExchangeName string
	RoutingKey   string
	QueueName    string
	Durable      bool
	Autodelete   bool
	Exclusive    bool
	Mandatory    bool
	Immediate    bool
	// contains filtered or unexported fields
}

func NewAmqpClient 

func NewAmqpClient(uri string) (*AmqpClient, error)

func (*AmqpClient) Close 

func (self *AmqpClient) Close() error

func (*AmqpClient) Connect 

func (self *AmqpClient) Connect() error

func (*AmqpClient) Err added in v1.0.1 

func (self *AmqpClient) Err() <-chan error

Receive a single error.

func (*AmqpClient) Publish 

func (self *AmqpClient) Publish(data []byte, header MessageHeader) error

Publish a single message.

func (*AmqpClient) PublishLines added in v1.0.1 

func (self *AmqpClient) PublishLines(reader io.Reader, header MessageHeader) error

Publish messages read from the given reader, separated by newlines ("\n").

func (*AmqpClient) Receive added in v1.0.1 

func (self *AmqpClient) Receive() <-chan *Message

Receive a single message.

func (*AmqpClient) Subscribe 

func (self *AmqpClient) Subscribe() error

Receive a message from the channel.

func (*AmqpClient) SubscribeRaw 

func (self *AmqpClient) SubscribeRaw() (<-chan amqp.Delivery, error)

type DeliveryMode added in v1.0.1 

type DeliveryMode int
const (
	Transient DeliveryMode = iota
	Persistent
)

type HttpServer 

type HttpServer struct {
	BaseHeader MessageHeader
	// contains filtered or unexported fields
}

func NewHttpServer 

func NewHttpServer(amqpClient *AmqpClient) *HttpServer

func (*HttpServer) ListenAndServe 

func (self *HttpServer) ListenAndServe(address string) error

func (*HttpServer) Respond 

func (self *HttpServer) Respond(w http.ResponseWriter, code int, payload interface{}, err error)

func (*HttpServer) ServeHTTP 

func (self *HttpServer) ServeHTTP(w http.ResponseWriter, req *http.Request)

type Message added in v1.0.1 

type Message struct {
	Timestamp time.Time
	Header    MessageHeader
	Body      []byte
}

func (*Message) Decode added in v1.0.1 

func (self *Message) Decode(into interface{}) error

type MessageHeader 

type MessageHeader struct {
	ContentType     string
	ContentEncoding string
	DeliveryMode    DeliveryMode
	Priority        int
	Expiration      time.Duration
}

Source Files

View all Source files

Directories

Path Synopsis
cmd
qcat command

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.