fixed

Documentation

Index

• type Publisher
  • func NewPublisher(endpoints []endpoint.Endpoint) *Publisher
  • func (p *Publisher) Endpoints() ([]endpoint.Endpoint, error)
  • func (p *Publisher) Replace(endpoints []endpoint.Endpoint)

Types

type Publisher

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

Publisher yields the same set of fixed endpoints.

func NewPublisher

func NewPublisher(endpoints []endpoint.Endpoint) *Publisher

NewPublisher returns a fixed endpoint Publisher.

func (*Publisher) Endpoints

func (p *Publisher) Endpoints() ([]endpoint.Endpoint, error)

Endpoints implements the Publisher interface.

func (*Publisher) Replace

func (p *Publisher) Replace(endpoints []endpoint.Endpoint)

Replace is a utility method to swap out the underlying endpoints of an existing fixed publisher. It's useful mostly for testing.