application

Documentation

Index

• func Deploy(kubeClient *meshkube.Client, oamComp v1alpha1.Component, ...) error
• type ArgoRollout
  • func (ar *ArgoRollout) Canary(opt RolloutEngineCanaryOptions) error
  • func (ar *ArgoRollout) Install() error
  • func (ar *ArgoRollout) Native(opt RolloutEngineGenericOptions) error
• type PatternConfiguration
• type PatternConfigurationRolloutStrategy
• type PatternSetting
• type PatternSettingAdvanced
• type RolloutEngine
  • func NewRolloutEngine(kubeclient *meshkube.Client, typ string) (RolloutEngine, error)
• type RolloutEngineCanaryOptions
• type RolloutEngineCanaryStep
• type RolloutEngineCanaryStepPause
• type RolloutEngineContainer
• type RolloutEngineContainerPort
• type RolloutEngineContainerResource
• type RolloutEngineGenericOptions
• type RolloutEngineGenericOptionsMetadata

Functions

func Deploy

func Deploy(
	kubeClient *meshkube.Client,
	oamComp v1alpha1.Component,
	oamConfig v1alpha1.Configuration,
	isDel bool,
) error

Deploy will deploy the application

Types

type ArgoRollout

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

func (*ArgoRollout) Canary

func (ar *ArgoRollout) Canary(opt RolloutEngineCanaryOptions) error

Canary performs canary rollout of the given application

func (*ArgoRollout) Install

func (ar *ArgoRollout) Install() error

Install installs argo rollout in the given namespace

func (*ArgoRollout) Native

func (ar *ArgoRollout) Native(opt RolloutEngineGenericOptions) error

Native will do simple rollout

type PatternConfiguration

type PatternConfiguration struct {
	RolloutStrategy *PatternConfigurationRolloutStrategy `json:"rollout_strategy,omitempty"`
}

type PatternConfigurationRolloutStrategy

type PatternConfigurationRolloutStrategy struct {
}

type PatternSetting

type PatternSetting struct {
	Replicas   int                      `json:"replicas,omitempty"`
	Mesh       serviceMesh              `json:"mesh,omitempty"`
	Containers []RolloutEngineContainer `json:"containers,omitempty"`
	Advanced   PatternSettingAdvanced   `json:"advanced,omitempty"`
}

type PatternSettingAdvanced

type PatternSettingAdvanced struct {
	CreateService *bool             `json:"create_service,omitempty"`
	Labels        map[string]string `json:"labels,omitempty"`
	Annotations   map[string]string `json:"annotations,omitempty"`
}

type RolloutEngine

type RolloutEngine interface {
	// Canary(RolloutEngineCanaryOptions) error
	Install() error
	Native(RolloutEngineGenericOptions) error
}

func NewRolloutEngine

func NewRolloutEngine(kubeclient *meshkube.Client, typ string) (RolloutEngine, error)

type RolloutEngineCanaryOptions

type RolloutEngineCanaryOptions struct {
	RolloutEngineGenericOptions
	Steps []RolloutEngineCanaryStep
}

type RolloutEngineCanaryStep

type RolloutEngineCanaryStep struct {
	SetWeight int
	Steps     []RolloutEngineCanaryStepPause
}

type RolloutEngineCanaryStepPause

type RolloutEngineCanaryStepPause struct {
	Duration int
}

type RolloutEngineContainer

type RolloutEngineContainer struct {
	Name      string
	Image     string
	Ports     []RolloutEngineContainerPort
	Resources []RolloutEngineContainerResource
	Envs      []v1.EnvVar
}

type RolloutEngineContainerPort

type RolloutEngineContainerPort struct {
	Name          string
	ContainerPort int
}

type RolloutEngineContainerResource

type RolloutEngineContainerResource struct {
	v1.ResourceRequirements
}

type RolloutEngineGenericOptions

type RolloutEngineGenericOptions struct {
	Name        string
	Namespace   string
	ServiceMesh string
	Metadata    RolloutEngineGenericOptionsMetadata
	Replicas    int
	Containers  []RolloutEngineContainer
	Delete      bool
	Advanced    PatternSettingAdvanced
}

type RolloutEngineGenericOptionsMetadata

type RolloutEngineGenericOptionsMetadata struct {
	Labels      map[string]string
	Annotations map[string]string
}