operator

Documentation

Overview

Quartermaster framework

Index

• Constants
• func GetStorageNodeSpecHash(sp spec.StorageNodeSpec) uint32
• func ListOptions(name string) api.ListOptions
• func NewQuartermasterRESTClient(c restclient.Config) (*restclient.RESTClient, error)
• func NewStorageClusterListWatch(client *restclient.RESTClient) *cache.ListWatch
• func NewStorageNodeListWatch(client *restclient.RESTClient) *cache.ListWatch
• func PodRunningAndReady(pod v1.Pod) (bool, error)
• func WaitForDeploymentReady(client kubernetes.Interface, namespace, name string, available int32) error
• func WaitForTPRReady(restClient restclient.Interface, tprGroup, tprVersion, tprName string) error
• type Config
• type Operator
  • func New(c Config, storageFuns ...qmstorage.StorageTypeNewFunc) (*Operator, error)
  • func (c *Operator) GetRESTClient() *restclient.RESTClient
  • func (c *Operator) GetStorage(name spec.StorageTypeIdentifier) (qmstorage.StorageType, error)
  • func (c *Operator) Run(stopc <-chan struct{}) error
• type StorageClusterOperator
  • func (s *StorageClusterOperator) HasSynced() bool
  • func (s *StorageClusterOperator) Setup(stopc <-chan struct{}) error
• type StorageOperator
  • func NewStorageClusterOperator(op *Operator) StorageOperator

Constants

const (
	TPRGroup   = "storage.coreos.com"
	TPRVersion = "v1alpha1"

	TPRStorageNodeKind    = "storagenode"
	TPRStorageStatusKind  = "storagestatus"
	TPRStorageClusterKind = "storagecluster"

	PluralTPRStorageNodeKind    = TPRStorageNodeKind + "s"
	PluralTPRStorageStatusKind  = TPRStorageStatusKind + "es"
	PluralTPRStorageClusterKind = TPRStorageClusterKind + "s"
)

Functions

func GetStorageNodeSpecHash

func GetStorageNodeSpecHash(sp spec.StorageNodeSpec) uint32

func ListOptions

func ListOptions(name string) api.ListOptions

func NewQuartermasterRESTClient

func NewQuartermasterRESTClient(c restclient.Config) (*restclient.RESTClient, error)

func NewStorageClusterListWatch

func NewStorageClusterListWatch(client *restclient.RESTClient) *cache.ListWatch

NewStorageClusterListWatch returns a new ListWatch on the StorageCluster resource.

func NewStorageNodeListWatch

func NewStorageNodeListWatch(client *restclient.RESTClient) *cache.ListWatch

NewStorageNodeListWatch returns a new ListWatch on the StorageNode resource.

func PodRunningAndReady

func PodRunningAndReady(pod v1.Pod) (bool, error)

PodRunningAndReady returns whether a pod is running and each container has passed it's ready state.

func WaitForDeploymentReady

func WaitForDeploymentReady(client kubernetes.Interface, namespace, name string, available int32) error

func WaitForTPRReady

func WaitForTPRReady(restClient restclient.Interface, tprGroup, tprVersion, tprName string) error

WaitForTPRReady waits for a third party resource to be available for use.

Types

type Config

type Config struct {
	Host        string
	TLSInsecure bool
	TLSConfig   restclient.TLSClientConfig
	Kubeconfig  string
	MasterUrl   string
}

Config defines configuration parameters for the Operator.

type Operator

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

func New

func New(c Config, storageFuns ...qmstorage.StorageTypeNewFunc) (*Operator, error)

New creates a new controller.

func (*Operator) GetRESTClient

func (c *Operator) GetRESTClient() *restclient.RESTClient

func (*Operator) GetStorage

func (c *Operator) GetStorage(name spec.StorageTypeIdentifier) (qmstorage.StorageType, error)

func (*Operator) Run

func (c *Operator) Run(stopc <-chan struct{}) error

Run the controller.

type StorageClusterOperator

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

func (*StorageClusterOperator) HasSynced

func (s *StorageClusterOperator) HasSynced() bool

func (*StorageClusterOperator) Setup

func (s *StorageClusterOperator) Setup(stopc <-chan struct{}) error

type StorageOperator

type StorageOperator interface {
	Setup(stopc <-chan struct{}) error
	HasSynced() bool
}

func NewStorageClusterOperator

func NewStorageClusterOperator(op *Operator) StorageOperator