subscribe

Documentation

Index

• func Subscribe(host string, messages chan<- []string, done <-chan bool, keepTrying bool, ...) error
• type HostMessage
• type Subscription
  • func SubscribeMulti(hosts, topics []string, quorum ...int) (*Subscription, error)
  • func (subs *Subscription) Close()
  • func (subs *Subscription) WaitForPattern(pattern []string, timeout time.Duration, quorum ...int) bool
  • func (subs *Subscription) WaitForPatterns(patterns [][]string, timeout time.Duration, quorum ...int) bool

Functions

func Subscribe

func Subscribe(host string, messages chan<- []string, done <-chan bool, keepTrying bool, topics ...string) error

Types

type HostMessage

type HostMessage struct {
	Sender  string
	Message []string
}

type Subscription

type Subscription struct {
	Hosts        []string
	Topics       []string
	HostMessages chan *HostMessage
	// contains filtered or unexported fields
}

func SubscribeMulti

func SubscribeMulti(hosts, topics []string, quorum ...int) (*Subscription, error)

func (*Subscription) Close

func (subs *Subscription) Close()

func (*Subscription) WaitForPattern

func (subs *Subscription) WaitForPattern(pattern []string, timeout time.Duration, quorum ...int) bool

func (*Subscription) WaitForPatterns

func (subs *Subscription) WaitForPatterns(patterns [][]string, timeout time.Duration, quorum ...int) bool

WaitForPatterns waits until subscription receives all patterns from quorum of hosts