Documentation
¶
Index ¶
- Constants
- type CleanupService
- func (cs *CleanupService) DeleteOrphanedAnalyticsWorkload(name string) error
- func (cs *CleanupService) DeleteOrphanedAnalyticsWorkloads(userId string, authToken string) (workloads []lib.Workload, err error)
- func (cs *CleanupService) DeleteOrphanedKafkaTopic(topic string) error
- func (cs *CleanupService) DeleteOrphanedKafkaTopics() (err error)
- func (cs *CleanupService) DeleteOrphanedKubeService(collection string, id string) error
- func (cs *CleanupService) DeleteOrphanedKubeServices(collection string) (deletedKubeServices []lib.KubeService, err error)
- func (cs *CleanupService) DeleteOrphanedPipelineService(id string, accessToken string) error
- func (cs *CleanupService) DeleteOrphanedPipelineServices(userId string, authToken string) (pipes []pipeModels.Pipeline, err error)
- func (cs *CleanupService) GetDeleteOrphanedKafkaTopicsStatus() lib.DeleteStatus
- func (cs *CleanupService) GetOrphanedAnalyticsWorkloads(userId string, authToken string) (orphanedAnalyticsWorkloads []lib.Workload, err error)
- func (cs *CleanupService) GetOrphanedKafkaTopics() (orphanedKafkaTopics []string, err error)
- func (cs *CleanupService) GetOrphanedKubeServices(collection string) (orphanedServices []lib.KubeService, err error)
- func (cs *CleanupService) GetOrphanedPipelineServices(userId string, authToken string) (orphanedPipelineWorkloads []pipeModels.Pipeline, err error)
- func (cs *CleanupService) StartCleanupService(recreatePipes bool) (err error)
- func (cs *CleanupService) StopDeleteOrphanedKafkaTopics() (err error)
- type Driver
Constants ¶
View Source
const DividerString = "++++++++++++++++++++++++++++++++++++++++++++++++++++++++"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CleanupService ¶
type CleanupService struct {
// contains filtered or unexported fields
}
func NewCleanupService ¶
func NewCleanupService(keycloak apis.KeycloakService, driver Driver, pipeline apis.PipelineService, logger util.FileLogger, kafkaAdmin *apis.KafkaAdmin, ctx context.Context) *CleanupService
func (*CleanupService) DeleteOrphanedAnalyticsWorkload ¶
func (cs *CleanupService) DeleteOrphanedAnalyticsWorkload(name string) error
func (*CleanupService) DeleteOrphanedAnalyticsWorkloads ¶
func (*CleanupService) DeleteOrphanedKafkaTopic ¶
func (cs *CleanupService) DeleteOrphanedKafkaTopic(topic string) error
func (*CleanupService) DeleteOrphanedKafkaTopics ¶
func (cs *CleanupService) DeleteOrphanedKafkaTopics() (err error)
func (*CleanupService) DeleteOrphanedKubeService ¶
func (cs *CleanupService) DeleteOrphanedKubeService(collection string, id string) error
func (*CleanupService) DeleteOrphanedKubeServices ¶
func (cs *CleanupService) DeleteOrphanedKubeServices(collection string) (deletedKubeServices []lib.KubeService, err error)
func (*CleanupService) DeleteOrphanedPipelineService ¶
func (cs *CleanupService) DeleteOrphanedPipelineService(id string, accessToken string) error
func (*CleanupService) DeleteOrphanedPipelineServices ¶
func (cs *CleanupService) DeleteOrphanedPipelineServices(userId string, authToken string) (pipes []pipeModels.Pipeline, err error)
func (*CleanupService) GetDeleteOrphanedKafkaTopicsStatus ¶
func (cs *CleanupService) GetDeleteOrphanedKafkaTopicsStatus() lib.DeleteStatus
func (*CleanupService) GetOrphanedAnalyticsWorkloads ¶
func (*CleanupService) GetOrphanedKafkaTopics ¶
func (cs *CleanupService) GetOrphanedKafkaTopics() (orphanedKafkaTopics []string, err error)
func (*CleanupService) GetOrphanedKubeServices ¶
func (cs *CleanupService) GetOrphanedKubeServices(collection string) (orphanedServices []lib.KubeService, err error)
func (*CleanupService) GetOrphanedPipelineServices ¶
func (cs *CleanupService) GetOrphanedPipelineServices(userId string, authToken string) (orphanedPipelineWorkloads []pipeModels.Pipeline, err error)
func (*CleanupService) StartCleanupService ¶
func (cs *CleanupService) StartCleanupService(recreatePipes bool) (err error)
func (*CleanupService) StopDeleteOrphanedKafkaTopics ¶
func (cs *CleanupService) StopDeleteOrphanedKafkaTopics() (err error)
type Driver ¶
type Driver interface {
GetServices(collection string) (services []lib.KubeService, err error)
GetWorkloads(collection string) (workloads []lib.Workload, err error)
GetWorkloadEnvs(collection string) (envs []map[string]string, err error)
DeleteWorkload(id string, collection string) error
DeleteService(id string, collection string) error
}
Source Files
Click to show internal directories.
Click to hide internal directories.