resourceprepares

Documentation

Index

• Constants
• type FlowManager
  • func (f FlowManager) CleanUp(capp cappv1alpha1.Capp) error
  • func (f FlowManager) CreateOrUpdateObject(capp cappv1alpha1.Capp) error
  • func (f FlowManager) IsRequired(capp cappv1alpha1.Capp) bool
• type KnativeDomainMappingManager
  • func (k KnativeDomainMappingManager) CleanUp(capp cappv1alpha1.Capp) error
  • func (k KnativeDomainMappingManager) CreateOrUpdateObject(capp cappv1alpha1.Capp) error
  • func (k KnativeDomainMappingManager) HandleIrrelevantDomainMapping(capp cappv1alpha1.Capp) error
  • func (k KnativeDomainMappingManager) IsRequired(capp cappv1alpha1.Capp) bool
• type KnativeServiceManager
  • func (k KnativeServiceManager) CleanUp(capp cappv1alpha1.Capp) error
  • func (k KnativeServiceManager) CreateOrUpdateObject(capp cappv1alpha1.Capp) error
  • func (k KnativeServiceManager) IsRequired(capp cappv1alpha1.Capp) bool
• type NFSPVCManager
  • func (n NFSPVCManager) CleanUp(capp cappv1alpha1.Capp) error
  • func (n NFSPVCManager) CreateOrUpdateObject(capp cappv1alpha1.Capp) error
  • func (n NFSPVCManager) IsRequired(capp cappv1alpha1.Capp) bool
• type OutputManager
  • func (o OutputManager) CleanUp(capp cappv1alpha1.Capp) error
  • func (o OutputManager) CreateOrUpdateObject(capp cappv1alpha1.Capp) error
  • func (o OutputManager) IsRequired(capp cappv1alpha1.Capp) bool
• type ResourceManager

Constants

const (
	DefaultAutoScaleCM = "autoscale-defaults"
	CappNS             = "capp-operator-system"
)

const (
	LogTypeElastic       string = "elastic"
	LogTypeSplunk        string = "splunk"
	KnativeConfiguration        = "serving.knative.dev/configuration"
	NginxPraser                 = "nginx"
	ElasticPort                 = 9200
	SplunkHecPort               = 8088
	ElasticSSLVersion           = "TLSv1_2"
	BufferTimekey               = "1m"
	BufferTimekeyWait           = "30s"
	BufferTimekeyUseUtc         = true
)

const (
	DomainMapping  = "domainMapping"
	KnativeServing = "knativeServing"
	Flow           = "flow"
	Output         = "output"
	NFSPVC         = "NfsPvc"
)

const (
	CappResourceKey = "rcs.dana.io/parent-capp"
)

Types

type FlowManager

type FlowManager struct {
	Ctx           context.Context
	K8sclient     client.Client
	Log           logr.Logger
	EventRecorder record.EventRecorder
}

func (FlowManager) CleanUp

func (f FlowManager) CleanUp(capp cappv1alpha1.Capp) error

CleanUp deletes the flow resource associated with the Capp object. The flow resource is deleted by calling the DeleteResource method of the resourceManager object.

func (FlowManager) CreateOrUpdateObject

func (f FlowManager) CreateOrUpdateObject(capp cappv1alpha1.Capp) error

CreateOrUpdateObject creates or updates a flow object based on the provided capp. It returns an error if any operation fails.

func (FlowManager) IsRequired

func (f FlowManager) IsRequired(capp cappv1alpha1.Capp) bool

IsRequired is responsible to determine if resource logging operator flow is required.

type KnativeDomainMappingManager

type KnativeDomainMappingManager struct {
	Ctx           context.Context
	K8sclient     client.Client
	Log           logr.Logger
	EventRecorder record.EventRecorder
}

func (KnativeDomainMappingManager) CleanUp

func (k KnativeDomainMappingManager) CleanUp(capp cappv1alpha1.Capp) error

func (KnativeDomainMappingManager) CreateOrUpdateObject

func (k KnativeDomainMappingManager) CreateOrUpdateObject(capp cappv1alpha1.Capp) error

func (KnativeDomainMappingManager) HandleIrrelevantDomainMapping

func (k KnativeDomainMappingManager) HandleIrrelevantDomainMapping(capp cappv1alpha1.Capp) error

func (KnativeDomainMappingManager) IsRequired

func (k KnativeDomainMappingManager) IsRequired(capp cappv1alpha1.Capp) bool

IsRequired is responsible to determine if resource knative domain mapping is required.

type KnativeServiceManager

type KnativeServiceManager struct {
	Ctx           context.Context
	K8sclient     client.Client
	Log           logr.Logger
	EventRecorder record.EventRecorder
}

func (KnativeServiceManager) CleanUp

func (k KnativeServiceManager) CleanUp(capp cappv1alpha1.Capp) error

CleanUp attempts to delete the associated KnativeService for a given Capp resource. If the KnativeService is not found, the function completes without error. If any other errors occur during the deletion process, an error detailing the issue is returned.

func (KnativeServiceManager) CreateOrUpdateObject

func (k KnativeServiceManager) CreateOrUpdateObject(capp cappv1alpha1.Capp) error

CreateOrUpdateObject ensures a KnativeService resource exists based on the provided Capp. If the Capp doesn't require a KnativeService, it triggers a cleanup. Otherwise, it either creates a new KnativeService or updates an existing one based on the Capp's specifications.

func (KnativeServiceManager) IsRequired

func (k KnativeServiceManager) IsRequired(capp cappv1alpha1.Capp) bool

IsRequired determines if a Knative service (ksvc) is required based on the Capp's spec.

type NFSPVCManager

type NFSPVCManager struct {
	Ctx           context.Context
	K8sclient     client.Client
	Log           logr.Logger
	EventRecorder record.EventRecorder
}

func (NFSPVCManager) CleanUp

func (n NFSPVCManager) CleanUp(capp cappv1alpha1.Capp) error

CleanUp deletes the NFSPVC resource associated with the Capp object. The NFSPVC resource is deleted by calling the DeleteResource method of the resourceManager object.

func (NFSPVCManager) CreateOrUpdateObject

func (n NFSPVCManager) CreateOrUpdateObject(capp cappv1alpha1.Capp) error

CreateOrUpdateObject creates or updates a nfspvc object based on the provided capp. It returns an error if any operation fails.

func (NFSPVCManager) IsRequired

func (n NFSPVCManager) IsRequired(capp cappv1alpha1.Capp) bool

IsRequired is responsible to determine if resource NfsPvc is required.

type OutputManager

type OutputManager struct {
	Ctx           context.Context
	K8sclient     client.Client
	Log           logr.Logger
	EventRecorder record.EventRecorder
}

func (OutputManager) CleanUp

func (o OutputManager) CleanUp(capp cappv1alpha1.Capp) error

CleanUp deletes the output resource associated with the Capp object. The output resource is deleted by calling the DeleteResource method of the resourceManager object.

func (OutputManager) CreateOrUpdateObject

func (o OutputManager) CreateOrUpdateObject(capp cappv1alpha1.Capp) error

CreateOrUpdateObject creates or updates an output object based on the provided Capp. It returns an error if any operation fails.

func (OutputManager) IsRequired

func (o OutputManager) IsRequired(capp cappv1alpha1.Capp) bool

IsRequired is responsible to determine if resource logging operator is required.

type ResourceManager

type ResourceManager interface {
	CreateOrUpdateObject(capp cappv1alpha1.Capp) error
	CleanUp(capp cappv1alpha1.Capp) error
	IsRequired(capp cappv1alpha1.Capp) bool
}