Documentation ¶
Index ¶
- Variables
- func NewRegistryStorage(m Registry) apiserver.RESTStorage
- type CachingRegistry
- type Clock
- type CloudRegistry
- type HealthyRegistry
- type Registry
- type RegistryStorage
- func (rs *RegistryStorage) Create(obj interface{}) (<-chan interface{}, error)
- func (rs *RegistryStorage) Delete(id string) (<-chan interface{}, error)
- func (rs *RegistryStorage) Get(id string) (interface{}, error)
- func (rs *RegistryStorage) List(selector labels.Selector) (interface{}, error)
- func (rs RegistryStorage) New() interface{}
- func (rs *RegistryStorage) Update(minion interface{}) (<-chan interface{}, error)
- type SystemClock
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrDoesNotExist = fmt.Errorf("The requested resource does not exist.")
Functions ¶
func NewRegistryStorage ¶
func NewRegistryStorage(m Registry) apiserver.RESTStorage
NewRegistryStorage returns a new RegistryStorage.
Types ¶
type CachingRegistry ¶
type CachingRegistry struct {
// contains filtered or unexported fields
}
func (*CachingRegistry) Delete ¶
func (r *CachingRegistry) Delete(minion string) error
func (*CachingRegistry) Insert ¶
func (r *CachingRegistry) Insert(minion string) error
func (*CachingRegistry) List ¶
func (r *CachingRegistry) List() ([]string, error)
type CloudRegistry ¶
type CloudRegistry struct {
// contains filtered or unexported fields
}
func NewCloudRegistry ¶
func NewCloudRegistry(cloud cloudprovider.Interface, matchRE string) (*CloudRegistry, error)
func (CloudRegistry) Delete ¶
func (r CloudRegistry) Delete(minion string) error
func (CloudRegistry) Insert ¶
func (r CloudRegistry) Insert(minion string) error
func (*CloudRegistry) List ¶
func (r *CloudRegistry) List() ([]string, error)
type HealthyRegistry ¶
type HealthyRegistry struct {
// contains filtered or unexported fields
}
func (*HealthyRegistry) Delete ¶
func (r *HealthyRegistry) Delete(minion string) error
func (*HealthyRegistry) Insert ¶
func (r *HealthyRegistry) Insert(minion string) error
func (*HealthyRegistry) List ¶
func (r *HealthyRegistry) List() (currentMinions []string, err error)
type Registry ¶
type Registry interface { List() (currentMinions []string, err error) Insert(minion string) error Delete(minion string) error Contains(minion string) (bool, error) }
Keep track of a set of minions. Safe for concurrent reading/writing.
func NewCachingRegistry ¶
func NewRegistry ¶
Initialize a minion registry with a list of minions.
type RegistryStorage ¶
type RegistryStorage struct {
// contains filtered or unexported fields
}
RegistryStorage implements the RESTStorage interface, backed by a MinionRegistry.
func (*RegistryStorage) Create ¶
func (rs *RegistryStorage) Create(obj interface{}) (<-chan interface{}, error)
func (*RegistryStorage) Delete ¶
func (rs *RegistryStorage) Delete(id string) (<-chan interface{}, error)
func (*RegistryStorage) Get ¶
func (rs *RegistryStorage) Get(id string) (interface{}, error)
func (*RegistryStorage) List ¶
func (rs *RegistryStorage) List(selector labels.Selector) (interface{}, error)
func (RegistryStorage) New ¶
func (rs RegistryStorage) New() interface{}
func (*RegistryStorage) Update ¶
func (rs *RegistryStorage) Update(minion interface{}) (<-chan interface{}, error)
type SystemClock ¶
type SystemClock struct{}
func (SystemClock) Now ¶
func (SystemClock) Now() time.Time
Click to show internal directories.
Click to hide internal directories.