Documentation
¶
Overview ¶
Package kubernetes defines the kubernetes discovery provider
Index ¶
- Constants
- type Discovery
- func (d *Discovery) Close() error
- func (d *Discovery) Deregister() error
- func (d *Discovery) DiscoverNodes() ([]*discovery.Node, error)
- func (d *Discovery) ID() string
- func (d *Discovery) Initialize() error
- func (d *Discovery) Register() error
- func (d *Discovery) SetConfig(meta discovery.Options) error
- func (d *Discovery) Watch(ctx context.Context) (<-chan discovery.Event, error)
Constants ¶
View Source
const ( Namespace string = "namespace" // Namespace specifies the kubernetes namespace ApplicationName = "app_name" // ApplicationName specifies the application name. GroupCachePortName = "group-port" // GroupCachePortName specifies the group cache port name )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Discovery ¶
type Discovery struct {
// contains filtered or unexported fields
}
Discovery represents the kubernetes discovery
func NewDiscovery ¶
func NewDiscovery() *Discovery
NewDiscovery returns an instance of the kubernetes discovery provider
func (*Discovery) Deregister ¶
Deregister removes this node from a service discovery directory.
func (*Discovery) DiscoverNodes ¶
DiscoverNodes returns a list of known nodes.
func (*Discovery) Initialize ¶
Initialize initializes the plugin: registers some internal data structures, clients etc.
Source Files
Click to show internal directories.
Click to hide internal directories.