replication

Documentation

Index

• Constants
• type AdmissionContext
  • func (ac *AdmissionContext) SetupAdmissionWebhooks(r *chi.Mux) error
• type Controller
  • func (c *Controller) Process(pctx *ctrl.ProcessContext) (bool, bool, error)
  • func (c *Controller) Run(ctx context.Context)
• type ControllerConstructor
  • func (cc *ControllerConstructor) AddFlags(flagset ctrl.FlagSet)
  • func (cc *ControllerConstructor) Describe() ctrl.Descriptor
  • func (cc *ControllerConstructor) New(config *ctrl.Config, cctx *ctrl.Context) (*ctrl.Constructed, error)
• type RejectionMessage

Constants

const (
	ReplicateKey = "replicate"
)

Types

type AdmissionContext

type AdmissionContext struct {
	AuthzClient         authz_v1client.SubjectAccessReviewInterface
	CurrentLocation     voyager.ClusterLocation
	ReplicatedLocations sets.ClusterLocation
	// contains filtered or unexported fields
}

func (*AdmissionContext) SetupAdmissionWebhooks

func (ac *AdmissionContext) SetupAdmissionWebhooks(r *chi.Mux) error

SetupAPI handles creating a route for the mutating webhook

type Controller

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

func (*Controller) Process

func (c *Controller) Process(pctx *ctrl.ProcessContext) (bool, bool, error)

TODO: We need to develop a way to reconcile clusters in the many error states we can get into

func (*Controller) Run

func (c *Controller) Run(ctx context.Context)

type ControllerConstructor

type ControllerConstructor struct {
	RemoteConfigFile string
	ConfigContext    string
	TLSCert          string
	TLSKey           string
}

func (*ControllerConstructor) AddFlags

func (cc *ControllerConstructor) AddFlags(flagset ctrl.FlagSet)

func (*ControllerConstructor) Describe

func (cc *ControllerConstructor) Describe() ctrl.Descriptor

func (*ControllerConstructor) New

func (cc *ControllerConstructor) New(config *ctrl.Config, cctx *ctrl.Context) (*ctrl.Constructed, error)

type RejectionMessage

type RejectionMessage string