deployer

Documentation

Index

• Variables
• type AppDeployer
• type Deployer
  • func NewDeployer(cluster *config.UserContext, secretSyncer *configsyncer.SecretManager) *Deployer
  • func (d *Deployer) ClusterLoggingSync(key string, obj *mgmtv3.ClusterLogging) (runtime.Object, error)
  • func (d *Deployer) ProjectLoggingSync(key string, obj *mgmtv3.ProjectLogging) (runtime.Object, error)
• type LoggingService
  • func NewService() *LoggingService
  • func (l *LoggingService) Init(cluster *config.UserContext)
  • func (l *LoggingService) Upgrade(currentVersion string) (string, error)
  • func (l *LoggingService) Version() (string, error)
• type TesterDeployer
  • func NewTesterDeployer(appsGetter projectv3.AppsGetter, projectLister mgmtv3.ProjectLister, ...) *TesterDeployer
  • func (d *TesterDeployer) Deploy(level, clusterName, projectID string, loggingTarget mgmtv3.LoggingTargets) error

Variables

var (
	ServiceName = "logging"
)

Types

type AppDeployer

type AppDeployer struct {
	AppsGetter projectv3.AppsGetter
	Namespaces v1.NamespaceInterface
	Pods       v1.PodInterface
}

type Deployer

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

func NewDeployer

func NewDeployer(cluster *config.UserContext, secretSyncer *configsyncer.SecretManager) *Deployer

func (*Deployer) ClusterLoggingSync

func (d *Deployer) ClusterLoggingSync(key string, obj *mgmtv3.ClusterLogging) (runtime.Object, error)

func (*Deployer) ProjectLoggingSync

func (d *Deployer) ProjectLoggingSync(key string, obj *mgmtv3.ProjectLogging) (runtime.Object, error)

type LoggingService

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

func NewService

func NewService() *LoggingService

func (*LoggingService) Init

func (l *LoggingService) Init(cluster *config.UserContext)

func (*LoggingService) Upgrade

func (l *LoggingService) Upgrade(currentVersion string) (string, error)

func (*LoggingService) Version

func (l *LoggingService) Version() (string, error)

type TesterDeployer

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

func NewTesterDeployer

func NewTesterDeployer(appsGetter projectv3.AppsGetter, projectLister mgmtv3.ProjectLister, pods v1.PodInterface, projectLoggingLister mgmtv3.ProjectLoggingLister, namespaces v1.NamespaceInterface, templateLister mgmtv3.CatalogTemplateLister) *TesterDeployer

func (*TesterDeployer) Deploy

func (d *TesterDeployer) Deploy(level, clusterName, projectID string, loggingTarget mgmtv3.LoggingTargets) error