controllers

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: May 8, 2020 License: MIT Imports: 73 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EtcdVersion = "v3.4.7"
)

Variables

This section is empty.

Functions

func WrapRetryError added in v0.5.0 

func WrapRetryError(err error) error

Types

type Certificate added in v0.5.0 

type Certificate struct {
	tls.Certificate
	// contains filtered or unexported fields
}

func NewCertificate added in v0.5.0 

func NewCertificate(source tls.Certificate) (Certificate, error)

func (*Certificate) MarshalCertificate added in v0.5.0 

func (c *Certificate) MarshalCertificate() []byte

func (*Certificate) ToSecret added in v0.5.0 

func (c *Certificate) ToSecret() *corev1.Secret

type CreateSecret added in v0.5.0 

type CreateSecret struct {
	Name   string
	Known  func() bool
	Create func() (*corev1.Secret, error)
}

type EtcdCluster added in v0.5.0 

type EtcdCluster struct {
	*etcdv1alpha1.EtcdCluster

	ClusterDomain string
	// contains filtered or unexported fields
}

func NewEtcdCluster added in v0.5.0 

func NewEtcdCluster(c *etcdv1alpha1.EtcdCluster, clusterDomain string) *EtcdCluster

func (*EtcdCluster) AllExistMembers added in v0.5.0 

func (c *EtcdCluster) AllExistMembers() []*corev1.Pod

func (*EtcdCluster) AllMembers added in v0.5.0 

func (c *EtcdCluster) AllMembers() []*corev1.Pod

AllMembers returns all members of etcd, regardless of status

func (*EtcdCluster) CA added in v0.5.0 

func (c *EtcdCluster) CA(s *corev1.Secret) (*corev1.Secret, error)

func (*EtcdCluster) CASecretName added in v0.5.0 

func (c *EtcdCluster) CASecretName() string

func (*EtcdCluster) Client added in v0.5.0 

func (c *EtcdCluster) Client(endpoints []string) (*clientv3.Client, error)

func (*EtcdCluster) ClientCertSecret added in v0.5.0 

func (c *EtcdCluster) ClientCertSecret(ca *corev1.Secret) (*corev1.Secret, error)

func (*EtcdCluster) ClientCertSecretName added in v0.5.0 

func (c *EtcdCluster) ClientCertSecretName() string

func (*EtcdCluster) ClientService added in v0.5.0 

func (c *EtcdCluster) ClientService() *corev1.Service

func (*EtcdCluster) ClientServiceName added in v0.5.0 

func (c *EtcdCluster) ClientServiceName() string

func (*EtcdCluster) CurrentInternalState added in v0.5.0 

func (c *EtcdCluster) CurrentInternalState() InternalState

func (*EtcdCluster) CurrentPhase added in v0.5.0 

func (c *EtcdCluster) CurrentPhase() etcdv1alpha1.EtcdClusterPhase

func (*EtcdCluster) DNSNames added in v0.5.0 

func (c *EtcdCluster) DNSNames() []string

func (*EtcdCluster) DefragmentCronJob added in v0.5.0 

func (c *EtcdCluster) DefragmentCronJob() *batchv1beta1.CronJob

func (*EtcdCluster) DefragmentCronJobName added in v0.5.0 

func (c *EtcdCluster) DefragmentCronJobName() string

func (*EtcdCluster) DiscoveryService added in v0.5.0 

func (c *EtcdCluster) DiscoveryService() *corev1.Service

func (*EtcdCluster) GetMetrics added in v0.5.0 

func (c *EtcdCluster) GetMetrics(addr string) ([]*dto.MetricFamily, error)

func (*EtcdCluster) IsPodReady added in v0.5.0 

func (c *EtcdCluster) IsPodReady(pod *corev1.Pod) bool

func (*EtcdCluster) PermanentMembers added in v0.5.0 

func (c *EtcdCluster) PermanentMembers() []*corev1.Pod

func (*EtcdCluster) ServerCert added in v0.5.0 

func (c *EtcdCluster) ServerCert(ca *corev1.Secret) (Certificate, error)

func (*EtcdCluster) ServerCertSecret added in v0.5.0 

func (c *EtcdCluster) ServerCertSecret(ca *corev1.Secret) (*corev1.Secret, error)

func (*EtcdCluster) ServerCertSecretName added in v0.5.0 

func (c *EtcdCluster) ServerCertSecretName() string

func (*EtcdCluster) ServerDiscoveryServiceName added in v0.5.0 

func (c *EtcdCluster) ServerDiscoveryServiceName() string

func (*EtcdCluster) SetAnnotationForPod added in v0.5.0 

func (c *EtcdCluster) SetAnnotationForPod(pod *corev1.Pod)

func (*EtcdCluster) SetCASecret added in v0.5.0 

func (c *EtcdCluster) SetCASecret(ca *corev1.Secret)

func (*EtcdCluster) SetOwnedPods added in v0.5.0 

func (c *EtcdCluster) SetOwnedPods(pods []*corev1.Pod)

func (*EtcdCluster) SetServerCertSecret added in v0.5.0 

func (c *EtcdCluster) SetServerCertSecret(cert *corev1.Secret)

func (*EtcdCluster) ShouldUpdate added in v0.5.0 

func (c *EtcdCluster) ShouldUpdate(pod *corev1.Pod) bool

func (*EtcdCluster) ShouldUpdateServerCertificate added in v0.5.0 

func (c *EtcdCluster) ShouldUpdateServerCertificate(certPem []byte) bool

func (*EtcdCluster) TemporaryMember added in v0.5.0 

func (c *EtcdCluster) TemporaryMember() *corev1.Pod

type EtcdController added in v0.5.0 

type EtcdController struct {
	schema.GroupVersionKind
	// contains filtered or unexported fields
}

func NewEtcdController added in v0.5.0 

func NewEtcdController(ctx context.Context, client *kubernetes.Clientset, cfg *rest.Config, clusterDomain string, runOutsideCluster bool) (*EtcdController, error)

func (*EtcdController) Run added in v0.5.0 

func (ec *EtcdController) Run(ctx context.Context, workers int)

type InternalState added in v0.5.0 

type InternalState string
const (
	InternalStateCreatingFirstMember InternalState = "creatingFirstNode"
	InternalStateCreatingMembers     InternalState = "creatingMembers"
	InternalStatePreparingUpdate     InternalState = "preparingUpdate"
	InternalStateUpdatingMember      InternalState = "updatingMember"
	InternalStateTeardownUpdating    InternalState = "teardownUpdating"
	InternalStateRunning             InternalState = "running"
)

type LagrangianProxy 

type LagrangianProxy struct {
	Name                string
	Namespace           string
	Object              *proxyv1.Proxy
	Spec                proxyv1.ProxySpec
	Datastore           *etcdv1alpha1.EtcdCluster
	CASecret            *corev1.Secret
	SigningPrivateKey   *corev1.Secret
	GithubWebhookSecret *corev1.Secret
	CookieSecret        *corev1.Secret
	InternalTokenSecret *corev1.Secret
	// contains filtered or unexported fields
}

func NewLagrangianProxy 

func NewLagrangianProxy(
	spec *proxyv1.Proxy,
	cmClient cmClientset.Interface, serviceLister listers.ServiceLister,
	backends []proxyv1.Backend, roles []proxyv1.Role, rpcPermissions []proxyv1.RpcPermission) *LagrangianProxy

func (*LagrangianProxy) Backends 

func (r *LagrangianProxy) Backends() []proxyv1.Backend

func (*LagrangianProxy) CASecretName 

func (r *LagrangianProxy) CASecretName() string

func (*LagrangianProxy) Certificate 

func (r *LagrangianProxy) Certificate() (*certmanager.Certificate, error)

func (*LagrangianProxy) CertificateSecretName 

func (r *LagrangianProxy) CertificateSecretName() string

func (*LagrangianProxy) ConfigForDashboard 

func (r *LagrangianProxy) ConfigForDashboard() (*corev1.ConfigMap, error)

func (*LagrangianProxy) ConfigForMain 

func (r *LagrangianProxy) ConfigForMain() (*corev1.ConfigMap, error)

func (*LagrangianProxy) ConfigForRPCServer 

func (r *LagrangianProxy) ConfigForRPCServer() (*corev1.ConfigMap, error)

func (*LagrangianProxy) ConfigNameForDashboard 

func (r *LagrangianProxy) ConfigNameForDashboard() string

func (*LagrangianProxy) ConfigNameForMain 

func (r *LagrangianProxy) ConfigNameForMain() string

func (*LagrangianProxy) ConfigNameForRPCServer 

func (r *LagrangianProxy) ConfigNameForRPCServer() string

func (*LagrangianProxy) ControlObject added in v0.5.0 

func (r *LagrangianProxy) ControlObject(obj metav1.Object)

func (*LagrangianProxy) CookieSecretName 

func (r *LagrangianProxy) CookieSecretName() string

func (*LagrangianProxy) Dashboard 

func (r *LagrangianProxy) Dashboard() (*process, error)

func (*LagrangianProxy) DeploymentNameForDashboard 

func (r *LagrangianProxy) DeploymentNameForDashboard() string

func (*LagrangianProxy) DeploymentNameForMain 

func (r *LagrangianProxy) DeploymentNameForMain() string

func (*LagrangianProxy) DeploymentNameForRPCServer 

func (r *LagrangianProxy) DeploymentNameForRPCServer() string

func (*LagrangianProxy) EtcdCluster 

func (r *LagrangianProxy) EtcdCluster() (*etcdv1alpha1.EtcdCluster, *monitoringv1.PodMonitor)

func (*LagrangianProxy) EtcdClusterName 

func (r *LagrangianProxy) EtcdClusterName() string

func (*LagrangianProxy) EtcdHost 

func (r *LagrangianProxy) EtcdHost() string

func (*LagrangianProxy) GithubSecretName 

func (r *LagrangianProxy) GithubSecretName() string

func (*LagrangianProxy) InternalTokenSecretName 

func (r *LagrangianProxy) InternalTokenSecretName() string

func (*LagrangianProxy) LabelsForDashboard 

func (r *LagrangianProxy) LabelsForDashboard() map[string]string

func (*LagrangianProxy) LabelsForDefragmentJob 

func (r *LagrangianProxy) LabelsForDefragmentJob() map[string]string

func (*LagrangianProxy) LabelsForMain 

func (r *LagrangianProxy) LabelsForMain() map[string]string

func (*LagrangianProxy) LabelsForRPCServer 

func (r *LagrangianProxy) LabelsForRPCServer() map[string]string

func (*LagrangianProxy) Main 

func (r *LagrangianProxy) Main() (*process, error)

func (*LagrangianProxy) NewCA added in v0.5.0 

func (r *LagrangianProxy) NewCA() (*corev1.Secret, error)

func (*LagrangianProxy) NewCookieSecret added in v0.5.0 

func (r *LagrangianProxy) NewCookieSecret() (*corev1.Secret, error)

func (*LagrangianProxy) NewGithubSecret added in v0.5.0 

func (r *LagrangianProxy) NewGithubSecret() (*corev1.Secret, error)

func (*LagrangianProxy) NewInternalTokenSecret added in v0.5.0 

func (r *LagrangianProxy) NewInternalTokenSecret() (*corev1.Secret, error)

func (*LagrangianProxy) NewSigningPrivateKey added in v0.5.0 

func (r *LagrangianProxy) NewSigningPrivateKey() (*corev1.Secret, error)

func (*LagrangianProxy) PodDisruptionBudgetNameForDashboard 

func (r *LagrangianProxy) PodDisruptionBudgetNameForDashboard() string

func (*LagrangianProxy) PodDisruptionBudgetNameForMain 

func (r *LagrangianProxy) PodDisruptionBudgetNameForMain() string

func (*LagrangianProxy) PrivateKeySecretName 

func (r *LagrangianProxy) PrivateKeySecretName() string

func (*LagrangianProxy) RPCServer 

func (r *LagrangianProxy) RPCServer() (*process, error)

func (*LagrangianProxy) ReverseProxyConfig 

func (r *LagrangianProxy) ReverseProxyConfig() (*corev1.ConfigMap, error)

func (*LagrangianProxy) ReverseProxyConfigName 

func (r *LagrangianProxy) ReverseProxyConfigName() string

func (*LagrangianProxy) Roles 

func (r *LagrangianProxy) Roles() []proxyv1.Role

func (*LagrangianProxy) RpcPermissions 

func (r *LagrangianProxy) RpcPermissions() []proxyv1.RpcPermission

func (*LagrangianProxy) Secrets added in v0.5.0 

func (r *LagrangianProxy) Secrets() []CreateSecret

func (*LagrangianProxy) ServiceNameForDashboard 

func (r *LagrangianProxy) ServiceNameForDashboard() string

func (*LagrangianProxy) ServiceNameForInternalApi 

func (r *LagrangianProxy) ServiceNameForInternalApi() string

func (*LagrangianProxy) ServiceNameForMain 

func (r *LagrangianProxy) ServiceNameForMain() string

func (*LagrangianProxy) ServiceNameForRPCServer 

func (r *LagrangianProxy) ServiceNameForRPCServer() string

func (*LagrangianProxy) Version 

func (r *LagrangianProxy) Version() string

type ProxyController added in v0.5.0 

type ProxyController struct {
	schema.GroupVersionKind
	// contains filtered or unexported fields
}

func New added in v0.5.0 

func New(ctx context.Context, client *kubernetes.Clientset, cfg *rest.Config) (*ProxyController, error)

func (*ProxyController) Run added in v0.5.0 

func (c *ProxyController) Run(ctx context.Context, workers int)

type RetryError added in v0.5.0 

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

func (*RetryError) Error added in v0.5.0 

func (e *RetryError) Error() string

func (*RetryError) Is added in v0.5.0 

func (e *RetryError) Is(err error) bool

func (*RetryError) Unwrap added in v0.5.0 

func (e *RetryError) Unwrap() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.