connectivityproxy

Documentation

Index

• Constants
• Variables
• type CommandActions
  • func (a *CommandActions) Apply(context *service.ActionContext, refresh bool) error
  • func (a *CommandActions) CreateCARootSecret(context *service.ActionContext, caClient connectivityclient.ConnectivityClient) error
  • func (a *CommandActions) CreateSecretCpSvcKey(ctx *service.ActionContext, ns, secretName, cpSvcKey string) error
  • func (a *CommandActions) CreateSecretMappingOperator(s *service.ActionContext, ns string) ([]byte, error)
  • func (a *CommandActions) CreateServiceMappingConfigMap(svcActionCtx *service.ActionContext, ns, configMapName string) error
  • func (a *CommandActions) FixConfiguration(ctx *service.ActionContext, ns, name, tunnelURL string) error
  • func (a *CommandActions) Remove(context *service.ActionContext) error
• type Commands
• type CustomAction
  • func (a *CustomAction) Run(context *service.ActionContext) error
• type K8sLoader
  • func (a *K8sLoader) FindBindingOperator(context *service.ActionContext) (*unstructured.Unstructured, error)
  • func (a *K8sLoader) FindSecret(context *service.ActionContext, binding *unstructured.Unstructured) (*apiCoreV1.Secret, error)
• type Loader
• type Locator
• type Map
• type Search

Constants

const (
	BindingKey             = "global.binding."
	SkipManifestAnnotation = "reconciler.kyma-project.io/skip-rendering-on-upgrade"
)

const (
	ReconcilerName = "connectivity-proxy"
)

Variables

var ErrReconciliationAborted = errors.New("reconciliation aborted")

var (
	ErrValueNotFound = errors.New("value not found")
)

Types

type CommandActions

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

func (*CommandActions) Apply

func (a *CommandActions) Apply(context *service.ActionContext, refresh bool) error

func (*CommandActions) CreateCARootSecret

func (a *CommandActions) CreateCARootSecret(context *service.ActionContext, caClient connectivityclient.ConnectivityClient) error

func (*CommandActions) CreateSecretCpSvcKey

func (a *CommandActions) CreateSecretCpSvcKey(ctx *service.ActionContext, ns, secretName, cpSvcKey string) error

func (*CommandActions) CreateSecretMappingOperator

func (a *CommandActions) CreateSecretMappingOperator(s *service.ActionContext, ns string) ([]byte, error)

func (*CommandActions) CreateServiceMappingConfigMap

func (a *CommandActions) CreateServiceMappingConfigMap(svcActionCtx *service.ActionContext, ns, configMapName string) error

func (*CommandActions) FixConfiguration

func (a *CommandActions) FixConfiguration(ctx *service.ActionContext, ns, name, tunnelURL string) error

FixConfiguration function corrects the config map to make sure certificate domain, and Connectivity Proxy's configuration match. This is 2.9.2 specific.

func (*CommandActions) Remove

func (a *CommandActions) Remove(context *service.ActionContext) error

type Commands

type Commands interface {
	Apply(*service.ActionContext, bool) error
	CreateCARootSecret(*service.ActionContext, connectivityclient.ConnectivityClient) error
	CreateSecretMappingOperator(*service.ActionContext, string) ([]byte, error)
	CreateSecretCpSvcKey(ctx *service.ActionContext, ns, secretName, cpSvcKey string) error
	Remove(*service.ActionContext) error
	CreateServiceMappingConfigMap(ctx *service.ActionContext, ns, configMapName string) error
	FixConfiguration(ctx *service.ActionContext, ns, name, tunnelURL string) error
}

type CustomAction

type CustomAction struct {
	Name     string
	Loader   Loader
	Commands Commands
}

func (*CustomAction) Run

func (a *CustomAction) Run(context *service.ActionContext) error

type K8sLoader

type K8sLoader struct {
	Search Search
}

func (*K8sLoader) FindBindingOperator

func (a *K8sLoader) FindBindingOperator(context *service.ActionContext) (*unstructured.Unstructured, error)

func (*K8sLoader) FindSecret

func (a *K8sLoader) FindSecret(context *service.ActionContext, binding *unstructured.Unstructured) (*apiCoreV1.Secret, error)

type Loader

type Loader interface {
	FindBindingOperator(context *service.ActionContext) (*unstructured.Unstructured, error)
	FindSecret(*service.ActionContext, *unstructured.Unstructured) (*apiCoreV1.Secret, error)
}

type Locator

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

type Map

type Map map[string]interface{}

type Search

type Search struct {
}