types

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"`

	WorkflowType                         string        `yaml:"workflowType"`
	WorkflowID                           string        `yaml:"workflowID"`
	WorkflowExecutionStartToCloseTimeout time.Duration `yaml:"workflowExecutionStartToCloseTimeout"`
	WorkflowDuration                     time.Duration `yaml:"workflowDuration"`
	ActivityCount                        int           `yaml:"activityCount"`

	EventID int64 `yaml:"eventID"`

	Domain            string   `yaml:"domain"`
	NewActiveClusters []string `yaml:"newActiveClusters"`
	FailoverTimeout   *int32   `yaml:"failoverTimeoutSec"`

	Want Validation `yaml:"want"`
}

type ReplicationDomainConfig struct {
	Name string `yaml:"name"`

	// ActiveClusters is the list of clusters that the test domain is active in
	// If one cluster is specified, the test domain will be regular active-passive global domain.
	// If multiple clusters are specified, the test domain will be active-active global domain.
	ActiveClusters []string `yaml:"activeClusters"`
}

type ReplicationSimulationConfig struct {
	// Clusters is the map of all clusters
	Clusters map[string]*Cluster `yaml:"clusters"`

	// PrimaryCluster is used for domain registration
	PrimaryCluster string `yaml:"primaryCluster"`

	Domains map[string]ReplicationDomainConfig `yaml:"domains"`

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

type ReplicationSimulationOperation string

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

type WorkflowInput struct {
	Duration      time.Duration
	ActivityCount int
}

type WorkflowOutput struct {
	Count int
}