Documentation ¶
Index ¶
- Constants
- Variables
- type Certificate
- type ConfigConverter
- func (ConfigConverter) Proxy(backends []*proxyv1alpha2.Backend, serviceLister listers.ServiceLister) ([]byte, error)
- func (ConfigConverter) RPCPermission(permissions []*proxyv1alpha2.RpcPermission) ([]byte, error)
- func (ConfigConverter) Role(backends []*proxyv1alpha2.Backend, roleList []*proxyv1alpha2.Role, ...) ([]byte, error)
- type CreateSecret
- type EtcdCluster
- func (c *EtcdCluster) AllExistMembers() []*corev1.Pod
- func (c *EtcdCluster) AllMembers() []*EtcdMember
- func (c *EtcdCluster) CA() (*corev1.Secret, error)
- func (c *EtcdCluster) CASecretName() string
- func (c *EtcdCluster) Client(endpoints []string) (*clientv3.Client, error)
- func (c *EtcdCluster) ClientCertSecret() (*corev1.Secret, error)
- func (c *EtcdCluster) ClientCertSecretName() string
- func (c *EtcdCluster) ClientService() *corev1.Service
- func (c *EtcdCluster) ClientServiceName() string
- func (c *EtcdCluster) CurrentInternalState() InternalState
- func (c *EtcdCluster) CurrentPhase() etcdv1alpha2.EtcdClusterPhase
- func (c *EtcdCluster) DNSNames() []string
- func (c *EtcdCluster) DefaultAnnotations() map[string]string
- func (c *EtcdCluster) DefaultLabels(etcdVersion string) map[string]string
- func (c *EtcdCluster) DefragmentCronJob() *batchv1.CronJob
- func (c *EtcdCluster) DefragmentCronJobName() string
- func (c *EtcdCluster) DiscoveryService() *corev1.Service
- func (c *EtcdCluster) EqualAnnotation(a, b map[string]string) bool
- func (c *EtcdCluster) EqualLabels(a, b map[string]string) bool
- func (c *EtcdCluster) EtcdRole() *rbacv1.Role
- func (c *EtcdCluster) EtcdRoleBinding() *rbacv1.RoleBinding
- func (c *EtcdCluster) EtcdVersion() string
- func (c *EtcdCluster) GetMetrics(addr string) ([]*dto.MetricFamily, error)
- func (c *EtcdCluster) GetOwnedPods(podLister listers.PodLister, pvcLister listers.PersistentVolumeClaimLister) error
- func (c *EtcdCluster) HasTemporaryMember() bool
- func (c *EtcdCluster) Init(secretLister listers.SecretLister)
- func (c *EtcdCluster) InjectRestoreContainer(pod *corev1.Pod)
- func (c *EtcdCluster) IsPodReady(pod *corev1.Pod) bool
- func (c *EtcdCluster) NeedRepair(pod *corev1.Pod) bool
- func (c *EtcdCluster) PermanentMembers() []*corev1.Pod
- func (c *EtcdCluster) ServerCert() (Certificate, error)
- func (c *EtcdCluster) ServerCertSecret() (*corev1.Secret, error)
- func (c *EtcdCluster) ServerCertSecretName() string
- func (c *EtcdCluster) ServerDiscoveryServiceName() string
- func (c *EtcdCluster) ServiceAccount() *corev1.ServiceAccount
- func (c *EtcdCluster) ServiceAccountName() string
- func (c *EtcdCluster) SetAnnotationForPod(pod *corev1.Pod)
- func (c *EtcdCluster) SetCASecret(ca *corev1.Secret)
- func (c *EtcdCluster) SetClientCertSecret(cert *corev1.Secret)
- func (c *EtcdCluster) SetOwnedPods(pods []*corev1.Pod)
- func (c *EtcdCluster) SetServerCertSecret(cert *corev1.Secret)
- func (c *EtcdCluster) ShouldUpdate(pod *corev1.Pod) bool
- func (c *EtcdCluster) ShouldUpdateServerCertificate(certPem []byte) bool
- func (c *EtcdCluster) TemporaryMember() *EtcdMember
- type EtcdController
- func (ec *EtcdController) ConvertToKeys() controllerbase.ObjectToKeyConverter
- func (ec *EtcdController) EventSources() []cache.SharedIndexInformer
- func (ec *EtcdController) Finalize(_ context.Context, _ interface{}) error
- func (ec *EtcdController) Finalizers() []string
- func (ec *EtcdController) GetObject(key string) (interface{}, error)
- func (ec *EtcdController) ListerSynced() []cache.InformerSynced
- func (ec *EtcdController) Name() string
- func (ec *EtcdController) Reconcile(ctx context.Context, obj interface{}) error
- func (ec *EtcdController) UpdateObject(ctx context.Context, obj interface{}) error
- type EtcdMember
- type GitHubController
- func (c *GitHubController) ConvertToKeys() controllerbase.ObjectToKeyConverter
- func (c *GitHubController) EventSources() []cache.SharedIndexInformer
- func (c *GitHubController) Finalize(ctx context.Context, obj interface{}) error
- func (c *GitHubController) Finalizers() []string
- func (c *GitHubController) GetObject(key string) (interface{}, error)
- func (c *GitHubController) ListerSynced() []cache.InformerSynced
- func (c *GitHubController) Name() string
- func (c *GitHubController) Reconcile(ctx context.Context, obj interface{}) error
- func (c *GitHubController) UpdateObject(ctx context.Context, obj interface{}) error
- type HeimdallrProxy
- func (r *HeimdallrProxy) Backends() []*proxyv1alpha2.Backend
- func (r *HeimdallrProxy) CASecretName() string
- func (r *HeimdallrProxy) Certificate() runtime.Object
- func (r *HeimdallrProxy) CertificateSecretName() string
- func (r *HeimdallrProxy) ConfigForDashboard() (*corev1.ConfigMap, error)
- func (r *HeimdallrProxy) ConfigForMain() (*corev1.ConfigMap, error)
- func (r *HeimdallrProxy) ConfigForRPCServer() (*corev1.ConfigMap, error)
- func (r *HeimdallrProxy) ConfigNameForDashboard() string
- func (r *HeimdallrProxy) ConfigNameForMain() string
- func (r *HeimdallrProxy) ConfigNameForRPCServer() string
- func (r *HeimdallrProxy) ControlObject(obj metav1.Object)
- func (r *HeimdallrProxy) CookieSecretName() string
- func (r *HeimdallrProxy) DefaultBackends() []*proxyv1alpha2.Backend
- func (r *HeimdallrProxy) DefaultRoleBindings() []*proxyv1alpha2.RoleBinding
- func (r *HeimdallrProxy) DefaultRoles() []*proxyv1alpha2.Role
- func (r *HeimdallrProxy) DefaultRpcPermissions() []*proxyv1alpha2.RpcPermission
- func (r *HeimdallrProxy) DeploymentNameForDashboard() string
- func (r *HeimdallrProxy) DeploymentNameForMain() string
- func (r *HeimdallrProxy) DeploymentNameForRPCServer() string
- func (r *HeimdallrProxy) EtcdCluster() (*etcdv1alpha2.EtcdCluster, *monitoringv1.PodMonitor)
- func (r *HeimdallrProxy) EtcdClusterName() string
- func (r *HeimdallrProxy) EtcdHost() string
- func (r *HeimdallrProxy) GithubSecretName() string
- func (r *HeimdallrProxy) IdealDashboard() (*process, error)
- func (r *HeimdallrProxy) IdealProxyProcess() (*process, error)
- func (r *HeimdallrProxy) IdealRPCServer() (*process, error)
- func (r *HeimdallrProxy) Init(secretLister listers.SecretLister) error
- func (r *HeimdallrProxy) InternalTokenSecretName() string
- func (r *HeimdallrProxy) LabelsForDashboard() map[string]string
- func (r *HeimdallrProxy) LabelsForDefragmentJob() map[string]string
- func (r *HeimdallrProxy) LabelsForMain() map[string]string
- func (r *HeimdallrProxy) LabelsForRPCServer() map[string]string
- func (r *HeimdallrProxy) NewCA() (*corev1.Secret, error)
- func (r *HeimdallrProxy) NewCookieSecret() (*corev1.Secret, error)
- func (r *HeimdallrProxy) NewGithubSecret() (*corev1.Secret, error)
- func (r *HeimdallrProxy) NewInternalTokenSecret() (*corev1.Secret, error)
- func (r *HeimdallrProxy) NewSigningPrivateKey() (*corev1.Secret, error)
- func (r *HeimdallrProxy) PodDisruptionBudgetNameForDashboard() string
- func (r *HeimdallrProxy) PodDisruptionBudgetNameForMain() string
- func (r *HeimdallrProxy) PodDisruptionBudgetNameForRPCServer() string
- func (r *HeimdallrProxy) PrivateKeySecretName() string
- func (r *HeimdallrProxy) ReverseProxyConfig() (*corev1.ConfigMap, error)
- func (r *HeimdallrProxy) ReverseProxyConfigName() string
- func (r *HeimdallrProxy) RoleBindings() []*proxyv1alpha2.RoleBinding
- func (r *HeimdallrProxy) Roles() []*proxyv1alpha2.Role
- func (r *HeimdallrProxy) RpcPermissions() []*proxyv1alpha2.RpcPermission
- func (r *HeimdallrProxy) Secrets() []CreateSecret
- func (r *HeimdallrProxy) ServiceNameForDashboard() string
- func (r *HeimdallrProxy) ServiceNameForInternalApi() string
- func (r *HeimdallrProxy) ServiceNameForMain() string
- func (r *HeimdallrProxy) ServiceNameForRPCServer() string
- func (r *HeimdallrProxy) Version() string
- type HeimdallrProxyParams
- type IngressController
- func (ic *IngressController) ConvertToKeys() controllerbase.ObjectToKeyConverter
- func (ic *IngressController) EventSources() []cache.SharedIndexInformer
- func (ic *IngressController) Finalize(ctx context.Context, obj interface{}) error
- func (ic *IngressController) Finalizers() []string
- func (ic *IngressController) GetObject(key string) (interface{}, error)
- func (ic *IngressController) ListerSynced() []cache.InformerSynced
- func (ic *IngressController) Name() string
- func (ic *IngressController) Reconcile(ctx context.Context, obj interface{}) error
- func (ic *IngressController) UpdateObject(ctx context.Context, obj interface{}) error
- type InternalState
- type MockOption
- type Probe
- type ProxyController
- func (c *ProxyController) ConvertToKeys() controllerbase.ObjectToKeyConverter
- func (c *ProxyController) EventSources() []cache.SharedIndexInformer
- func (c *ProxyController) Finalize(_ context.Context, _ interface{}) error
- func (c *ProxyController) Finalizers() []string
- func (c *ProxyController) GetObject(key string) (interface{}, error)
- func (c *ProxyController) ListerSynced() []cache.InformerSynced
- func (c *ProxyController) Name() string
- func (c *ProxyController) Reconcile(ctx context.Context, obj interface{}) error
- func (c *ProxyController) UpdateObject(ctx context.Context, obj interface{}) error
- type RoleBindings
Constants ¶
View Source
const ( EtcdClientPort = 2379 EtcdPeerPort = 2380 EtcdMetricsPort = 2381 )
View Source
const ( EtcdVersion = "v3.4.8" ProxyImageRepository = "ghcr.io/f110/heimdallr/proxy" RPCServerImageRepository = "ghcr.io/f110/heimdallr/rpcserver" DashboardImageRepository = "ghcr.io/f110/heimdallr/dashboard" )
Variables ¶
View Source
var ( ErrEtcdClusterIsNotReady = errors.New("EtcdCluster is not ready yet") ErrRPCServerIsNotReady = errors.New("rpc server is not ready") )
Functions ¶
This section is empty.
Types ¶
type Certificate ¶
type Certificate struct { tls.Certificate // contains filtered or unexported fields }
func NewCertificate ¶
func NewCertificate(secret *corev1.Secret, source tls.Certificate) (Certificate, error)
func (*Certificate) MarshalCertificate ¶
func (c *Certificate) MarshalCertificate() []byte
func (*Certificate) ToSecret ¶
func (c *Certificate) ToSecret() *corev1.Secret
type ConfigConverter ¶
type ConfigConverter struct { }
func (ConfigConverter) Proxy ¶
func (ConfigConverter) Proxy(backends []*proxyv1alpha2.Backend, serviceLister listers.ServiceLister) ([]byte, error)
func (ConfigConverter) RPCPermission ¶
func (ConfigConverter) RPCPermission(permissions []*proxyv1alpha2.RpcPermission) ([]byte, error)
func (ConfigConverter) Role ¶
func (ConfigConverter) Role(backends []*proxyv1alpha2.Backend, roleList []*proxyv1alpha2.Role, roleBindings []*proxyv1alpha2.RoleBinding) ([]byte, error)
type CreateSecret ¶
type EtcdCluster ¶
type EtcdCluster struct { *etcdv1alpha2.EtcdCluster ClusterDomain string // contains filtered or unexported fields }
func NewEtcdCluster ¶
func NewEtcdCluster(c *etcdv1alpha2.EtcdCluster, clusterDomain string, log *zap.Logger, mockOpt *MockOption) *EtcdCluster
func (*EtcdCluster) AllExistMembers ¶
func (c *EtcdCluster) AllExistMembers() []*corev1.Pod
func (*EtcdCluster) AllMembers ¶
func (c *EtcdCluster) AllMembers() []*EtcdMember
AllMembers returns all members of etcd, regardless of status
func (*EtcdCluster) CASecretName ¶
func (c *EtcdCluster) CASecretName() string
func (*EtcdCluster) Client ¶
func (c *EtcdCluster) Client(endpoints []string) (*clientv3.Client, error)
func (*EtcdCluster) ClientCertSecret ¶
func (c *EtcdCluster) ClientCertSecret() (*corev1.Secret, error)
func (*EtcdCluster) ClientCertSecretName ¶
func (c *EtcdCluster) ClientCertSecretName() string
func (*EtcdCluster) ClientService ¶
func (c *EtcdCluster) ClientService() *corev1.Service
func (*EtcdCluster) ClientServiceName ¶
func (c *EtcdCluster) ClientServiceName() string
func (*EtcdCluster) CurrentInternalState ¶
func (c *EtcdCluster) CurrentInternalState() InternalState
func (*EtcdCluster) CurrentPhase ¶
func (c *EtcdCluster) CurrentPhase() etcdv1alpha2.EtcdClusterPhase
func (*EtcdCluster) DNSNames ¶
func (c *EtcdCluster) DNSNames() []string
func (*EtcdCluster) DefaultAnnotations ¶ added in v0.15.0
func (c *EtcdCluster) DefaultAnnotations() map[string]string
func (*EtcdCluster) DefaultLabels ¶ added in v0.15.0
func (c *EtcdCluster) DefaultLabels(etcdVersion string) map[string]string
func (*EtcdCluster) DefragmentCronJob ¶
func (c *EtcdCluster) DefragmentCronJob() *batchv1.CronJob
func (*EtcdCluster) DefragmentCronJobName ¶
func (c *EtcdCluster) DefragmentCronJobName() string
func (*EtcdCluster) DiscoveryService ¶
func (c *EtcdCluster) DiscoveryService() *corev1.Service
func (*EtcdCluster) EqualAnnotation ¶ added in v0.15.0
func (c *EtcdCluster) EqualAnnotation(a, b map[string]string) bool
func (*EtcdCluster) EqualLabels ¶ added in v0.15.0
func (c *EtcdCluster) EqualLabels(a, b map[string]string) bool
EqualLabels reports whether a and b are "semantic equal".
func (*EtcdCluster) EtcdRole ¶
func (c *EtcdCluster) EtcdRole() *rbacv1.Role
func (*EtcdCluster) EtcdRoleBinding ¶
func (c *EtcdCluster) EtcdRoleBinding() *rbacv1.RoleBinding
func (*EtcdCluster) EtcdVersion ¶
func (c *EtcdCluster) EtcdVersion() string
func (*EtcdCluster) GetMetrics ¶
func (c *EtcdCluster) GetMetrics(addr string) ([]*dto.MetricFamily, error)
func (*EtcdCluster) GetOwnedPods ¶
func (c *EtcdCluster) GetOwnedPods(podLister listers.PodLister, pvcLister listers.PersistentVolumeClaimLister) error
func (*EtcdCluster) HasTemporaryMember ¶
func (c *EtcdCluster) HasTemporaryMember() bool
func (*EtcdCluster) Init ¶
func (c *EtcdCluster) Init(secretLister listers.SecretLister)
func (*EtcdCluster) InjectRestoreContainer ¶
func (c *EtcdCluster) InjectRestoreContainer(pod *corev1.Pod)
func (*EtcdCluster) IsPodReady ¶
func (c *EtcdCluster) IsPodReady(pod *corev1.Pod) bool
func (*EtcdCluster) NeedRepair ¶
func (c *EtcdCluster) NeedRepair(pod *corev1.Pod) bool
func (*EtcdCluster) PermanentMembers ¶
func (c *EtcdCluster) PermanentMembers() []*corev1.Pod
func (*EtcdCluster) ServerCert ¶
func (c *EtcdCluster) ServerCert() (Certificate, error)
func (*EtcdCluster) ServerCertSecret ¶
func (c *EtcdCluster) ServerCertSecret() (*corev1.Secret, error)
func (*EtcdCluster) ServerCertSecretName ¶
func (c *EtcdCluster) ServerCertSecretName() string
func (*EtcdCluster) ServerDiscoveryServiceName ¶
func (c *EtcdCluster) ServerDiscoveryServiceName() string
func (*EtcdCluster) ServiceAccount ¶
func (c *EtcdCluster) ServiceAccount() *corev1.ServiceAccount
func (*EtcdCluster) ServiceAccountName ¶
func (c *EtcdCluster) ServiceAccountName() string
func (*EtcdCluster) SetAnnotationForPod ¶
func (c *EtcdCluster) SetAnnotationForPod(pod *corev1.Pod)
func (*EtcdCluster) SetCASecret ¶
func (c *EtcdCluster) SetCASecret(ca *corev1.Secret)
func (*EtcdCluster) SetClientCertSecret ¶
func (c *EtcdCluster) SetClientCertSecret(cert *corev1.Secret)
func (*EtcdCluster) SetOwnedPods ¶
func (c *EtcdCluster) SetOwnedPods(pods []*corev1.Pod)
func (*EtcdCluster) SetServerCertSecret ¶
func (c *EtcdCluster) SetServerCertSecret(cert *corev1.Secret)
func (*EtcdCluster) ShouldUpdate ¶
func (c *EtcdCluster) ShouldUpdate(pod *corev1.Pod) bool
func (*EtcdCluster) ShouldUpdateServerCertificate ¶
func (c *EtcdCluster) ShouldUpdateServerCertificate(certPem []byte) bool
func (*EtcdCluster) TemporaryMember ¶
func (c *EtcdCluster) TemporaryMember() *EtcdMember
type EtcdController ¶
type EtcdController struct { *controllerbase.Controller // contains filtered or unexported fields }
func NewEtcdController ¶
func NewEtcdController( sharedInformerFactory *client.InformerFactory, coreSharedInformerFactory kubeinformers.SharedInformerFactory, coreClient kubernetes.Interface, etcdClient *client.EtcdV1alpha2, cfg *rest.Config, clusterDomain string, runOutsideCluster bool, transport http.RoundTripper, mockOpt *MockOption, ) (*EtcdController, error)
func (*EtcdController) ConvertToKeys ¶
func (ec *EtcdController) ConvertToKeys() controllerbase.ObjectToKeyConverter
func (*EtcdController) EventSources ¶
func (ec *EtcdController) EventSources() []cache.SharedIndexInformer
func (*EtcdController) Finalize ¶
func (ec *EtcdController) Finalize(_ context.Context, _ interface{}) error
func (*EtcdController) Finalizers ¶
func (ec *EtcdController) Finalizers() []string
func (*EtcdController) GetObject ¶
func (ec *EtcdController) GetObject(key string) (interface{}, error)
func (*EtcdController) ListerSynced ¶
func (ec *EtcdController) ListerSynced() []cache.InformerSynced
func (*EtcdController) Name ¶
func (ec *EtcdController) Name() string
func (*EtcdController) Reconcile ¶
func (ec *EtcdController) Reconcile(ctx context.Context, obj interface{}) error
func (*EtcdController) UpdateObject ¶
func (ec *EtcdController) UpdateObject(ctx context.Context, obj interface{}) error
type EtcdMember ¶
type EtcdMember struct { Pod *corev1.Pod PersistentVolumeClaim *corev1.PersistentVolumeClaim // TODO: Remove after v0.12 OldVersion bool }
type GitHubController ¶
type GitHubController struct { *controllerbase.Controller // contains filtered or unexported fields }
func NewGitHubController ¶
func NewGitHubController( sharedInformerFactory *client.InformerFactory, coreSharedInformerFactory kubeinformers.SharedInformerFactory, coreClient kubernetes.Interface, proxyClient *client.ProxyV1alpha2, transport http.RoundTripper, ) (*GitHubController, error)
func (*GitHubController) ConvertToKeys ¶
func (c *GitHubController) ConvertToKeys() controllerbase.ObjectToKeyConverter
func (*GitHubController) EventSources ¶
func (c *GitHubController) EventSources() []cache.SharedIndexInformer
func (*GitHubController) Finalize ¶
func (c *GitHubController) Finalize(ctx context.Context, obj interface{}) error
func (*GitHubController) Finalizers ¶
func (c *GitHubController) Finalizers() []string
func (*GitHubController) GetObject ¶
func (c *GitHubController) GetObject(key string) (interface{}, error)
func (*GitHubController) ListerSynced ¶
func (c *GitHubController) ListerSynced() []cache.InformerSynced
func (*GitHubController) Name ¶
func (c *GitHubController) Name() string
func (*GitHubController) Reconcile ¶
func (c *GitHubController) Reconcile(ctx context.Context, obj interface{}) error
func (*GitHubController) UpdateObject ¶
func (c *GitHubController) UpdateObject(ctx context.Context, obj interface{}) error
type HeimdallrProxy ¶
type HeimdallrProxy struct { Name string Namespace string Object *proxyv1alpha2.Proxy Spec proxyv1alpha2.ProxySpec Datastore *etcdv1alpha2.EtcdCluster CASecret *corev1.Secret SigningPrivateKey *corev1.Secret GithubWebhookSecret *corev1.Secret CookieSecret *corev1.Secret InternalTokenSecret *corev1.Secret ServerCertSecret *corev1.Secret IdentityProviderSecret *corev1.Secret DatastoreClientCertSecret *corev1.Secret RPCServer *process ProxyServer *process DashboardServer *process // contains filtered or unexported fields }
func NewHeimdallrProxy ¶
func NewHeimdallrProxy(opt HeimdallrProxyParams) *HeimdallrProxy
func (*HeimdallrProxy) Backends ¶
func (r *HeimdallrProxy) Backends() []*proxyv1alpha2.Backend
func (*HeimdallrProxy) CASecretName ¶
func (r *HeimdallrProxy) CASecretName() string
func (*HeimdallrProxy) Certificate ¶
func (r *HeimdallrProxy) Certificate() runtime.Object
func (*HeimdallrProxy) CertificateSecretName ¶
func (r *HeimdallrProxy) CertificateSecretName() string
func (*HeimdallrProxy) ConfigForDashboard ¶
func (r *HeimdallrProxy) ConfigForDashboard() (*corev1.ConfigMap, error)
func (*HeimdallrProxy) ConfigForMain ¶
func (r *HeimdallrProxy) ConfigForMain() (*corev1.ConfigMap, error)
func (*HeimdallrProxy) ConfigForRPCServer ¶
func (r *HeimdallrProxy) ConfigForRPCServer() (*corev1.ConfigMap, error)
func (*HeimdallrProxy) ConfigNameForDashboard ¶
func (r *HeimdallrProxy) ConfigNameForDashboard() string
func (*HeimdallrProxy) ConfigNameForMain ¶
func (r *HeimdallrProxy) ConfigNameForMain() string
func (*HeimdallrProxy) ConfigNameForRPCServer ¶
func (r *HeimdallrProxy) ConfigNameForRPCServer() string
func (*HeimdallrProxy) ControlObject ¶
func (r *HeimdallrProxy) ControlObject(obj metav1.Object)
func (*HeimdallrProxy) CookieSecretName ¶
func (r *HeimdallrProxy) CookieSecretName() string
func (*HeimdallrProxy) DefaultBackends ¶
func (r *HeimdallrProxy) DefaultBackends() []*proxyv1alpha2.Backend
func (*HeimdallrProxy) DefaultRoleBindings ¶
func (r *HeimdallrProxy) DefaultRoleBindings() []*proxyv1alpha2.RoleBinding
func (*HeimdallrProxy) DefaultRoles ¶
func (r *HeimdallrProxy) DefaultRoles() []*proxyv1alpha2.Role
func (*HeimdallrProxy) DefaultRpcPermissions ¶
func (r *HeimdallrProxy) DefaultRpcPermissions() []*proxyv1alpha2.RpcPermission
func (*HeimdallrProxy) DeploymentNameForDashboard ¶
func (r *HeimdallrProxy) DeploymentNameForDashboard() string
func (*HeimdallrProxy) DeploymentNameForMain ¶
func (r *HeimdallrProxy) DeploymentNameForMain() string
func (*HeimdallrProxy) DeploymentNameForRPCServer ¶
func (r *HeimdallrProxy) DeploymentNameForRPCServer() string
func (*HeimdallrProxy) EtcdCluster ¶
func (r *HeimdallrProxy) EtcdCluster() (*etcdv1alpha2.EtcdCluster, *monitoringv1.PodMonitor)
func (*HeimdallrProxy) EtcdClusterName ¶
func (r *HeimdallrProxy) EtcdClusterName() string
func (*HeimdallrProxy) EtcdHost ¶
func (r *HeimdallrProxy) EtcdHost() string
func (*HeimdallrProxy) GithubSecretName ¶
func (r *HeimdallrProxy) GithubSecretName() string
func (*HeimdallrProxy) IdealDashboard ¶
func (r *HeimdallrProxy) IdealDashboard() (*process, error)
func (*HeimdallrProxy) IdealProxyProcess ¶
func (r *HeimdallrProxy) IdealProxyProcess() (*process, error)
func (*HeimdallrProxy) IdealRPCServer ¶
func (r *HeimdallrProxy) IdealRPCServer() (*process, error)
func (*HeimdallrProxy) Init ¶
func (r *HeimdallrProxy) Init(secretLister listers.SecretLister) error
func (*HeimdallrProxy) InternalTokenSecretName ¶
func (r *HeimdallrProxy) InternalTokenSecretName() string
func (*HeimdallrProxy) LabelsForDashboard ¶
func (r *HeimdallrProxy) LabelsForDashboard() map[string]string
func (*HeimdallrProxy) LabelsForDefragmentJob ¶
func (r *HeimdallrProxy) LabelsForDefragmentJob() map[string]string
func (*HeimdallrProxy) LabelsForMain ¶
func (r *HeimdallrProxy) LabelsForMain() map[string]string
func (*HeimdallrProxy) LabelsForRPCServer ¶
func (r *HeimdallrProxy) LabelsForRPCServer() map[string]string
func (*HeimdallrProxy) NewCookieSecret ¶
func (r *HeimdallrProxy) NewCookieSecret() (*corev1.Secret, error)
func (*HeimdallrProxy) NewGithubSecret ¶
func (r *HeimdallrProxy) NewGithubSecret() (*corev1.Secret, error)
func (*HeimdallrProxy) NewInternalTokenSecret ¶
func (r *HeimdallrProxy) NewInternalTokenSecret() (*corev1.Secret, error)
func (*HeimdallrProxy) NewSigningPrivateKey ¶
func (r *HeimdallrProxy) NewSigningPrivateKey() (*corev1.Secret, error)
func (*HeimdallrProxy) PodDisruptionBudgetNameForDashboard ¶
func (r *HeimdallrProxy) PodDisruptionBudgetNameForDashboard() string
func (*HeimdallrProxy) PodDisruptionBudgetNameForMain ¶
func (r *HeimdallrProxy) PodDisruptionBudgetNameForMain() string
func (*HeimdallrProxy) PodDisruptionBudgetNameForRPCServer ¶
func (r *HeimdallrProxy) PodDisruptionBudgetNameForRPCServer() string
func (*HeimdallrProxy) PrivateKeySecretName ¶
func (r *HeimdallrProxy) PrivateKeySecretName() string
func (*HeimdallrProxy) ReverseProxyConfig ¶
func (r *HeimdallrProxy) ReverseProxyConfig() (*corev1.ConfigMap, error)
func (*HeimdallrProxy) ReverseProxyConfigName ¶
func (r *HeimdallrProxy) ReverseProxyConfigName() string
func (*HeimdallrProxy) RoleBindings ¶
func (r *HeimdallrProxy) RoleBindings() []*proxyv1alpha2.RoleBinding
func (*HeimdallrProxy) Roles ¶
func (r *HeimdallrProxy) Roles() []*proxyv1alpha2.Role
func (*HeimdallrProxy) RpcPermissions ¶
func (r *HeimdallrProxy) RpcPermissions() []*proxyv1alpha2.RpcPermission
func (*HeimdallrProxy) Secrets ¶
func (r *HeimdallrProxy) Secrets() []CreateSecret
func (*HeimdallrProxy) ServiceNameForDashboard ¶
func (r *HeimdallrProxy) ServiceNameForDashboard() string
func (*HeimdallrProxy) ServiceNameForInternalApi ¶
func (r *HeimdallrProxy) ServiceNameForInternalApi() string
func (*HeimdallrProxy) ServiceNameForMain ¶
func (r *HeimdallrProxy) ServiceNameForMain() string
func (*HeimdallrProxy) ServiceNameForRPCServer ¶
func (r *HeimdallrProxy) ServiceNameForRPCServer() string
func (*HeimdallrProxy) Version ¶
func (r *HeimdallrProxy) Version() string
type HeimdallrProxyParams ¶
type HeimdallrProxyParams struct { Spec *proxyv1alpha2.Proxy ThirdPartyClientSet *thirdpartyclient.Set ServiceLister listers.ServiceLister Backends []*proxyv1alpha2.Backend Roles []*proxyv1alpha2.Role RpcPermissions []*proxyv1alpha2.RpcPermission RoleBindings []*proxyv1alpha2.RoleBinding CertManagerVersion string }
type IngressController ¶
type IngressController struct { *controllerbase.Controller // contains filtered or unexported fields }
func NewIngressController ¶
func NewIngressController( coreSharedInformerFactory coreInformers.SharedInformerFactory, sharedInformerFactory *client.InformerFactory, coreClient kubernetes.Interface, proxyClient *client.ProxyV1alpha2, ) *IngressController
func (*IngressController) ConvertToKeys ¶
func (ic *IngressController) ConvertToKeys() controllerbase.ObjectToKeyConverter
func (*IngressController) EventSources ¶
func (ic *IngressController) EventSources() []cache.SharedIndexInformer
func (*IngressController) Finalize ¶
func (ic *IngressController) Finalize(ctx context.Context, obj interface{}) error
func (*IngressController) Finalizers ¶
func (ic *IngressController) Finalizers() []string
func (*IngressController) GetObject ¶
func (ic *IngressController) GetObject(key string) (interface{}, error)
func (*IngressController) ListerSynced ¶
func (ic *IngressController) ListerSynced() []cache.InformerSynced
func (*IngressController) Name ¶
func (ic *IngressController) Name() string
func (*IngressController) Reconcile ¶
func (ic *IngressController) Reconcile(ctx context.Context, obj interface{}) error
func (*IngressController) UpdateObject ¶
func (ic *IngressController) UpdateObject(ctx context.Context, obj interface{}) error
type InternalState ¶
type InternalState string
const ( InternalStateCreatingFirstMember InternalState = "creatingFirstNode" InternalStateCreatingMembers InternalState = "creatingMembers" InternalStateRepair InternalState = "repair" InternalStateRestore InternalState = "restore" InternalStatePreparingUpdate InternalState = "preparingUpdate" InternalStateUpdatingMember InternalState = "updatingMember" InternalStateTeardownUpdating InternalState = "teardownUpdating" InternalStateRunning InternalState = "running" )
type MockOption ¶
type MockOption struct { Cluster clientv3.Cluster Maintenance clientv3.Maintenance }
type ProxyController ¶
type ProxyController struct { *controllerbase.Controller // contains filtered or unexported fields }
func NewProxyController ¶
func NewProxyController( ctx context.Context, sharedInformerFactory *client.InformerFactory, coreSharedInformerFactory kubeinformers.SharedInformerFactory, coreClient kubernetes.Interface, clientSet *client.Set, thirdPartyClientSet *thirdpartyclient.Set, ) (*ProxyController, error)
func (*ProxyController) ConvertToKeys ¶
func (c *ProxyController) ConvertToKeys() controllerbase.ObjectToKeyConverter
func (*ProxyController) EventSources ¶
func (c *ProxyController) EventSources() []cache.SharedIndexInformer
func (*ProxyController) Finalize ¶
func (c *ProxyController) Finalize(_ context.Context, _ interface{}) error
func (*ProxyController) Finalizers ¶
func (c *ProxyController) Finalizers() []string
func (*ProxyController) GetObject ¶
func (c *ProxyController) GetObject(key string) (interface{}, error)
func (*ProxyController) ListerSynced ¶
func (c *ProxyController) ListerSynced() []cache.InformerSynced
func (*ProxyController) Name ¶
func (c *ProxyController) Name() string
func (*ProxyController) Reconcile ¶
func (c *ProxyController) Reconcile(ctx context.Context, obj interface{}) error
func (*ProxyController) UpdateObject ¶
func (c *ProxyController) UpdateObject(ctx context.Context, obj interface{}) error
type RoleBindings ¶
type RoleBindings []*proxyv1alpha2.RoleBinding
func (RoleBindings) Select ¶
func (rb RoleBindings) Select(fn func(*proxyv1alpha2.RoleBinding) bool) []*proxyv1alpha2.RoleBinding
Source Files ¶
Click to show internal directories.
Click to hide internal directories.