Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EqualCheckpoints ¶
func EqualCheckpoints(a, b Checkpoint) bool
EqualCheckpoints compares two Checkpoints for equality, if their underlying objects are equal, so are the Checkpoints
func EqualRemoteConfigSources ¶
func EqualRemoteConfigSources(a, b RemoteConfigSource) bool
EqualRemoteConfigSources is a helper for comparing remote config sources by comparing the underlying API objects for semantic equality.
Types ¶
type Checkpoint ¶
type Checkpoint interface {
// UID returns the UID of the config source object behind the Checkpoint
UID() string
// Parse extracts the KubeletConfiguration from the checkpoint, applies defaults, and converts to the internal type
Parse() (*kubeletconfig.KubeletConfiguration, error)
// Encode returns a []byte representation of the config source object behind the Checkpoint
Encode() ([]byte, error)
// contains filtered or unexported methods
}
Checkpoint represents a local copy of a config source (payload) object
func DecodeCheckpoint ¶
func DecodeCheckpoint(data []byte) (Checkpoint, error)
DecodeCheckpoint is a helper for using the apimachinery to decode serialized checkpoints
func NewConfigMapCheckpoint ¶
func NewConfigMapCheckpoint(cm *apiv1.ConfigMap) (Checkpoint, error)
NewConfigMapCheckpoint returns a Checkpoint backed by `cm`. `cm` must be non-nil and have a non-empty ObjectMeta.UID, or an error will be returned.
type RemoteConfigSource ¶
type RemoteConfigSource interface {
// UID returns the UID of the remote config source object
UID() string
// Download downloads the remote config source object returns a Checkpoint backed by the object,
// or a sanitized failure reason and error if the download fails
Download(client clientset.Interface) (Checkpoint, string, error)
// Encode returns a []byte representation of the object behind the RemoteConfigSource
Encode() ([]byte, error)
// contains filtered or unexported methods
}
RemoteConfigSource represents a remote config source object that can be downloaded as a Checkpoint
func DecodeRemoteConfigSource ¶
func DecodeRemoteConfigSource(data []byte) (RemoteConfigSource, error)
DecodeRemoteConfigSource is a helper for using the apimachinery to decode serialized RemoteConfigSources; e.g. the objects stored in the .cur and .lkg files by checkpoint/store/fsstore.go
func NewRemoteConfigSource ¶
func NewRemoteConfigSource(source *apiv1.NodeConfigSource) (RemoteConfigSource, string, error)
NewRemoteConfigSource constructs a RemoteConfigSource from a v1/NodeConfigSource object, or returns a sanitized failure reason and an error if the `source` is blatantly invalid. You should only call this with a non-nil config source.
Source Files
Directories