Documentation
¶
Overview ¶
+k8s:deepcopy-gen=package +groupName=replication.database.arangodb.com
Index ¶
- Constants
- Variables
- func IsValidation(err error) bool
- func Resource(resource string) schema.GroupResource
- type ArangoDeploymentReplication
- func (d *ArangoDeploymentReplication) AsOwner() meta.OwnerReference
- func (in *ArangoDeploymentReplication) DeepCopy() *ArangoDeploymentReplication
- func (in *ArangoDeploymentReplication) DeepCopyInto(out *ArangoDeploymentReplication)
- func (in *ArangoDeploymentReplication) DeepCopyObject() runtime.Object
- func (d *ArangoDeploymentReplication) OwnerOf(in meta.Object) bool
- type ArangoDeploymentReplicationList
- type CollectionStatus
- type Condition
- type ConditionList
- func (in ConditionList) DeepCopy() ConditionList
- func (in ConditionList) DeepCopyInto(out *ConditionList)
- func (list ConditionList) Get(conditionType ConditionType) (Condition, bool)
- func (list ConditionList) IsTrue(conditionType ConditionType) bool
- func (list *ConditionList) Remove(conditionType ConditionType) bool
- func (list *ConditionList) Update(conditionType ConditionType, status bool, reason, message string) bool
- type ConditionType
- type DatabaseStatus
- type DatabaseSynchronizationError
- type DatabaseSynchronizationStatus
- type DeploymentReplicationCancel
- type DeploymentReplicationPhase
- type DeploymentReplicationSpec
- func (in *DeploymentReplicationSpec) DeepCopy() *DeploymentReplicationSpec
- func (in *DeploymentReplicationSpec) DeepCopyInto(out *DeploymentReplicationSpec)
- func (s DeploymentReplicationSpec) ResetImmutableFields(target *DeploymentReplicationSpec) []string
- func (s *DeploymentReplicationSpec) SetDefaults()
- func (s *DeploymentReplicationSpec) SetDefaultsFrom(source DeploymentReplicationSpec)
- func (s DeploymentReplicationSpec) Validate() error
- type DeploymentReplicationStatus
- type EndpointAuthenticationSpec
- func (in *EndpointAuthenticationSpec) DeepCopy() *EndpointAuthenticationSpec
- func (in *EndpointAuthenticationSpec) DeepCopyInto(out *EndpointAuthenticationSpec)
- func (s EndpointAuthenticationSpec) GetKeyfileSecretName() string
- func (s EndpointAuthenticationSpec) GetUserSecretName() string
- func (s EndpointAuthenticationSpec) ResetImmutableFields(target *EndpointAuthenticationSpec, fieldPrefix string) []string
- func (s *EndpointAuthenticationSpec) SetDefaults()
- func (s *EndpointAuthenticationSpec) SetDefaultsFrom(source EndpointAuthenticationSpec)
- func (s EndpointAuthenticationSpec) Validate(keyfileSecretNameRequired bool) error
- type EndpointSpec
- func (in *EndpointSpec) DeepCopy() *EndpointSpec
- func (in *EndpointSpec) DeepCopyInto(out *EndpointSpec)
- func (s EndpointSpec) GetDeploymentName() string
- func (s EndpointSpec) HasDeploymentName() bool
- func (s EndpointSpec) ResetImmutableFields(target *EndpointSpec, fieldPrefix string) []string
- func (s *EndpointSpec) SetDefaults()
- func (s *EndpointSpec) SetDefaultsFrom(source EndpointSpec)
- func (s EndpointSpec) Validate(isSourceEndpoint bool) error
- type EndpointStatus
- type EndpointTLSSpec
- func (in *EndpointTLSSpec) DeepCopy() *EndpointTLSSpec
- func (in *EndpointTLSSpec) DeepCopyInto(out *EndpointTLSSpec)
- func (s EndpointTLSSpec) GetCASecretName() string
- func (s EndpointTLSSpec) ResetImmutableFields(target *EndpointTLSSpec, fieldPrefix string) []string
- func (s *EndpointTLSSpec) SetDefaults()
- func (s *EndpointTLSSpec) SetDefaultsFrom(source EndpointTLSSpec)
- func (s EndpointTLSSpec) Validate(caSecretNameRequired bool) error
- type ShardStatus
- type SynchronizationStatus
Constants ¶
const ( // ConditionTypeConfigured indicates that the replication has been configured. ConditionTypeConfigured ConditionType = "Configured" // ConditionTypeEnsuredInSync indicates that the replication consistency was checked. ConditionTypeEnsuredInSync ConditionType = "EnsuredInSync" // ConditionTypeAborted indicates that the replication is cancelling with abort option. ConditionTypeAborted ConditionType = "Aborted" // ConditionConfiguredReasonActive describes synchronization as active. ConditionConfiguredReasonActive = "Active" // ConditionConfiguredReasonInactive describes synchronization as inactive. ConditionConfiguredReasonInactive = "Inactive" // ConditionConfiguredReasonInvalid describes synchronization as active. ConditionConfiguredReasonInvalid = "Invalid" )
const (
ArangoDeploymentReplicationVersion = string(utilConstants.VersionV2Alpha1)
)
Variables ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme SchemeGroupVersion = schema.GroupVersion{Group: replication.ArangoDeploymentReplicationGroupName, Version: ArangoDeploymentReplicationVersion} )
var ( // ValidationError indicates a validation failure ValidationError = errors.New("validation failed") )
Functions ¶
func IsValidation ¶
IsValidation return true when the given error is or is caused by a ValidationError.
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource gets an ArangoCluster GroupResource for a specified resource
Types ¶
type ArangoDeploymentReplication ¶
type ArangoDeploymentReplication struct {
meta.TypeMeta `json:",inline"`
meta.ObjectMeta `json:"metadata,omitempty"`
Spec DeploymentReplicationSpec `json:"spec"`
Status DeploymentReplicationStatus `json:"status"`
}
ArangoDeploymentReplication contains the entire Kubernetes info for an ArangoDB local storage provider.
func (*ArangoDeploymentReplication) AsOwner ¶
func (d *ArangoDeploymentReplication) AsOwner() meta.OwnerReference
AsOwner creates an OwnerReference for the given replication
func (*ArangoDeploymentReplication) DeepCopy ¶
func (in *ArangoDeploymentReplication) DeepCopy() *ArangoDeploymentReplication
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArangoDeploymentReplication.
func (*ArangoDeploymentReplication) DeepCopyInto ¶
func (in *ArangoDeploymentReplication) DeepCopyInto(out *ArangoDeploymentReplication)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ArangoDeploymentReplication) DeepCopyObject ¶
func (in *ArangoDeploymentReplication) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ArangoDeploymentReplicationList ¶
type ArangoDeploymentReplicationList struct {
meta.TypeMeta `json:",inline"`
// Standard list metadata
// More info: http://releases.k8s.io/HEAD/docs/devel/api-conventions.md#metadata
meta.ListMeta `json:"metadata,omitempty"`
Items []ArangoDeploymentReplication `json:"items"`
}
ArangoDeploymentReplicationList is a list of ArangoDB deployment replications.
func (*ArangoDeploymentReplicationList) DeepCopy ¶
func (in *ArangoDeploymentReplicationList) DeepCopy() *ArangoDeploymentReplicationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArangoDeploymentReplicationList.
func (*ArangoDeploymentReplicationList) DeepCopyInto ¶
func (in *ArangoDeploymentReplicationList) DeepCopyInto(out *ArangoDeploymentReplicationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ArangoDeploymentReplicationList) DeepCopyObject ¶
func (in *ArangoDeploymentReplicationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type CollectionStatus ¶
type CollectionStatus struct {
// Name of the collection
Name string `json:"name"`
// Replication status per shard.
// The list is ordered by shard index (0..noShards-1)
Shards []ShardStatus `json:"shards,omitempty"`
}
CollectionStatus contains the status of a single collection. Deprecated
func (*CollectionStatus) DeepCopy ¶
func (in *CollectionStatus) DeepCopy() *CollectionStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CollectionStatus.
func (*CollectionStatus) DeepCopyInto ¶
func (in *CollectionStatus) DeepCopyInto(out *CollectionStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Condition ¶
type Condition struct {
// Type of condition.
Type ConditionType `json:"type"`
// Status of the condition, one of True, False, Unknown.
Status core.ConditionStatus `json:"status"`
// The last time this condition was updated.
LastUpdateTime meta.Time `json:"lastUpdateTime,omitempty"`
// Last time the condition transitioned from one status to another.
LastTransitionTime meta.Time `json:"lastTransitionTime,omitempty"`
// The reason for the condition's last transition.
Reason string `json:"reason,omitempty"`
// A human readable message indicating details about the transition.
Message string `json:"message,omitempty"`
}
Condition represents one current condition of a deployment or deployment member. A condition might not show up if it is not happening. For example, if a cluster is not upgrading, the Upgrading condition would not show up.
func (*Condition) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Condition.
func (*Condition) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConditionList ¶
type ConditionList []Condition
ConditionList is a list of conditions. Each type is allowed only once.
func (ConditionList) DeepCopy ¶
func (in ConditionList) DeepCopy() ConditionList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionList.
func (ConditionList) DeepCopyInto ¶
func (in ConditionList) DeepCopyInto(out *ConditionList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (ConditionList) Get ¶
func (list ConditionList) Get(conditionType ConditionType) (Condition, bool)
Get a condition by type. Returns true if found, false if not found.
func (ConditionList) IsTrue ¶
func (list ConditionList) IsTrue(conditionType ConditionType) bool
IsTrue return true when a condition with given type exists and its status is `True`.
func (*ConditionList) Remove ¶
func (list *ConditionList) Remove(conditionType ConditionType) bool
Remove the condition with given type. Returns true if removed, or false if not found.
func (*ConditionList) Update ¶
func (list *ConditionList) Update(conditionType ConditionType, status bool, reason, message string) bool
Update the condition, replacing an old condition with same type (if any) Returns true when changes were made, false otherwise.
type DatabaseStatus ¶
type DatabaseStatus struct {
// Name of the database
Name string `json:"name"`
// Collections holds the replication status of each collection in the database.
// List is ordered by name of the collection.
Collections []CollectionStatus `json:"collections,omitempty"`
}
DatabaseStatus contains the status of a single database. Deprecated
func (*DatabaseStatus) DeepCopy ¶
func (in *DatabaseStatus) DeepCopy() *DatabaseStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseStatus.
func (*DatabaseStatus) DeepCopyInto ¶
func (in *DatabaseStatus) DeepCopyInto(out *DatabaseStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DatabaseSynchronizationError ¶
type DatabaseSynchronizationError struct {
Collection string `json:"collection,omitempty"`
Shard string `json:"shard,omitempty"`
Message string `json:"message"`
}
DatabaseSynchronizationError contains the error message for specific shard in collection
func (*DatabaseSynchronizationError) DeepCopy ¶
func (in *DatabaseSynchronizationError) DeepCopy() *DatabaseSynchronizationError
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseSynchronizationError.
func (*DatabaseSynchronizationError) DeepCopyInto ¶
func (in *DatabaseSynchronizationError) DeepCopyInto(out *DatabaseSynchronizationError)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DatabaseSynchronizationStatus ¶
type DatabaseSynchronizationStatus struct {
// Deprecated
// ShardsTotal shows how many shards are expected to be in-sync
ShardsTotal int `json:"shards-total"`
// Deprecated
// ShardsInSync shows how many shards are already in-sync
ShardsInSync int `json:"shards-in-sync"`
// Errors contains a list of errors if there were unexpected errors during synchronization
Errors []DatabaseSynchronizationError `json:"errors,omitempty"`
}
DatabaseSynchronizationStatus contains the synchronization status of replication for database
func (*DatabaseSynchronizationStatus) DeepCopy ¶
func (in *DatabaseSynchronizationStatus) DeepCopy() *DatabaseSynchronizationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseSynchronizationStatus.
func (*DatabaseSynchronizationStatus) DeepCopyInto ¶
func (in *DatabaseSynchronizationStatus) DeepCopyInto(out *DatabaseSynchronizationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeploymentReplicationCancel ¶
type DeploymentReplicationCancel struct {
// EnsureInSync if it is true then during cancellation process data consistency is required.
// Default value is true.
EnsureInSync *bool `json:"ensureInSync"`
// SourceReadOnly if it true then after cancellation source data center should be in read-only mode.
// Default value is false.
SourceReadOnly *bool `json:"sourceReadOnly"`
}
DeploymentReplicationCancel describes what to do during cancellation process.
func (*DeploymentReplicationCancel) DeepCopy ¶
func (in *DeploymentReplicationCancel) DeepCopy() *DeploymentReplicationCancel
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeploymentReplicationCancel.
func (*DeploymentReplicationCancel) DeepCopyInto ¶
func (in *DeploymentReplicationCancel) DeepCopyInto(out *DeploymentReplicationCancel)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeploymentReplicationPhase ¶
type DeploymentReplicationPhase string
DeploymentReplicationPhase is a strongly typed lifetime phase of a deployment replication
const ( // DeploymentReplicationPhaseNone indicates that the phase is not set yet DeploymentReplicationPhaseNone DeploymentReplicationPhase = "" // DeploymentReplicationPhaseFailed indicates that a deployment replication is in a failed state // from which automatic recovery is impossible. Inspect `Reason` for more info. DeploymentReplicationPhaseFailed DeploymentReplicationPhase = "Failed" )
func (DeploymentReplicationPhase) IsFailed ¶
func (cs DeploymentReplicationPhase) IsFailed() bool
IsFailed returns true if given state is DeploymentStateFailed
type DeploymentReplicationSpec ¶
type DeploymentReplicationSpec struct {
Source EndpointSpec `json:"source"`
Destination EndpointSpec `json:"destination"`
// Cancellation describes what to do during cancellation process.
Cancellation DeploymentReplicationCancel `json:"cancellation"`
}
DeploymentReplicationSpec contains the specification part of an ArangoDeploymentReplication.
func (*DeploymentReplicationSpec) DeepCopy ¶
func (in *DeploymentReplicationSpec) DeepCopy() *DeploymentReplicationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeploymentReplicationSpec.
func (*DeploymentReplicationSpec) DeepCopyInto ¶
func (in *DeploymentReplicationSpec) DeepCopyInto(out *DeploymentReplicationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (DeploymentReplicationSpec) ResetImmutableFields ¶
func (s DeploymentReplicationSpec) ResetImmutableFields(target *DeploymentReplicationSpec) []string
ResetImmutableFields replaces all immutable fields in the given target with values from the source spec. It returns a list of fields that have been reset. Field names are relative to `spec.`.
func (*DeploymentReplicationSpec) SetDefaults ¶
func (s *DeploymentReplicationSpec) SetDefaults()
SetDefaults fills empty field with default values.
func (*DeploymentReplicationSpec) SetDefaultsFrom ¶
func (s *DeploymentReplicationSpec) SetDefaultsFrom(source DeploymentReplicationSpec)
SetDefaultsFrom fills empty field with default values from the given source.
func (DeploymentReplicationSpec) Validate ¶
func (s DeploymentReplicationSpec) Validate() error
Validate the given spec, returning an error on validation problems or nil if all ok.
type DeploymentReplicationStatus ¶
type DeploymentReplicationStatus struct {
// Phase holds the current lifetime phase of the deployment replication
Phase DeploymentReplicationPhase `json:"phase,omitempty"`
// Reason contains a human readable reason for reaching the current phase (can be empty)
Reason string `json:"reason,omitempty"` // Reason for current phase
// Conditions specific to the entire deployment replication
Conditions ConditionList `json:"conditions,omitempty"`
// Deprecated: this field will be removed in future versions
// Source contains the detailed status of the source endpoint
Source EndpointStatus `json:"source"`
// Deprecated: this field will be removed in future versions
// Destination contains the detailed status of the destination endpoint
Destination EndpointStatus `json:"destination"`
// Deprecated: this field will not be updated anymore
// CancelFailures records the number of times that the configuration was canceled
// which resulted in an error.
CancelFailures int `json:"cancel-failures,omitempty"`
// IncomingSynchronization contains the incoming synchronization status for all databases
IncomingSynchronization SynchronizationStatus `json:"incoming-synchronization,omitempty"`
}
DeploymentReplicationStatus contains the status part of an ArangoDeploymentReplication.
func (*DeploymentReplicationStatus) DeepCopy ¶
func (in *DeploymentReplicationStatus) DeepCopy() *DeploymentReplicationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeploymentReplicationStatus.
func (*DeploymentReplicationStatus) DeepCopyInto ¶
func (in *DeploymentReplicationStatus) DeepCopyInto(out *DeploymentReplicationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EndpointAuthenticationSpec ¶
type EndpointAuthenticationSpec struct {
// KeyfileSecretName holds the name of a Secret containing a client authentication
// certificate formatted at keyfile in a `tls.keyfile` field.
KeyfileSecretName *string `json:"keyfileSecretName,omitempty"`
// UserSecretName holds the name of a Secret containing a `username` & `password`
// field used for basic authentication.
// The user identified by the username must have write access in the `_system` database
// of the ArangoDB cluster at the endpoint.
UserSecretName *string `json:"userSecretName,omitempty"`
}
EndpointAuthenticationSpec contains the specification to authentication with the syncmasters in either source or destination endpoint.
func (*EndpointAuthenticationSpec) DeepCopy ¶
func (in *EndpointAuthenticationSpec) DeepCopy() *EndpointAuthenticationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointAuthenticationSpec.
func (*EndpointAuthenticationSpec) DeepCopyInto ¶
func (in *EndpointAuthenticationSpec) DeepCopyInto(out *EndpointAuthenticationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (EndpointAuthenticationSpec) GetKeyfileSecretName ¶
func (s EndpointAuthenticationSpec) GetKeyfileSecretName() string
GetKeyfileSecretName returns the value of keyfileSecretName.
func (EndpointAuthenticationSpec) GetUserSecretName ¶
func (s EndpointAuthenticationSpec) GetUserSecretName() string
GetUserSecretName returns the value of userSecretName.
func (EndpointAuthenticationSpec) ResetImmutableFields ¶
func (s EndpointAuthenticationSpec) ResetImmutableFields(target *EndpointAuthenticationSpec, fieldPrefix string) []string
ResetImmutableFields replaces all immutable fields in the given target with values from the source spec. It returns a list of fields that have been reset. Field names are relative to `spec.`.
func (*EndpointAuthenticationSpec) SetDefaults ¶
func (s *EndpointAuthenticationSpec) SetDefaults()
SetDefaults fills empty field with default values.
func (*EndpointAuthenticationSpec) SetDefaultsFrom ¶
func (s *EndpointAuthenticationSpec) SetDefaultsFrom(source EndpointAuthenticationSpec)
SetDefaultsFrom fills empty field with default values from the given source.
func (EndpointAuthenticationSpec) Validate ¶
func (s EndpointAuthenticationSpec) Validate(keyfileSecretNameRequired bool) error
Validate the given spec, returning an error on validation problems or nil if all ok.
type EndpointSpec ¶
type EndpointSpec struct {
// DeploymentName holds the name of an ArangoDeployment resource.
// If set this provides default values for masterEndpoint, auth & tls.
DeploymentName *string `json:"deploymentName,omitempty"`
// MasterEndpoint holds a list of URLs used to reach the syncmaster(s).
MasterEndpoint []string `json:"masterEndpoint,omitempty"`
// Authentication holds settings needed to authentication at the syncmaster.
Authentication EndpointAuthenticationSpec `json:"auth"`
// TLS holds settings needed to verify the TLS connection to the syncmaster.
TLS EndpointTLSSpec `json:"tls"`
}
EndpointSpec contains the specification used to reach the syncmasters in either source or destination mode.
func (*EndpointSpec) DeepCopy ¶
func (in *EndpointSpec) DeepCopy() *EndpointSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSpec.
func (*EndpointSpec) DeepCopyInto ¶
func (in *EndpointSpec) DeepCopyInto(out *EndpointSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (EndpointSpec) GetDeploymentName ¶
func (s EndpointSpec) GetDeploymentName() string
GetDeploymentName returns the value of deploymentName.
func (EndpointSpec) HasDeploymentName ¶
func (s EndpointSpec) HasDeploymentName() bool
HasDeploymentName returns the true when a non-empty deployment name it set.
func (EndpointSpec) ResetImmutableFields ¶
func (s EndpointSpec) ResetImmutableFields(target *EndpointSpec, fieldPrefix string) []string
ResetImmutableFields replaces all immutable fields in the given target with values from the source spec. It returns a list of fields that have been reset. Field names are relative to `spec.`.
func (*EndpointSpec) SetDefaults ¶
func (s *EndpointSpec) SetDefaults()
SetDefaults fills empty field with default values.
func (*EndpointSpec) SetDefaultsFrom ¶
func (s *EndpointSpec) SetDefaultsFrom(source EndpointSpec)
SetDefaultsFrom fills empty field with default values from the given source.
func (EndpointSpec) Validate ¶
func (s EndpointSpec) Validate(isSourceEndpoint bool) error
Validate the given spec, returning an error on validation problems or nil if all ok.
type EndpointStatus ¶
type EndpointStatus struct {
// Databases holds the replication status of all databases from the point of view of this endpoint.
// List is ordered by name of the database.
Databases []DatabaseStatus `json:"databases,omitempty"`
}
EndpointStatus contains the status of either the source or destination endpoint. Deprecated
func (*EndpointStatus) DeepCopy ¶
func (in *EndpointStatus) DeepCopy() *EndpointStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointStatus.
func (*EndpointStatus) DeepCopyInto ¶
func (in *EndpointStatus) DeepCopyInto(out *EndpointStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EndpointTLSSpec ¶
type EndpointTLSSpec struct {
// CASecretName holds the name of a Secret containing a ca.crt public key for TLS validation.
CASecretName *string `json:"caSecretName,omitempty"`
}
EndpointTLSSpec contains the specification regarding the TLS connection to the syncmasters in either source or destination endpoint.
func (*EndpointTLSSpec) DeepCopy ¶
func (in *EndpointTLSSpec) DeepCopy() *EndpointTLSSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointTLSSpec.
func (*EndpointTLSSpec) DeepCopyInto ¶
func (in *EndpointTLSSpec) DeepCopyInto(out *EndpointTLSSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (EndpointTLSSpec) GetCASecretName ¶
func (s EndpointTLSSpec) GetCASecretName() string
GetCASecretName returns the value of caSecretName.
func (EndpointTLSSpec) ResetImmutableFields ¶
func (s EndpointTLSSpec) ResetImmutableFields(target *EndpointTLSSpec, fieldPrefix string) []string
ResetImmutableFields replaces all immutable fields in the given target with values from the source spec. It returns a list of fields that have been reset. Field names are relative to `spec.`.
func (*EndpointTLSSpec) SetDefaults ¶
func (s *EndpointTLSSpec) SetDefaults()
SetDefaults fills empty field with default values.
func (*EndpointTLSSpec) SetDefaultsFrom ¶
func (s *EndpointTLSSpec) SetDefaultsFrom(source EndpointTLSSpec)
SetDefaultsFrom fills empty field with default values from the given source.
func (EndpointTLSSpec) Validate ¶
func (s EndpointTLSSpec) Validate(caSecretNameRequired bool) error
Validate the given spec, returning an error on validation problems or nil if all ok.
type ShardStatus ¶
type ShardStatus struct {
Status string `json:"status"`
}
ShardStatus contains the status of a single shard. Deprecated
func (*ShardStatus) DeepCopy ¶
func (in *ShardStatus) DeepCopy() *ShardStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ShardStatus.
func (*ShardStatus) DeepCopyInto ¶
func (in *ShardStatus) DeepCopyInto(out *ShardStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SynchronizationStatus ¶
type SynchronizationStatus struct {
// Databases holds the synchronization status for each database.
Databases map[string]DatabaseSynchronizationStatus `json:"databases,omitempty"`
// Progress the value in percents showing the progress of synchronization
Progress float32 `json:"progress,omitempty"`
// AllInSync is true if target cluster is fully in-sync with source cluster
AllInSync bool `json:"allInSync,omitempty"`
// Error contains an error description if there is an error preventing synchronization
Error string `json:"error,omitempty"`
}
SynchronizationStatus contains the synchronization status of replication for all databases
func (*SynchronizationStatus) DeepCopy ¶
func (in *SynchronizationStatus) DeepCopy() *SynchronizationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SynchronizationStatus.
func (*SynchronizationStatus) DeepCopyInto ¶
func (in *SynchronizationStatus) DeepCopyInto(out *SynchronizationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files
¶
- collection_status.go
- conditions.go
- database_status.go
- database_synchronization_status.go
- doc.go
- endpoint_authentication_spec.go
- endpoint_spec.go
- endpoint_status.go
- endpoint_tls_spec.go
- errors.go
- register.go
- replication.go
- replication_phase.go
- replication_spec.go
- replication_status.go
- shard_status.go
- synchronization_status.go
- zz_generated.deepcopy.go