token

Documentation

Index

• Constants
• func AllNames(refs ...*NodeReference) []string
• func NewReplicationOptions(factor int, names ...string) (*ReplicationOptions, *ReplicaSelector)
• func NoReplication() (*ReplicationOptions, *ReplicaSelector)
• type NodeReference
  • func (r *NodeReference) AllNames() []string
  • func (r *NodeReference) Id() string
  • func (r *NodeReference) ReplicaName() string
  • func (r *NodeReference) String() string
• type ReplicaSelector
  • func (s *ReplicaSelector) All(names ...string) []string
  • func (s *ReplicaSelector) Get(name string) *NodeReference
• type ReplicationOptions
  • func (o *ReplicationOptions) For(name string) []node.Option
• type ReplicationOpts
• type TestSuite
  • func NewLocalTestSuite(sqlConfigs map[string]*common.PostgresConfig, startPort func() int, ...) *TestSuite
  • func NewTestSuite(sqlConfigs map[string]*common.PostgresConfig, startPort func() int, ...) *TestSuite
  • func (s *TestSuite) Setup()
  • func (s *TestSuite) TearDown()

Constants

const None = 0

Functions

func AllNames

func AllNames(refs ...*NodeReference) []string

func NewReplicationOptions

func NewReplicationOptions(factor int, names ...string) (*ReplicationOptions, *ReplicaSelector)

func NoReplication

func NoReplication() (*ReplicationOptions, *ReplicaSelector)

Types

type NodeReference

type NodeReference struct {
	// contains filtered or unexported fields
}

func (*NodeReference) AllNames

func (r *NodeReference) AllNames() []string

func (*NodeReference) Id

func (r *NodeReference) Id() string

func (*NodeReference) ReplicaName

func (r *NodeReference) ReplicaName() string

func (*NodeReference) String

func (r *NodeReference) String() string

type ReplicaSelector

type ReplicaSelector map[string]int

func (*ReplicaSelector) All

func (s *ReplicaSelector) All(names ...string) []string

func (*ReplicaSelector) Get

func (s *ReplicaSelector) Get(name string) *NodeReference

type ReplicationOptions

type ReplicationOptions struct {
	*integration.ReplicationOptions
}

func (*ReplicationOptions) For

func (o *ReplicationOptions) For(name string) []node.Option

type ReplicationOpts

type ReplicationOpts interface {
	For(name string) []node.Option
}

type TestSuite

type TestSuite struct {
	II *integration.Infrastructure
	// contains filtered or unexported fields
}

func NewLocalTestSuite

func NewLocalTestSuite(sqlConfigs map[string]*common.PostgresConfig, startPort func() int, topologies []api.Topology) *TestSuite

NewLocalTestSuite returns a new test suite that stores configuration data in `./testdata` and does not remove it when the test is done.

func NewTestSuite

func NewTestSuite(sqlConfigs map[string]*common.PostgresConfig, startPort func() int, topologies []api.Topology) *TestSuite

func (*TestSuite) Setup

func (s *TestSuite) Setup()

func (*TestSuite) TearDown

func (s *TestSuite) TearDown()