pubsub

Documentation

Index

• type Future
• type GPSFuture
  • func (g *GPSFuture) Wait() error
• type NSQFuture
  • func (n *NSQFuture) Wait() error
• type Option
  • func ContentType(name string, codec gobroker.Codec) Option
  • func GoogleJSON(projectID, cluster string, cred []byte) Option
  • func GoogleJSONFile(projectID, cluster, filename string) Option
  • func MaxReconnect(retry int) Option
  • func NSQLookupd(address string) Option
  • func RabbitMQAMQP(server, vHost string) Option
• type Publisher
  • func NewPublisher(impl gobroker.Implementation, options ...Option) Publisher
• type RMQFuture
  • func (r *RMQFuture) Wait() error
• type SubHandler
• type Subscriber
  • func NewSubscriber(impl gobroker.Implementation, handlers []*SubHandler, options ...Option) Subscriber

Types

type Future

type Future interface {
	// Wait waits the broker to ack, will return error from the broker after sent the message if any.
	Wait() error
}

type GPSFuture

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

func (*GPSFuture) Wait

func (g *GPSFuture) Wait() error

type NSQFuture

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

func (*NSQFuture) Wait

func (n *NSQFuture) Wait() error

type Option

type Option func(c *config)

Option configures Publisher & Subscriber

func ContentType

func ContentType(name string, codec gobroker.Codec) Option

ContentType configures custom content-type for message body along with its codec

func GoogleJSON

func GoogleJSON(projectID, cluster string, cred []byte) Option

GoogleJSON configures Publisher & Subscriber for Google Cloud Pub/Sub auth using JSON bytes

func GoogleJSONFile

func GoogleJSONFile(projectID, cluster, filename string) Option

GoogleJSONFile configures Publisher & Subscriber for Google Cloud Pub/Sub auth using JSON filename

func MaxReconnect

func MaxReconnect(retry int) Option

MaxReconnect defines retry attempts to reconnect, 0 means unlimited retry

func NSQLookupd

func NSQLookupd(address string) Option

func RabbitMQAMQP

func RabbitMQAMQP(server, vHost string) Option

RabbitMQAMQP configures Publisher & Subscriber for RabbitMQ connection

type Publisher

type Publisher interface {
	// Publish publishes a message to a worker pool and might block for broker ack.
	Publish(topic string, message interface{}) error
	// PublishAsync publishes a message to a worker pool without waiting for broker ack.
	PublishAsync(topic string, message interface{}) Future
}

Publisher provides adapter to publish message

func NewPublisher

func NewPublisher(impl gobroker.Implementation, options ...Option) Publisher

NewPublisher returns the publisher instance based on the desired implementation

type RMQFuture

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

func (*RMQFuture) Wait

func (r *RMQFuture) Wait() error

type SubHandler

type SubHandler struct {
	Name        string
	Topic       string
	Handler     gobroker.Handler
	Concurrent  int
	MaxRequeue  int
	MaxInFlight int

	// Timeout configures an in-flight message ack deadline processed by subscriber
	Timeout time.Duration
}

SubHandler defines subscriber configuration

type Subscriber

type Subscriber interface {
	// Start will spawn workers to subscribe
	Start()
	// Stop will terminate all connections and workers
	Stop()
}

Subscriber provides adapter to subscribe topics

func NewSubscriber

func NewSubscriber(impl gobroker.Implementation, handlers []*SubHandler, options ...Option) Subscriber

NewSubscriber returns the subscriber instance based on the desired implementation