kcpenvtest

Documentation

Index

• type Environment
  • func NewEnvironment(apiExportEndpointSliceName string, providerWorkspaceName string, ...) *Environment
  • func (te *Environment) ApplySetup(pathToRootConfig string, config *rest.Config, setupDirectoryPath string, ...) error
  • func (te *Environment) ApplyYAML(pathToRootConfig string, config *rest.Config, pathToSetupDir string, ...) error
  • func (te *Environment) Start() (*rest.Config, string, error)
  • func (te *Environment) Stop(useExistingCluster bool) error
• type KCPServer
  • func NewKCPServer(baseDir string, binary string, pathToRoot string, log *logger.Logger) *KCPServer
  • func (s *KCPServer) Configure() *process.Arguments
  • func (s *KCPServer) Start() error
  • func (s *KCPServer) Stop() error
• type TemplateParameters

Types

type Environment

type Environment struct {
	Scheme *runtime.Scheme

	ControlPlaneStartTimeout time.Duration

	ControlPlaneStopTimeout time.Duration

	Config *rest.Config

	RelativeSetupDirectory string

	PathToRoot             string
	RelativeAssetDirectory string

	ProviderWorkspace          string
	APIExportEndpointSliceName string
	// contains filtered or unexported fields
}

func NewEnvironment

func NewEnvironment(apiExportEndpointSliceName string, providerWorkspaceName string, pathToRoot string, relativeAssetDirectory string, relativeSetupDirectory string, useExistingCluster bool, log *logger.Logger) *Environment

func (*Environment) ApplySetup

func (te *Environment) ApplySetup(pathToRootConfig string, config *rest.Config, setupDirectoryPath string, serverUrl string) error

func (*Environment) ApplyYAML

func (te *Environment) ApplyYAML(pathToRootConfig string, config *rest.Config, pathToSetupDir string, serverUrl string) error

func (*Environment) Start

func (te *Environment) Start() (*rest.Config, string, error)

func (*Environment) Stop

func (te *Environment) Stop(useExistingCluster bool) error

type KCPServer

type KCPServer struct {
	Out          io.Writer
	Err          io.Writer
	StartTimeout time.Duration
	StopTimeout  time.Duration
	Dir          string
	Binary       string
	Args         []string
	PathToRoot   string
	// contains filtered or unexported fields
}

func NewKCPServer

func NewKCPServer(baseDir string, binary string, pathToRoot string, log *logger.Logger) *KCPServer

func (*KCPServer) Configure

func (s *KCPServer) Configure() *process.Arguments

func (*KCPServer) Start

func (s *KCPServer) Start() error

func (*KCPServer) Stop

func (s *KCPServer) Stop() error

type TemplateParameters

type TemplateParameters struct {
	ApiExportRootTenancyKcpIoIdentityHash  string `json:"apiExportRootTenancyKcpIoIdentityHash"`
	ApiExportRootTopologyKcpIoIdentityHash string `json:"apiExportRootTopologyKcpIoIdentityHash"`
	ApiExportRootShardsKcpIoIdentityHash   string `json:"apiExportRootShardsKcpIoIdentityHash"`
}