broker

Documentation

Index

• type CoordClientBrokerWrapper
  • func NewCoordClientWrapper(coordClient coordinating.CoordClient) CoordClientBrokerWrapper
  • func (t CoordClientBrokerWrapper) AddBroker(host string) error
  • func (t CoordClientBrokerWrapper) GetBroker(name string) (string, error)
  • func (t CoordClientBrokerWrapper) GetBrokers() ([]string, error)
  • func (t CoordClientBrokerWrapper) WatchBrokersPathChanged(ctx context.Context) (chan []string, error)

Types

type CoordClientBrokerWrapper

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

func NewCoordClientWrapper

func NewCoordClientWrapper(coordClient coordinating.CoordClient) CoordClientBrokerWrapper

func (CoordClientBrokerWrapper) AddBroker

func (t CoordClientBrokerWrapper) AddBroker(host string) error

func (CoordClientBrokerWrapper) GetBroker

func (t CoordClientBrokerWrapper) GetBroker(name string) (string, error)

func (CoordClientBrokerWrapper) GetBrokers

func (t CoordClientBrokerWrapper) GetBrokers() ([]string, error)

func (CoordClientBrokerWrapper) WatchBrokersPathChanged

func (t CoordClientBrokerWrapper) WatchBrokersPathChanged(ctx context.Context) (chan []string, error)

WatchBrokersPathChanged : register a watcher on children changed and retrieve updated brokers