types

Documentation

Index

• Constants
• func Logf(t *testing.T, msg string, args ...interface{})
• func WorkerIdentityFor(clusterName string) string
• type Cluster
• type Operation
• type ReplicationSimulationConfig
  • func LoadConfig() (*ReplicationSimulationConfig, error)
  • func (s *ReplicationSimulationConfig) MustGetFrontendClient(t *testing.T, clusterName string) frontend.Client
  • func (s *ReplicationSimulationConfig) MustInitClientsFor(t *testing.T, clusterName string)
  • func (s *ReplicationSimulationConfig) MustRegisterDomain(t *testing.T)
• type ReplicationSimulationOperation
• type Validation
• type WorkflowInput
• type WorkflowOutput

Constants

const (
	DefaultTestCase = "testdata/replication_simulation_default.yaml"
	DomainName      = "test-domain"
	TasklistName    = "test-tasklist"
	WorkflowName    = "test-workflow"
	ActivityName    = "test-activity"

	TimerInterval = 5 * time.Second
)

Functions

func Logf

func Logf(t *testing.T, msg string, args ...interface{})

func WorkerIdentityFor

func WorkerIdentityFor(clusterName string) string

Types

type Cluster

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

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

type Operation

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

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

	PrimaryCluster string `yaml:"primaryCluster"`

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

func LoadConfig

func LoadConfig() (*ReplicationSimulationConfig, error)

func (*ReplicationSimulationConfig) MustGetFrontendClient

func (s *ReplicationSimulationConfig) MustGetFrontendClient(t *testing.T, clusterName string) frontend.Client

func (*ReplicationSimulationConfig) MustInitClientsFor

func (s *ReplicationSimulationConfig) MustInitClientsFor(t *testing.T, clusterName string)

func (*ReplicationSimulationConfig) MustRegisterDomain

func (s *ReplicationSimulationConfig) MustRegisterDomain(t *testing.T)

type ReplicationSimulationOperation

type ReplicationSimulationOperation string

const (
	ReplicationSimulationOperationStartWorkflow ReplicationSimulationOperation = "start_workflow"
	ReplicationSimulationOperationFailover      ReplicationSimulationOperation = "failover"
	ReplicationSimulationOperationValidate      ReplicationSimulationOperation = "validate"
)

type Validation

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

type WorkflowInput

type WorkflowInput struct {
	Duration time.Duration
}

type WorkflowOutput

type WorkflowOutput struct {
	Count int
}