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 was canceled 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 = "v1"
)
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. // If `userSecretName` has not been set, // the client authentication certificate found in the secret with this name is also used to configure // the synchronization and fetch the synchronization status. 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) // Use this setting if the source cluster is not running inside a Kubernetes cluster // that is reachable from the Kubernetes cluster the `ArangoDeploymentReplication` resource is deployed in. // Specifying this setting and `deploymentName` at the same time is not allowed. // +doc/default: [] 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. // This setting is required, unless `deploymentName` has been set. 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