replication

type Cluster struct {
	GRPCEndpoint string `yaml:"grpcEndpoint"`

	AdminClient    admin.Client    `yaml:"-"`
	FrontendClient frontend.Client `yaml:"-"`
}

type Operation struct {
	Type    ReplicationSimulationOperation `yaml:"op"`
	At      time.Duration                  `yaml:"at"`
	Cluster string                         `yaml:"cluster"`

	WorkflowID       string        `yaml:"workflowID"`
	WorkflowDuration time.Duration `yaml:"workflowDuration"`

	NewActiveCluster   string `yaml:"newActiveCluster"`
	FailovertimeoutSec *int32 `yaml:"failoverTimeoutSec"`

	Want Validation `yaml:"want"`
}

type ReplicationSimulationConfig struct {
	Clusters map[string]*Cluster `yaml:"clusters"`

	PrimaryCluster string `yaml:"primaryCluster"`

	Operations []*Operation `yaml:"operations"`
}

type ReplicationSimulationOperation string

type Validation struct {
	Status                      string `yaml:"status"`
	StartedByWorkersInCluster   string `yaml:"startedByWorkersInCluster"`
	CompletedByWorkersInCluster string `yaml:"completedByWorkersInCluster"`
}

type WorkflowInput struct {
	Duration time.Duration
}

type WorkflowOutput struct {
	Count int
}