operator

Documentation

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 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) 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 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
}

Config defines configuration parameters for the Operator.

type Operator

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

Operator manages lify cycle of Prometheus deployments and monitoring configurations.

func New

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

New creates a new controller.

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