k8s

package
v0.5.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 7, 2023 License: MPL-2.0 Imports: 32 Imported by: 0

README

Design

Lifecycle

Every time we enter a reconciliation loop we do essentially the same 5 things in the following order for logical consistency:

  1. See where we are in the lifecycle of an object -- if it's being deleted, clean it up, if it needs finalizer additions or deletions, do them -- this happens in the Controller/reconciler itself.
  2. Validate and resolve any references to external objects -- this happens in the reconciliation manager.
  3. Attempt to upsert the object into our state tree -- this happens in the store that the manager invokes.
  4. Synchronize any changed objects from the upsert into Consul's state -- this happens in a synchronization adapter used by the store.
  5. Synchronize any status changes back to Kubernetes -- this happens as callbacks invoked by the store after synchronization either fails or completes.

Error Handling

Generally we've followed the following major design principles for error handling in our reconciler loop code:

  1. Any unexpected Kubernetes API errors should return an error from the controller Reconcile method which will immediately reschedule (in a ratelimited fashion) the event on the loop.
  2. Any errors that are non-retryable in nature due to bad data i.e. validation errors, should be swallowed and Kubernetes status conditions used to give user feedback.
  3. Errors from synchronizing a resolved Gateway-Route tree, whether they're Consul network-connectivity issues or data validation issues due to external modification or invalid Consul state should be retried, however the reconciliation loop should not be blocked, instead the reconciliation attempt should be requeued with a delay, allowing subsequent state changes to still be processed, causing whatever guards against out-of-date configuration (generation checks) to eventually drop the bad event.
  4. In order to facillitate the above, wrap all controller Reconcile methods in gatewayclient.NewRequeueingMiddleware and make sure any errors returned from the gatewayclient api calls are wrapped in gatewayclient.K8sError.

Documentation

Index

Constants

View Source
const (
	ControllerName = "hashicorp.com/consul-api-gateway-controller"
)

Variables

This section is empty.

Functions

func StoreConfig added in v0.5.0

func StoreConfig(adapter core.SyncAdapter, client gatewayclient.Client, consulClient consul.Client, logger hclog.Logger, config Config) store.Config

Types

type Config

type Config struct {
	CACert              string
	PrimaryDatacenter   string
	SDSServerHost       string
	SDSServerPort       int
	MetricsBindAddr     string
	HealthProbeBindAddr string
	WebhookPort         int
	RestConfig          *rest.Config
	Namespace           string

	// ConsulNamespaceConfig
	ConsulNamespaceConfig ConsulNamespaceConfig
}

func Defaults

func Defaults() *Config

type ConsulNamespaceConfig

type ConsulNamespaceConfig struct {
	ConsulDestinationNamespace      string
	MirrorKubernetesNamespaces      bool
	MirrorKubernetesNamespacePrefix string
	PartitionInfo                   consul.PartitionInfo
}

func (ConsulNamespaceConfig) Namespace

func (c ConsulNamespaceConfig) Namespace(namespace string) string

type K8sSecretClient

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

K8sSecretClient acts as a secret fetcher for kubernetes secrets

func NewK8sSecretClient

func NewK8sSecretClient(logger hclog.Logger, config *rest.Config) (*K8sSecretClient, error)

NewK8sSecretClient initializes a K8sSecretClient instance

func (*K8sSecretClient) FetchSecret

func (c *K8sSecretClient) FetchSecret(ctx context.Context, fullName string) (*tls.Secret, time.Time, error)

FetchSecret fetches a kubernetes secret described with the url name of k8s://namespace/secret-name

type Kubernetes

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

func New

func New(logger hclog.Logger, config *Config) (*Kubernetes, error)

func (*Kubernetes) Client added in v0.5.0

func (k *Kubernetes) Client() gatewayclient.Client

func (*Kubernetes) SetConsul

func (k *Kubernetes) SetConsul(consul consul.Client)

func (*Kubernetes) SetStore

func (k *Kubernetes) SetStore(store store.Store)

func (*Kubernetes) Start

func (k *Kubernetes) Start(ctx context.Context) error

Start will run the kubernetes controllers and return a startup error if occurred

Directories

Path Synopsis
mocks
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
mocks
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
mocks
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL