consulrunner

Documentation

Index

• Constants
• type ClusterRunner
  • func NewClusterRunner(c ClusterRunnerConfig) *ClusterRunner
  • func (cr *ClusterRunner) Address() string
  • func (cr *ClusterRunner) ConsulCluster() string
  • func (cr *ClusterRunner) ConsulVersion() string
  • func (cr *ClusterRunner) HasPerformanceFlag() bool
  • func (cr *ClusterRunner) NewClient() consuladapter.Client
  • func (cr *ClusterRunner) Reset() error
  • func (cr *ClusterRunner) SessionTTL() time.Duration
  • func (cr *ClusterRunner) Start()
  • func (cr *ClusterRunner) Stop()
  • func (cr *ClusterRunner) URL() string
  • func (cr *ClusterRunner) WaitUntilReady()
• type ClusterRunnerConfig

Constants

const (
	PortOffsetHTTP
	PortOffsetHTTPS

	PortOffsetLength
)

Types

type ClusterRunner

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

func NewClusterRunner

func NewClusterRunner(c ClusterRunnerConfig) *ClusterRunner

func (*ClusterRunner) Address

func (cr *ClusterRunner) Address() string

func (*ClusterRunner) ConsulCluster

func (cr *ClusterRunner) ConsulCluster() string

func (*ClusterRunner) ConsulVersion

func (cr *ClusterRunner) ConsulVersion() string

func (*ClusterRunner) HasPerformanceFlag

func (cr *ClusterRunner) HasPerformanceFlag() bool

func (*ClusterRunner) NewClient

func (cr *ClusterRunner) NewClient() consuladapter.Client

func (*ClusterRunner) Reset

func (cr *ClusterRunner) Reset() error

func (*ClusterRunner) SessionTTL

func (cr *ClusterRunner) SessionTTL() time.Duration

func (*ClusterRunner) Start

func (cr *ClusterRunner) Start()

func (*ClusterRunner) Stop

func (cr *ClusterRunner) Stop()

func (*ClusterRunner) URL

func (cr *ClusterRunner) URL() string

func (*ClusterRunner) WaitUntilReady

func (cr *ClusterRunner) WaitUntilReady()

type ClusterRunnerConfig

type ClusterRunnerConfig struct {
	StartingPort int
	NumNodes     int
	Scheme       string
	CACert       string
	ClientCert   string
	ClientKey    string
}