Documentation ¶
Index ¶
- Constants
- type TokenDiscoveryService
- func (s *TokenDiscoveryService) CreateCluster() (string, error)
- func (s *TokenDiscoveryService) Fetch() ([]*discovery.Node, error)
- func (s *TokenDiscoveryService) Initialize(urltoken string, heartbeat int) error
- func (s *TokenDiscoveryService) Register(addr string) error
- func (s *TokenDiscoveryService) Watch(callback discovery.WatchCallback)
Constants ¶
View Source
const DISCOVERY_URL = "https://discovery-stage.hub.docker.com/v1"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TokenDiscoveryService ¶
type TokenDiscoveryService struct {
// contains filtered or unexported fields
}
func (*TokenDiscoveryService) CreateCluster ¶
func (s *TokenDiscoveryService) CreateCluster() (string, error)
CreateCluster returns a unique cluster token
func (*TokenDiscoveryService) Fetch ¶
func (s *TokenDiscoveryService) Fetch() ([]*discovery.Node, error)
FetchNodes returns the node for the discovery service at the specified endpoint
func (*TokenDiscoveryService) Initialize ¶
func (s *TokenDiscoveryService) Initialize(urltoken string, heartbeat int) error
func (*TokenDiscoveryService) Register ¶
func (s *TokenDiscoveryService) Register(addr string) error
RegisterNode adds a new node identified by the into the discovery service
func (*TokenDiscoveryService) Watch ¶
func (s *TokenDiscoveryService) Watch(callback discovery.WatchCallback)
Click to show internal directories.
Click to hide internal directories.