mirror of
https://github.com/zrepl/zrepl.git
synced 2025-01-08 07:19:02 +01:00
30cdc1430e
This commit
- adds a configuration in which no step holds, replication cursors, etc. are created
- removes the send.step_holds.disable_incremental setting
- creates a new config option `replication` for active-side jobs
- adds the replication.protection.{initial,incremental} settings, each
of which can have values
- `guarantee_resumability`
- `guarantee_incremental`
- `guarantee_nothing`
(refer to docs/configuration/replication.rst for semantics)
The `replication` config from an active side is sent to both endpoint.Sender and endpoint.Receiver
for each replication step. Sender and Receiver then act accordingly.
For `guarantee_incremental`, we add the new `tentative-replication-cursor` abstraction.
The necessity for that abstraction is outlined in https://github.com/zrepl/zrepl/issues/340.
fixes https://github.com/zrepl/zrepl/issues/340
43 lines
1.3 KiB
Go
43 lines
1.3 KiB
Go
package logic
|
|
|
|
import (
|
|
"github.com/pkg/errors"
|
|
"github.com/zrepl/zrepl/config"
|
|
"github.com/zrepl/zrepl/replication/logic/pdu"
|
|
)
|
|
|
|
type PlannerPolicy struct {
|
|
EncryptedSend tri // all sends must be encrypted (send -w, and encryption!=off)
|
|
ReplicationConfig pdu.ReplicationConfig
|
|
}
|
|
|
|
func ReplicationConfigFromConfig(in *config.Replication) (*pdu.ReplicationConfig, error) {
|
|
initial, err := pduReplicationGuaranteeKindFromConfig(in.Protection.Initial)
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "field 'initial'")
|
|
}
|
|
incremental, err := pduReplicationGuaranteeKindFromConfig(in.Protection.Incremental)
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "field 'incremental'")
|
|
}
|
|
return &pdu.ReplicationConfig{
|
|
Protection: &pdu.ReplicationConfigProtection{
|
|
Initial: initial,
|
|
Incremental: incremental,
|
|
},
|
|
}, nil
|
|
}
|
|
|
|
func pduReplicationGuaranteeKindFromConfig(in string) (k pdu.ReplicationGuaranteeKind, _ error) {
|
|
switch in {
|
|
case "guarantee_nothing":
|
|
return pdu.ReplicationGuaranteeKind_GuaranteeNothing, nil
|
|
case "guarantee_incremental":
|
|
return pdu.ReplicationGuaranteeKind_GuaranteeIncrementalReplication, nil
|
|
case "guarantee_resumability":
|
|
return pdu.ReplicationGuaranteeKind_GuaranteeResumability, nil
|
|
default:
|
|
return k, errors.Errorf("%q is not in guarantee_{nothing,incremental,resumability}", in)
|
|
}
|
|
}
|