Documentation
¶
Index ¶
Constants ¶
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 CappResourceKey = "rcs.dana.io/parent-capp"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FlowManager ¶ added in v0.1.2
type FlowManager struct {
Ctx context.Context
K8sclient client.Client
Log logr.Logger
EventRecorder record.EventRecorder
}
func (FlowManager) CleanUp ¶ added in v0.1.2
func (f FlowManager) CleanUp(capp rcsv1alpha1.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 ¶ added in v0.1.2
func (f FlowManager) CreateOrUpdateObject(capp rcsv1alpha1.Capp) error
CreateOrUpdateObject creates or updates a flow object based on the provided capp. It returns an error if any operation fails.
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 rcsv1alpha1.Capp) error
func (KnativeDomainMappingManager) CreateOrUpdateObject ¶
func (k KnativeDomainMappingManager) CreateOrUpdateObject(capp rcsv1alpha1.Capp) error
func (KnativeDomainMappingManager) HandleIrrelevantDomainMapping ¶
func (k KnativeDomainMappingManager) HandleIrrelevantDomainMapping(capp rcsv1alpha1.Capp) error
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 rcsv1alpha1.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 rcsv1alpha1.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.
type OutputManager ¶ added in v0.1.2
type OutputManager struct {
Ctx context.Context
K8sclient client.Client
Log logr.Logger
EventRecorder record.EventRecorder
}
func (OutputManager) CleanUp ¶ added in v0.1.2
func (o OutputManager) CleanUp(capp rcsv1alpha1.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 ¶ added in v0.1.2
func (o OutputManager) CreateOrUpdateObject(capp rcsv1alpha1.Capp) error
CreateOrUpdateObject creates or updates an output object based on the provided capp. It returns an error if any operation fails.
type ResourceManager ¶
type ResourceManager interface {
CreateOrUpdateObject(capp rcsv1alpha1.Capp) error
CleanUp(capp rcsv1alpha1.Capp) error
// contains filtered or unexported methods
}
Source Files