publisher

Documentation

Index

• type Publisher
  • func NewPublisher(etcdHost string, etcdPort int, etcdPath string, publishInterval int, ...) (*Publisher, error)
  • func (p *Publisher) Start()

Types

type Publisher

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

Publisher takes responsibility for regularly updating etcd with the host and port where this logger component is running. This permits other components to discover it.

func NewPublisher

func NewPublisher(etcdHost string, etcdPort int, etcdPath string, publishInterval int,
	publishTTL int, logHost string, logPort int) (*Publisher, error)

NewPublisher returns a pointer to a new Publisher instance.

func (*Publisher) Start

func (p *Publisher) Start()

Start begins the publisher's main loop.