resources

Documentation

Index

• Constants
• Variables
• func CheckObjectUpdatedIgnoreStatus(current, updated runtime.Object) (bool, error)
• func CopyDict(src map[string]string) map[string]string
• func CreateOrUpdateIgnoreStatus(ctx context.Context, c client.Client, obj client.Object, f ctrlutil.MutateFn) (ctrlutil.OperationResult, error)
• func StringRJust(str, pad string, length int) string
• type ConfigMapBuilder
  • func (b *ConfigMapBuilder) Build(obj client.Object) error
  • func (b *ConfigMapBuilder) Placeholder(cr client.Object) client.Object
• type DatabaseBuilder
  • func NewDatabase(ydbCr *api.Database) DatabaseBuilder
  • func (b *DatabaseBuilder) GetPath() string
  • func (b *DatabaseBuilder) GetResourceBuilders() []ResourceBuilder
  • func (b *DatabaseBuilder) GetStorageEndpoint() string
  • func (b *DatabaseBuilder) GetStorageEndpointWithProto() string
  • func (b *DatabaseBuilder) SetStatusOnFirstReconcile() bool
  • func (b *DatabaseBuilder) Unwrap() *api.Database
• type DatabaseStatefulSetBuilder
  • func (b *DatabaseStatefulSetBuilder) Build(obj client.Object) error
  • func (b *DatabaseStatefulSetBuilder) Placeholder(cr client.Object) client.Object
• type EncryptionSecretBuilder
  • func (b *EncryptionSecretBuilder) Build(obj client.Object) error
  • func (b *EncryptionSecretBuilder) Placeholder(cr client.Object) client.Object
• type ResourceBuilder
• type ServiceBuilder
  • func (b *ServiceBuilder) Build(obj client.Object) error
  • func (b *ServiceBuilder) Placeholder(cr client.Object) client.Object
• type ServiceMonitorBuilder
  • func (b *ServiceMonitorBuilder) Build(obj client.Object) error
  • func (b *ServiceMonitorBuilder) Placeholder(cr client.Object) client.Object
• type StorageClusterBuilder
  • func NewCluster(ydbCr *api.Storage) StorageClusterBuilder
  • func (b *StorageClusterBuilder) GetGRPCEndpoint() string
  • func (b *StorageClusterBuilder) GetGRPCEndpointWithProto() string
  • func (b *StorageClusterBuilder) GetResourceBuilders(restConfig *rest.Config) []ResourceBuilder
  • func (b *StorageClusterBuilder) SetStatusOnFirstReconcile() bool
  • func (b *StorageClusterBuilder) Unwrap() *api.Storage
• type StorageStatefulSetBuilder
  • func (b *StorageStatefulSetBuilder) Build(obj client.Object) error
  • func (b *StorageStatefulSetBuilder) GenerateDeviceName(index int) string
  • func (b *StorageStatefulSetBuilder) GeneratePVCName(index int) string
  • func (b *StorageStatefulSetBuilder) Placeholder(cr client.Object) client.Object

Constants

const (
	DefaultNameFormat = "%s"
)

Variables

var CreateOrUpdate = ctrl.CreateOrUpdate

Functions

func CheckObjectUpdatedIgnoreStatus

func CheckObjectUpdatedIgnoreStatus(current, updated runtime.Object) (bool, error)

func CopyDict

func CopyDict(src map[string]string) map[string]string

func CreateOrUpdateIgnoreStatus

func CreateOrUpdateIgnoreStatus(ctx context.Context, c client.Client, obj client.Object, f ctrlutil.MutateFn) (ctrlutil.OperationResult, error)

func StringRJust

func StringRJust(str, pad string, length int) string

Types

type ConfigMapBuilder

type ConfigMapBuilder struct {
	client.Object

	Name   string
	Data   map[string]string
	Labels map[string]string
}

func (*ConfigMapBuilder) Build

func (b *ConfigMapBuilder) Build(obj client.Object) error

func (*ConfigMapBuilder) Placeholder

func (b *ConfigMapBuilder) Placeholder(cr client.Object) client.Object

type DatabaseBuilder

type DatabaseBuilder struct {
	*api.Database
	Storage *api.Storage
}

func NewDatabase

func NewDatabase(ydbCr *api.Database) DatabaseBuilder

func (*DatabaseBuilder) GetPath

func (b *DatabaseBuilder) GetPath() string

func (*DatabaseBuilder) GetResourceBuilders

func (b *DatabaseBuilder) GetResourceBuilders() []ResourceBuilder

func (*DatabaseBuilder) GetStorageEndpoint

func (b *DatabaseBuilder) GetStorageEndpoint() string

func (*DatabaseBuilder) GetStorageEndpointWithProto

func (b *DatabaseBuilder) GetStorageEndpointWithProto() string

func (*DatabaseBuilder) SetStatusOnFirstReconcile

func (b *DatabaseBuilder) SetStatusOnFirstReconcile() bool

func (*DatabaseBuilder) Unwrap

func (b *DatabaseBuilder) Unwrap() *api.Database

type DatabaseStatefulSetBuilder

type DatabaseStatefulSetBuilder struct {
	*v1alpha1.Database

	Labels  map[string]string
	Storage *v1alpha1.Storage
}

func (*DatabaseStatefulSetBuilder) Build

func (b *DatabaseStatefulSetBuilder) Build(obj client.Object) error

func (*DatabaseStatefulSetBuilder) Placeholder

func (b *DatabaseStatefulSetBuilder) Placeholder(cr client.Object) client.Object

type EncryptionSecretBuilder

type EncryptionSecretBuilder struct {
	client.Object

	Pin    string
	Labels map[string]string
}

func (*EncryptionSecretBuilder) Build

func (b *EncryptionSecretBuilder) Build(obj client.Object) error

func (*EncryptionSecretBuilder) Placeholder

func (b *EncryptionSecretBuilder) Placeholder(cr client.Object) client.Object

type ResourceBuilder

type ResourceBuilder interface {
	Placeholder(cr client.Object) client.Object
	Build(client.Object) error
}

type ServiceBuilder

type ServiceBuilder struct {
	client.Object

	NameFormat string

	Ports    []corev1.ServicePort
	Headless bool

	IPFamilies     []corev1.IPFamily
	IPFamilyPolicy *corev1.IPFamilyPolicyType

	Labels         map[string]string
	SelectorLabels map[string]string

	Annotations map[string]string
}

func (*ServiceBuilder) Build

func (b *ServiceBuilder) Build(obj client.Object) error

func (*ServiceBuilder) Placeholder

func (b *ServiceBuilder) Placeholder(cr client.Object) client.Object

type ServiceMonitorBuilder

type ServiceMonitorBuilder struct {
	client.Object

	Name            string
	MetricsServices []metrics.Service
	TargetPort      int
	Options         *v1alpha1.MonitoringOptions

	Labels         labels.Labels
	SelectorLabels labels.Labels
}

func (*ServiceMonitorBuilder) Build

func (b *ServiceMonitorBuilder) Build(obj client.Object) error

func (*ServiceMonitorBuilder) Placeholder

func (b *ServiceMonitorBuilder) Placeholder(cr client.Object) client.Object

type StorageClusterBuilder

type StorageClusterBuilder struct {
	*api.Storage
}

func NewCluster

func NewCluster(ydbCr *api.Storage) StorageClusterBuilder

func (*StorageClusterBuilder) GetGRPCEndpoint

func (b *StorageClusterBuilder) GetGRPCEndpoint() string

func (*StorageClusterBuilder) GetGRPCEndpointWithProto

func (b *StorageClusterBuilder) GetGRPCEndpointWithProto() string

func (*StorageClusterBuilder) GetResourceBuilders

func (b *StorageClusterBuilder) GetResourceBuilders(restConfig *rest.Config) []ResourceBuilder

func (*StorageClusterBuilder) SetStatusOnFirstReconcile

func (b *StorageClusterBuilder) SetStatusOnFirstReconcile() bool

func (*StorageClusterBuilder) Unwrap

func (b *StorageClusterBuilder) Unwrap() *api.Storage

type StorageStatefulSetBuilder

type StorageStatefulSetBuilder struct {
	*v1alpha1.Storage
	RestConfig *rest.Config

	Labels map[string]string
}

func (*StorageStatefulSetBuilder) Build

func (b *StorageStatefulSetBuilder) Build(obj client.Object) error

func (*StorageStatefulSetBuilder) GenerateDeviceName

func (b *StorageStatefulSetBuilder) GenerateDeviceName(index int) string

func (*StorageStatefulSetBuilder) GeneratePVCName

func (b *StorageStatefulSetBuilder) GeneratePVCName(index int) string

func (*StorageStatefulSetBuilder) Placeholder

func (b *StorageStatefulSetBuilder) Placeholder(cr client.Object) client.Object