edswatch

package
v0.0.0-...-f3d1372 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 3, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ServiceWatch

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

ServiceWatch runs consul watch for the specified service

func NewWatch

func NewWatch(agentHost string, service eds.Endpoint, hub pubsub.Hub) (*ServiceWatch, error)

NewWatch creates a new service watch

func (*ServiceWatch) PublishCLA

func (sw *ServiceWatch) PublishCLA(idx uint64, data interface{})

PublishCLA publishes a cluster load assignment to hub

func (ServiceWatch) Run

func (sw ServiceWatch) Run(errorChannel chan error)

Run consul watch for the specified service

func (ServiceWatch) Stop

func (sw ServiceWatch) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL