registration

Documentation

Index

• Constants
• Variables
• type RegistrationCache
  • func NewRegistrationCache(ctx context.Context, consulClientConfig *consul.Config, ...) *RegistrationCache
• type RegistrationsController
  • func (r *RegistrationsController) Logger(name types.NamespacedName) logr.Logger
  • func (r *RegistrationsController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *RegistrationsController) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error
  • func (r *RegistrationsController) UpdateStatus(ctx context.Context, log logr.Logger, registration *v1alpha1.Registration, ...) error
• type Result

Constants

const (
	ConditionSynced       = "Synced"
	ConditionRegistered   = "Registered"
	ConditionDeregistered = "Deregistered"
)

Conditions.

const (
	SyncError                 = "SyncError"
	ConsulErrorRegistration   = "ConsulErrorRegistration"
	ConsulErrorDeregistration = "ConsulErrorDeregistration"
	ConsulDeregistration      = "ConsulDeregistration"
)

Status Reasons.

const NotInServiceMeshFilter = "ServiceMeta[\"managed-by\"] != \"consul-k8s-endpoints-controller\""

const (
	RegistrationFinalizer = "registration.finalizers.consul.hashicorp.com"
)

Variables

var (
	ErrRegisteringService   = fmt.Errorf("error registering service")
	ErrDeregisteringService = fmt.Errorf("error deregistering service")
	ErrUpdatingACLRoles     = fmt.Errorf("error updating ACL roles")
	ErrRemovingACLRoles     = fmt.Errorf("error removing ACL roles")
)

Types

type RegistrationCache

type RegistrationCache struct {
	ConsulClientConfig  *consul.Config
	ConsulServerConnMgr consul.ServerConnectionManager

	Services map[string]*v1alpha1.Registration

	UpdateChan chan string
	// contains filtered or unexported fields
}

func NewRegistrationCache

func NewRegistrationCache(ctx context.Context, consulClientConfig *consul.Config, consulServerConnMgr consul.ServerConnectionManager, k8sClient client.Client, namespacesEnabled, partitionsEnabled bool) *RegistrationCache

type RegistrationsController

type RegistrationsController struct {
	client.Client
	configentries.FinalizerPatcher
	Scheme *runtime.Scheme
	Cache  *RegistrationCache
	Log    logr.Logger
}

RegistrationsController is the controller for Registrations resources.

func (*RegistrationsController) Logger

func (r *RegistrationsController) Logger(name types.NamespacedName) logr.Logger

func (*RegistrationsController) Reconcile

func (r *RegistrationsController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*RegistrationsController) SetupWithManager

func (r *RegistrationsController) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

func (*RegistrationsController) UpdateStatus

func (r *RegistrationsController) UpdateStatus(ctx context.Context, log logr.Logger, registration *v1alpha1.Registration, result Result) error

type Result

type Result struct {
	Registering        bool
	ConsulDeregistered bool
	Sync               error
	Registration       error
	Deregistration     error
	Finalizer          error
}