process

Documentation

Index

• Constants
• type CleanUpStep
  • func NewCleanUp(p *Process) CleanUpStep
  • func (s CleanUpStep) Do() error
  • func (s CleanUpStep) ToString() string
• type Clients
• type ConvertTriggersToKymaSubscriptions
  • func NewConvertTriggersToKymaSubscriptions(p *Process) ConvertTriggersToKymaSubscriptions
  • func (s ConvertTriggersToKymaSubscriptions) Do() error
  • func (s ConvertTriggersToKymaSubscriptions) NewSubscription(trigger *eventingv1alpha1.Trigger) *kymaeventingv1alpha1.Subscription
  • func (s ConvertTriggersToKymaSubscriptions) ToString() string
• type Data
• type DeleteAppSubscriptions
  • func NewDeleteAppSubscriptions(p *Process) DeleteAppSubscriptions
  • func (s DeleteAppSubscriptions) Do() error
  • func (s DeleteAppSubscriptions) ToString() string
• type DeleteBrokers
  • func NewDeleteBrokers(p *Process) DeleteBrokers
  • func (s DeleteBrokers) Do() error
  • func (s DeleteBrokers) ToString() string
• type DeleteEventServiceDeployments
  • func NewDeleteEventServiceDeployments(p *Process) DeleteEventServiceDeployments
  • func (s DeleteEventServiceDeployments) Do() error
  • func (s DeleteEventServiceDeployments) ToString() string
• type DeleteEventSources
  • func NewDeleteEventSources(p *Process) DeleteEventSources
  • func (s DeleteEventSources) Do() error
  • func (s DeleteEventSources) ToString() string
• type DeleteTriggers
  • func NewDeleteTriggers(p *Process) DeleteTriggers
  • func (s DeleteTriggers) Do() error
  • func (s DeleteTriggers) ToString() string
• type E2ESetup
• type Metadata
• type PatchConnectivityValidators
  • func NewPatchConnectivityValidators(p *Process) PatchConnectivityValidators
  • func (s PatchConnectivityValidators) Do() error
  • func (s PatchConnectivityValidators) ToString() string
• type PatchDeploymentSpec
• type PatchLabels
• type Process
  • func (p *Process) AddSteps()
  • func (p Process) Execute() error
• type SaveCurrentState
  • func NewSaveCurrentState(p *Process) SaveCurrentState
  • func (s SaveCurrentState) Do() error
  • func (s SaveCurrentState) ToString() string
• type Spec
• type State
• type Step
• type Template
• type TemplateSpec
• type UnLabelNamespace
  • func NewUnLabelNamespace(p *Process) UnLabelNamespace
  • func (s UnLabelNamespace) Do() error
  • func (s UnLabelNamespace) ToString() string

Constants

const (
	BackedUpConfigMapName      = "eventing-post-upgrade-backed-up-data"
	BackedUpConfigMapNamespace = "kyma-system"
	KymaIntegrationNamespace   = "kyma-integration"
)

Types

type CleanUpStep

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

func NewCleanUp

func NewCleanUp(p *Process) CleanUpStep

func (CleanUpStep) Do

func (s CleanUpStep) Do() error

func (CleanUpStep) ToString

func (s CleanUpStep) ToString() string

type Clients

type Clients struct {
	Trigger          trigger.Client
	Broker           broker.Client
	Subscription     subscription.Client
	Channel          channel.Client
	Application      application.Client
	Deployment       deployment.Client
	ConfigMap        configmap.Client
	HttpSource       httpsource.Client
	Namespace        namespace.Client
	KymaSubscription kymasubscription.Client
}

type ConvertTriggersToKymaSubscriptions

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

func NewConvertTriggersToKymaSubscriptions

func NewConvertTriggersToKymaSubscriptions(p *Process) ConvertTriggersToKymaSubscriptions

func (ConvertTriggersToKymaSubscriptions) Do

func (s ConvertTriggersToKymaSubscriptions) Do() error

func (ConvertTriggersToKymaSubscriptions) NewSubscription

func (s ConvertTriggersToKymaSubscriptions) NewSubscription(trigger *eventingv1alpha1.Trigger) *kymaeventingv1alpha1.Subscription

func (ConvertTriggersToKymaSubscriptions) ToString

func (s ConvertTriggersToKymaSubscriptions) ToString() string

type Data

type Data struct {
	Triggers               runtime.RawExtension
	Subscriptions          runtime.RawExtension
	Channels               runtime.RawExtension
	ConnectivityValidators runtime.RawExtension
	EventServices          runtime.RawExtension
	Namespaces             runtime.RawExtension
}

type DeleteAppSubscriptions

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

func NewDeleteAppSubscriptions

func NewDeleteAppSubscriptions(p *Process) DeleteAppSubscriptions

func (DeleteAppSubscriptions) Do

func (s DeleteAppSubscriptions) Do() error

func (DeleteAppSubscriptions) ToString

func (s DeleteAppSubscriptions) ToString() string

type DeleteBrokers

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

func NewDeleteBrokers

func NewDeleteBrokers(p *Process) DeleteBrokers

func (DeleteBrokers) Do

func (s DeleteBrokers) Do() error

func (DeleteBrokers) ToString

func (s DeleteBrokers) ToString() string

type DeleteEventServiceDeployments

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

func NewDeleteEventServiceDeployments

func NewDeleteEventServiceDeployments(p *Process) DeleteEventServiceDeployments

func (DeleteEventServiceDeployments) Do

func (s DeleteEventServiceDeployments) Do() error

func (DeleteEventServiceDeployments) ToString

func (s DeleteEventServiceDeployments) ToString() string

type DeleteEventSources

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

func NewDeleteEventSources

func NewDeleteEventSources(p *Process) DeleteEventSources

func (DeleteEventSources) Do

func (s DeleteEventSources) Do() error

func (DeleteEventSources) ToString

func (s DeleteEventSources) ToString() string

type DeleteTriggers

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

func NewDeleteTriggers

func NewDeleteTriggers(p *Process) DeleteTriggers

func (DeleteTriggers) Do

func (s DeleteTriggers) Do() error

func (DeleteTriggers) ToString

func (s DeleteTriggers) ToString() string

type E2ESetup

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

type Metadata

type Metadata struct {
	Labels map[string][]byte `json:"labels"`
}

type PatchConnectivityValidators

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

func NewPatchConnectivityValidators

func NewPatchConnectivityValidators(p *Process) PatchConnectivityValidators

func (PatchConnectivityValidators) Do

func (s PatchConnectivityValidators) Do() error

func (PatchConnectivityValidators) ToString

func (s PatchConnectivityValidators) ToString() string

type PatchDeploymentSpec

type PatchDeploymentSpec struct {
	Spec Spec `json:"spec"`
}

type PatchLabels

type PatchLabels struct {
	Metadata Metadata `json:"metadata"`
}

type Process

type Process struct {
	Steps           []Step
	ReleaseName     string
	BEBNamespace    string
	EventingBackend string
	EventTypePrefix string
	Clients         Clients
	Logger          *logrus.Logger
	State           State
}

func (*Process) AddSteps

func (p *Process) AddSteps()

func (Process) Execute

func (p Process) Execute() error

type SaveCurrentState

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

func NewSaveCurrentState

func NewSaveCurrentState(p *Process) SaveCurrentState

func (SaveCurrentState) Do

func (s SaveCurrentState) Do() error

func (SaveCurrentState) ToString

func (s SaveCurrentState) ToString() string

type Spec

type Spec struct {
	Template Template `json:"template"`
}

type State

type State struct {
	Triggers               *eventingv1alpha1.TriggerList
	Brokers                *eventingv1alpha1.BrokerList
	Subscriptions          *messagingv1alpha1.SubscriptionList
	Channels               *messagingv1alpha1.ChannelList
	Applications           *applicationconnectorv1alpha1.ApplicationList
	ConnectivityValidators *appsv1.DeploymentList
	EventServices          *appsv1.DeploymentList
	EventSources           *sourcesv1alpha1.HTTPSourceList
	Namespaces             *corev1.NamespaceList
}

type Step

type Step interface {
	Do() error
	ToString() string
}

type Template

type Template struct {
	Spec TemplateSpec `json:"spec"`
}

type TemplateSpec

type TemplateSpec struct {
	Containers []corev1.Container `json:"containers"`
}

type UnLabelNamespace

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

func NewUnLabelNamespace

func NewUnLabelNamespace(p *Process) UnLabelNamespace

func (UnLabelNamespace) Do

func (s UnLabelNamespace) Do() error

func (UnLabelNamespace) ToString

func (s UnLabelNamespace) ToString() string