argo

Documentation

Overview

This file is part of kuberpult.

Kuberpult is free software: you can redistribute it and/or modify it under the terms of the Expat(MIT) License as published by the Free Software Foundation.

Kuberpult is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the MIT License for more details.

You should have received a copy of the MIT License along with kuberpult. If not, see <https://directory.fsf.org/wiki/License:Expat>.

Copyright 2023 freiheit.com

Index

• func CreateArgoApplication(overview *api.GetOverviewResponse, app *api.Environment_Application, ...) *v1alpha1.Application
• type ArgoAppProcessor
  • func New(appClient application.ApplicationServiceClient, ...) ArgoAppProcessor
  • func (a *ArgoAppProcessor) Consume(ctx context.Context, hlth *setup.HealthReporter) error
  • func (a *ArgoAppProcessor) ConsumeArgo(ctx context.Context, hlth *setup.HealthReporter) error
  • func (a ArgoAppProcessor) CreateOrUpdateApp(ctx context.Context, overview *api.GetOverviewResponse, ...)
  • func (a ArgoAppProcessor) DeleteArgoApps(ctx context.Context, argoApps map[string]*v1alpha1.Application, ...) error
  • func (a *ArgoAppProcessor) Push(ctx context.Context, last *api.GetOverviewResponse)
• type Key
• type SimplifiedApplicationServiceClient

Functions

func CreateArgoApplication

func CreateArgoApplication(overview *api.GetOverviewResponse, app *api.Environment_Application, env *api.Environment) *v1alpha1.Application

Types

type ArgoAppProcessor

type ArgoAppProcessor struct {
	ApplicationClient     application.ApplicationServiceClient
	ManageArgoAppsEnabled bool
	ManageArgoAppsFilter  []string
	// contains filtered or unexported fields
}

func New

func New(appClient application.ApplicationServiceClient, manageArgoApplicationEnabled bool, manageArgoApplicationFilter []string) ArgoAppProcessor

func (*ArgoAppProcessor) Consume

func (a *ArgoAppProcessor) Consume(ctx context.Context, hlth *setup.HealthReporter) error

func (*ArgoAppProcessor) ConsumeArgo

func (a *ArgoAppProcessor) ConsumeArgo(ctx context.Context, hlth *setup.HealthReporter) error

func (ArgoAppProcessor) CreateOrUpdateApp

func (a ArgoAppProcessor) CreateOrUpdateApp(ctx context.Context, overview *api.GetOverviewResponse, app *api.Environment_Application, env *api.Environment, appsKnownToArgo map[string]*v1alpha1.Application)

func (ArgoAppProcessor) DeleteArgoApps

func (a ArgoAppProcessor) DeleteArgoApps(ctx context.Context, argoApps map[string]*v1alpha1.Application, apps map[string]*api.Environment_Application) error

func (*ArgoAppProcessor) Push

func (a *ArgoAppProcessor) Push(ctx context.Context, last *api.GetOverviewResponse)

type Key

type Key struct {
	AppName     string
	EnvName     string
	Application *api.Environment_Application
	Environment *api.Environment
}

type SimplifiedApplicationServiceClient

type SimplifiedApplicationServiceClient interface {
	Watch(ctx context.Context, qry *application.ApplicationQuery, opts ...grpc.CallOption) (application.ApplicationService_WatchClient, error)
}

this is a simpler version of ApplicationServiceClient from the application package