resource

Documentation

Index

• Constants
• func ClusterPlaceholder(name string) *api.CrdbCluster
• type Builder
• type Cluster
  • func NewCluster(original *api.CrdbCluster) Cluster
  • func (cluster Cluster) ClientTLSSecretName() string
  • func (cluster Cluster) DiscoveryServiceName() string
  • func (cluster Cluster) Domain() string
  • func (cluster Cluster) InitTime() metav1.Time
  • func (cluster Cluster) IsFresh(fetcher Fetcher) (bool, error)
  • func (cluster Cluster) Name() string
  • func (cluster Cluster) Namespace() string
  • func (cluster Cluster) NodeTLSSecretName() string
  • func (cluster Cluster) ObjectKey() types.NamespacedName
  • func (cluster Cluster) PublicServiceName() string
  • func (cluster Cluster) SecureMode() string
  • func (cluster Cluster) SetFalse(ctype api.ClusterConditionType)
  • func (cluster Cluster) SetTrue(ctype api.ClusterConditionType)
  • func (cluster Cluster) Spec() *api.CrdbClusterSpec
  • func (cluster Cluster) StatefulSetName() string
  • func (cluster Cluster) Status() *api.CrdbClusterStatus
  • func (cluster Cluster) Unwrap() *api.CrdbCluster
• type DiscoveryServiceBuilder
  • func (b DiscoveryServiceBuilder) Build(obj runtime.Object) error
  • func (b DiscoveryServiceBuilder) Placeholder() runtime.Object
• type Fetcher
• type KubeFetcher
  • func NewKubeFetcher(ctx context.Context, namespace string, reader client.Reader) *KubeFetcher
  • func (f KubeFetcher) Fetch(o runtime.Object) error
• type KubePersister
  • func NewKubePersister(ctx context.Context, namespace string, client client.Client, ...) *KubePersister
  • func (p KubePersister) Persist(obj runtime.Object, mutateFn func() error) (upserted bool, err error)
• type ManagedResource
  • func NewManagedKubeResource(ctx context.Context, client client.Client, cluster *Cluster, ...) ManagedResource
• type Persister
• type PublicServiceBuilder
  • func (b PublicServiceBuilder) Build(obj runtime.Object) error
  • func (b PublicServiceBuilder) Placeholder() runtime.Object
• type Reconciler
  • func (r Reconciler) Reconcile() (upserted bool, err error)
• type Resource
  • func NewKubeResource(ctx context.Context, client client.Client, namespace string, ...) Resource
• type StatefulSetBuilder
  • func (b StatefulSetBuilder) Build(obj runtime.Object) error
  • func (b StatefulSetBuilder) Placeholder() runtime.Object
• type TLSSecret
  • func LoadTLSSecret(name string, r Resource) (*TLSSecret, error)
  • func (s *TLSSecret) Key() []byte
  • func (s *TLSSecret) Ready() bool
  • func (s *TLSSecret) UpdateCertAndCA(cert, ca []byte, log logr.Logger) error
  • func (s *TLSSecret) UpdateKey(key []byte) error

Constants

const (
	DbContainerName = "db"
)

Functions

func ClusterPlaceholder

func ClusterPlaceholder(name string) *api.CrdbCluster

Types

type Builder

type Builder interface {
	Build(runtime.Object) error
	Placeholder() runtime.Object
}

type Cluster

type Cluster struct {
	Fetcher
	// contains filtered or unexported fields
}

func NewCluster

func NewCluster(original *api.CrdbCluster) Cluster

func (Cluster) ClientTLSSecretName

func (cluster Cluster) ClientTLSSecretName() string

func (Cluster) DiscoveryServiceName

func (cluster Cluster) DiscoveryServiceName() string

func (Cluster) Domain

func (cluster Cluster) Domain() string

func (Cluster) InitTime

func (cluster Cluster) InitTime() metav1.Time

func (Cluster) IsFresh

func (cluster Cluster) IsFresh(fetcher Fetcher) (bool, error)

func (Cluster) Name

func (cluster Cluster) Name() string

func (Cluster) Namespace

func (cluster Cluster) Namespace() string

func (Cluster) NodeTLSSecretName

func (cluster Cluster) NodeTLSSecretName() string

func (Cluster) ObjectKey

func (cluster Cluster) ObjectKey() types.NamespacedName

func (Cluster) PublicServiceName

func (cluster Cluster) PublicServiceName() string

func (Cluster) SecureMode

func (cluster Cluster) SecureMode() string

func (Cluster) SetFalse

func (cluster Cluster) SetFalse(ctype api.ClusterConditionType)

func (Cluster) SetTrue

func (cluster Cluster) SetTrue(ctype api.ClusterConditionType)

func (Cluster) Spec

func (cluster Cluster) Spec() *api.CrdbClusterSpec

func (Cluster) StatefulSetName

func (cluster Cluster) StatefulSetName() string

func (Cluster) Status

func (cluster Cluster) Status() *api.CrdbClusterStatus

func (Cluster) Unwrap

func (cluster Cluster) Unwrap() *api.CrdbCluster

type DiscoveryServiceBuilder

type DiscoveryServiceBuilder struct {
	*Cluster

	Selector map[string]string
}

This service only exists to create DNS entries for each pod in the StatefulSet such that they can resolve each other's IP addresses. It does not create a load-balanced ClusterIP and should not be used directly by clients in most circumstances.

func (DiscoveryServiceBuilder) Build

func (b DiscoveryServiceBuilder) Build(obj runtime.Object) error

func (DiscoveryServiceBuilder) Placeholder

func (b DiscoveryServiceBuilder) Placeholder() runtime.Object

type Fetcher

type Fetcher interface {
	Fetch(obj runtime.Object) error
}

type KubeFetcher

type KubeFetcher struct {
	client.Reader
	// contains filtered or unexported fields
}

func NewKubeFetcher

func NewKubeFetcher(ctx context.Context, namespace string, reader client.Reader) *KubeFetcher

func (KubeFetcher) Fetch

func (f KubeFetcher) Fetch(o runtime.Object) error

type KubePersister

type KubePersister struct {
	client.Client
	// contains filtered or unexported fields
}

func NewKubePersister

func NewKubePersister(ctx context.Context, namespace string, client client.Client, persistFn kube.PersistFn) *KubePersister

func (KubePersister) Persist

func (p KubePersister) Persist(obj runtime.Object, mutateFn func() error) (upserted bool, err error)

type ManagedResource

type ManagedResource struct {
	Resource

	labels.Labels
}

func NewManagedKubeResource

func NewManagedKubeResource(ctx context.Context, client client.Client, cluster *Cluster, persistFn kube.PersistFn) ManagedResource

type Persister

type Persister interface {
	Persist(obj runtime.Object, mutateFn func() error) (upserted bool, err error)
}

type PublicServiceBuilder

type PublicServiceBuilder struct {
	*Cluster

	Selector map[string]string
}

func (PublicServiceBuilder) Build

func (b PublicServiceBuilder) Build(obj runtime.Object) error

func (PublicServiceBuilder) Placeholder

func (b PublicServiceBuilder) Placeholder() runtime.Object

type Reconciler

type Reconciler struct {
	ManagedResource

	Builder
	Owner  metav1.Object
	Scheme *runtime.Scheme
}

func (Reconciler) Reconcile

func (r Reconciler) Reconcile() (upserted bool, err error)

type Resource

type Resource struct {
	Fetcher
	Persister
}

func NewKubeResource

func NewKubeResource(ctx context.Context, client client.Client, namespace string, persistFn kube.PersistFn) Resource

type StatefulSetBuilder

type StatefulSetBuilder struct {
	*Cluster

	Selector labels.Labels
}

func (StatefulSetBuilder) Build

func (b StatefulSetBuilder) Build(obj runtime.Object) error

func (StatefulSetBuilder) Placeholder

func (b StatefulSetBuilder) Placeholder() runtime.Object

type TLSSecret

type TLSSecret struct {
	Resource
	// contains filtered or unexported fields
}

func LoadTLSSecret

func LoadTLSSecret(name string, r Resource) (*TLSSecret, error)

func (*TLSSecret) Key

func (s *TLSSecret) Key() []byte

func (*TLSSecret) Ready

func (s *TLSSecret) Ready() bool

func (*TLSSecret) UpdateCertAndCA

func (s *TLSSecret) UpdateCertAndCA(cert, ca []byte, log logr.Logger) error

func (*TLSSecret) UpdateKey

func (s *TLSSecret) UpdateKey(key []byte) error