pubsub

Documentation

Index

• 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 SubHandler
• type Subscriber
  • func NewSubscriber(impl gobroker.Implementation, handlers []*SubHandler, options ...Option) Subscriber

Types

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(topic string, message interface{}) error
}

Publisher provides adapter to publish message

func NewPublisher

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

NewPublisher implements adapter instance for Publisher

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 implements adapter instance for Subscriber