qcat

package module
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2020 License: MIT Imports: 19 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.1.0`

Variables

View Source 
var DefaultConnectTimeout = 5 * time.Second
View Source 
var DefaultQueueName = `qcat`
View Source 
var DefaultServerAddress = `:17684`

Functions

This section is empty.

Types

type AMQP added in v1.0.2 

type AMQP struct {
	ID                string
	Host              string
	Port              int
	Username          string
	Password          string
	ConnectTimeout    time.Duration
	HeartbeatInterval time.Duration
	TLS               *tls.Config
	Vhost             string
	ExchangeName      string
	RoutingKey        string
	QueueName         string
	Durable           bool
	Autodelete        bool
	Exclusive         bool
	Mandatory         bool
	Immediate         bool
	AutoAck           bool
	Prefetch          int
	PrefetchBytes     int
	PrefetchGlobal    bool
	Headers           map[string]interface{}
	ClientProperties  map[string]interface{}
	// contains filtered or unexported fields
}

func NewAMQP added in v1.0.2 

func NewAMQP(uri string) (*AMQP, error)

func (*AMQP) Acknowledge added in v1.0.9 

func (self *AMQP) Acknowledge(tag uint64) error

Acknowledge a message by its Delivery tag

func (*AMQP) Close added in v1.0.2 

func (self *AMQP) Close() error

func (*AMQP) Connect added in v1.0.2 

func (self *AMQP) Connect() error

func (*AMQP) Err added in v1.0.2 

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

Receive a single error.

func (*AMQP) Publish added in v1.0.2 

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

Publish a single message.

func (*AMQP) PublishJSON added in v1.0.6 

func (self *AMQP) PublishJSON(body interface{}, header MessageHeader) error

Publish a single message serialized as JSON.

func (*AMQP) PublishLines added in v1.0.2 

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

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

func (*AMQP) Receive added in v1.0.2 

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

Receive a single message.

func (*AMQP) Reject added in v1.0.9 

func (self *AMQP) Reject(tag uint64) error

Reject a message by its Delivery tag

func (*AMQP) Requeue added in v1.0.9 

func (self *AMQP) Requeue(tag uint64) error

Requeue a message by its Delivery tag

func (*AMQP) Subscribe added in v1.0.2 

func (self *AMQP) Subscribe() error

Receive a message from the channel.

func (*AMQP) SubscribeRaw added in v1.0.2 

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

type DeliveryMode added in v1.0.1 

type DeliveryMode int
const (
	Transient  DeliveryMode = 1
	Persistent              = 2
)

type HttpServer 

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

func NewHttpServer 

func NewHttpServer(amqpClient *AMQP) *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
	// contains filtered or unexported fields
}

func (*Message) Acknowledge added in v1.0.5 

func (self *Message) Acknowledge(multiple ...bool) error

Acknowledge the successful processing of a message.

func (*Message) Decode added in v1.0.1 

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

func (*Message) DeliveryTag added in v1.0.9 

func (self *Message) DeliveryTag() uint64

func (*Message) ID added in v1.0.9 

func (self *Message) ID() string

func (*Message) Reject added in v1.0.5 

func (self *Message) Reject(multiple ...bool) error

Reject a message, but don't requeue it.

func (*Message) Requeue added in v1.0.5 

func (self *Message) Requeue(multiple ...bool) error

Reject a message and requeue it.

func (*Message) ShouldAck added in v1.0.5 

func (self *Message) ShouldAck() bool

type MessageHeader 

type MessageHeader struct {
	ID              string
	ContentType     string
	ContentEncoding string
	DeliveryMode    DeliveryMode
	Priority        int
	Expiration      time.Duration
	Headers         map[string]interface{}
}

Source Files

View all Source files

Directories

Path Synopsis
cmd
qcat

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.