ingress

Documentation

Index

• Constants
• type ChartsConfig
• type Config
  • func (c Config) Validate() error
• type ControllerSpec
  • func (s *ControllerSpec) TraefikConfig() (TraefikConfigSpec, error)
  • func (s ControllerSpec) Validate(config Config) error
• type Manager
  • func NewManager(config Config, helmService services.HelmService, logger services.Logger) Manager
  • func (m Manager) GetOutput(ctx context.Context, clusterID uint, ...) (integratedservices.IntegratedServiceOutput, error)
  • func (Manager) Name() string
  • func (m Manager) ValidateSpec(ctx context.Context, spec integratedservices.IntegratedServiceSpec) error
• type Operator
  • func NewOperator(clusters OperatorClusterStore, ...) Operator
  • func (op Operator) Apply(ctx context.Context, clusterID uint, ...) error
  • func (op Operator) Deactivate(ctx context.Context, clusterID uint, ...) error
  • func (Operator) Name() string
• type OperatorCluster
• type OperatorClusterStore
• type OrgDomain
• type OrgDomainService
• type ServiceSpec
  • func (s ServiceSpec) Validate() error
• type Spec
  • func (s Spec) Validate(config Config) error
• type TraefikChartConfig
• type TraefikConfigSpec
  • func (s TraefikConfigSpec) Validate() error
• type TraefikSSLSpec

Constants

const (
	ServiceTypeClusterIP    = "ClusterIP"
	ServiceTypeLoadBalancer = "LoadBalancer"
	ServiceTypeNodePort     = "NodePort"
)

const (
	ControllerTraefik = "traefik"
)

const ServiceName = "ingress"

ServiceName is the unique name of the integrated service

Types

type ChartsConfig

type ChartsConfig struct {
	Traefik TraefikChartConfig
}

type Config

type Config struct {
	Namespace   string
	ReleaseName string
	Controllers []string
	Charts      ChartsConfig
}

func (Config) Validate

func (c Config) Validate() error

type ControllerSpec

type ControllerSpec struct {
	Type      string                 `json:"type" mapstructure:"type"`
	RawConfig map[string]interface{} `json:"config" mapstructure:"config"`
	// contains filtered or unexported fields
}

func (*ControllerSpec) TraefikConfig

func (s *ControllerSpec) TraefikConfig() (TraefikConfigSpec, error)

func (ControllerSpec) Validate

func (s ControllerSpec) Validate(config Config) error

type Manager

type Manager struct {
	integratedservices.PassthroughIntegratedServiceSpecPreparer
	// contains filtered or unexported fields
}

func NewManager

func NewManager(config Config, helmService services.HelmService, logger services.Logger) Manager

func (Manager) GetOutput

func (m Manager) GetOutput(ctx context.Context, clusterID uint, spec integratedservices.IntegratedServiceSpec) (integratedservices.IntegratedServiceOutput, error)

func (Manager) Name

func (Manager) Name() string

Name returns the integrated service's name.

func (Manager) ValidateSpec

func (m Manager) ValidateSpec(ctx context.Context, spec integratedservices.IntegratedServiceSpec) error

type Operator

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

func NewOperator

func NewOperator(
	clusters OperatorClusterStore,
	clusterService integratedservices.ClusterService,
	config Config,
	helmService services.HelmService,
	orgDomainService OrgDomainService,
) Operator

func (Operator) Apply

func (op Operator) Apply(ctx context.Context, clusterID uint, spec integratedservices.IntegratedServiceSpec) error

Apply applies a desired state for an integrated service on the given cluster.

func (Operator) Deactivate

func (op Operator) Deactivate(ctx context.Context, clusterID uint, spec integratedservices.IntegratedServiceSpec) error

Deactivate deactivates an integrated service on the given cluster.

func (Operator) Name

func (Operator) Name() string

Name returns the integrated service's name.

type OperatorCluster

type OperatorCluster struct {
	OrganizationID uint
	Cloud          string
}

type OperatorClusterStore

type OperatorClusterStore interface {
	Get(ctx context.Context, clusterID uint) (OperatorCluster, error)
}

type OrgDomain

type OrgDomain struct {
	Name         string
	WildcardName string
}

type OrgDomainService

type OrgDomainService interface {
	GetOrgDomain(ctx context.Context, orgID uint) (OrgDomain, error)
}

type ServiceSpec

type ServiceSpec struct {
	Type        string            `json:"type" mapstructure:"type"`
	Annotations map[string]string `json:"annotations" mapstructure:"annotations"`
}

func (ServiceSpec) Validate

func (s ServiceSpec) Validate() error

type Spec

type Spec struct {
	Controller   ControllerSpec `json:"controller" mapstructure:"controller"`
	IngressClass string         `json:"ingressClass" mapstructure:"ingressClass"`
	Service      ServiceSpec    `json:"service" mapstructure:"service"`
}

func (Spec) Validate

func (s Spec) Validate(config Config) error

type TraefikChartConfig

type TraefikChartConfig struct {
	Chart   string
	Version string
	Values  values.Config
}

type TraefikConfigSpec

type TraefikConfigSpec struct {
	SSL TraefikSSLSpec `json:"ssl" mapstructure:"ssl"`
}

func (TraefikConfigSpec) Validate

func (s TraefikConfigSpec) Validate() error

type TraefikSSLSpec

type TraefikSSLSpec struct {
	DefaultCN      string   `json:"defaultCN" mapstructure:"defaultCN"`
	DefaultIPList  []string `json:"defaultIPList" mapstructure:"defaultIPList"`
	DefaultSANList []string `json:"defaultSANList" mapstructure:"defaultSANList"`
}