autodetect

Documentation

Index

• Variables
• func AvailableAPIs(discovery discovery.DiscoveryInterface, groups map[string]bool) ([]*metav1.APIResourceList, error)
• func IsElasticsearchOperatorAvailable(apiList []*metav1.APIResourceList) bool
• type AuthDelegatorAvailability
  • func (p AuthDelegatorAvailability) String() string
• type Background
  • func New(mgr manager.Manager) (*Background, error)
  • func WithClients(cl client.Client, dcl discovery.DiscoveryInterface, clr client.Reader) *Background
  • func (b *Background) Start()
  • func (b *Background) Stop()
• type ESOperatorIntegration
  • func (p ESOperatorIntegration) String() string
• type KafkaOperatorIntegration
  • func (p KafkaOperatorIntegration) String() string
• type Platform
  • func (p Platform) String() string

Variables

var OperatorConfiguration operatorConfigurationWrapper

Functions

func AvailableAPIs

func AvailableAPIs(discovery discovery.DiscoveryInterface, groups map[string]bool) ([]*metav1.APIResourceList, error)

AvailableAPIs returns available list of CRDs from the cluster.

func IsElasticsearchOperatorAvailable

func IsElasticsearchOperatorAvailable(apiList []*metav1.APIResourceList) bool

IsElasticsearchOperatorAvailable returns true if OpenShift Elasticsearch CRD is available in the cluster.

Types

type AuthDelegatorAvailability

type AuthDelegatorAvailability int

AuthDelegatorAvailability holds the if the AuthDelegator available.

const (
	// AuthDelegatorAvailabilityYes represents the AuthDelegator is available.
	AuthDelegatorAvailabilityYes AuthDelegatorAvailability = iota

	// AuthDelegatorAvailabilityNo represents the AuthDelegator is not available.
	AuthDelegatorAvailabilityNo

	// AuthDelegatorAvailabilityUnknown represents the AuthDelegator availability is not known.
	AuthDelegatorAvailabilityUnknown
)

func (AuthDelegatorAvailability) String

func (p AuthDelegatorAvailability) String() string

type Background

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

Background represents a procedure that runs in the background, periodically auto-detecting features

func New

func New(mgr manager.Manager) (*Background, error)

New creates a new auto-detect runner

func WithClients

func WithClients(cl client.Client, dcl discovery.DiscoveryInterface, clr client.Reader) *Background

WithClients builds a new Background with the provided clients

func (*Background) Start

func (b *Background) Start()

Start initializes the auto-detection process that runs in the background

func (*Background) Stop

func (b *Background) Stop()

Stop causes the background process to stop auto detecting capabilities

type ESOperatorIntegration

type ESOperatorIntegration int

ESOperatorIntegration holds the if the ES Operator integration is enabled.

const (
	// ESOperatorIntegrationYes represents the ES Operator integration is enabled.
	ESOperatorIntegrationYes ESOperatorIntegration = iota

	// ESOperatorIntegrationNo represents the ES Operator integration is disabled.
	ESOperatorIntegrationNo
)

func (ESOperatorIntegration) String

func (p ESOperatorIntegration) String() string

type KafkaOperatorIntegration

type KafkaOperatorIntegration int

KafkaOperatorIntegration holds the if the Kafka Operator integration is enabled.

const (
	// KafkaOperatorIntegrationYes represents the Kafka Operator integration is enabled.
	KafkaOperatorIntegrationYes KafkaOperatorIntegration = iota

	// KafkaOperatorIntegrationNo represents the Kafka Operator integration is disabled.
	KafkaOperatorIntegrationNo
)

func (KafkaOperatorIntegration) String

func (p KafkaOperatorIntegration) String() string

type Platform

type Platform int

Platform holds the auto-detected running platform.

const (
	// KubernetesPlatform represents the cluster is Kubernetes.
	KubernetesPlatform Platform = iota

	// OpenShiftPlatform represents the cluster is OpenShift.
	OpenShiftPlatform
)

func (Platform) String

func (p Platform) String() string