mock

Documentation

Index

• Constants
• type MockProvider
  • func New() (*MockProvider, error)
  • func (m *MockProvider) AddClusterProxy(clusterId string, httpsProxy string, httpProxy string, userCABundle string) error
  • func (m *MockProvider) AddGateAgreement(clusterID string, versionGateID string) error
  • func (m *MockProvider) AddProperty(cluster *spi.Cluster, tag string, value string) error
  • func (m *MockProvider) CheckQuota(sku string) (bool, error)
  • func (m *MockProvider) CincinnatiChannel() spi.CincinnatiChannel
  • func (m *MockProvider) ClusterKubeconfig(clusterID string) ([]byte, error)
  • func (m *MockProvider) DeleteCluster(clusterID string) error
  • func (m *MockProvider) DetermineMachineType(cloudProvider string) (string, error)
  • func (m *MockProvider) Environment() string
  • func (m *MockProvider) Expire(clusterID string, duration time.Duration) error
  • func (m *MockProvider) ExtendExpiry(clusterID string, hours uint64, minutes uint64, seconds uint64) error
  • func (m *MockProvider) GetCluster(clusterID string) (*spi.Cluster, error)
  • func (m *MockProvider) GetProperty(clusterID string, property string) (string, error)
  • func (m *MockProvider) GetUpgradePolicyID(clusterID string) (string, error)
  • func (m *MockProvider) GetVersionGateID(version string, label string) (string, error)
  • func (o *MockProvider) Hibernate(id string) bool
  • func (m *MockProvider) InstallAddons(clusterID string, addonIDs []spi.AddOnID, ...) (int, error)
  • func (m *MockProvider) IsValidClusterName(clusterName string) (bool, error)
  • func (m *MockProvider) LaunchCluster(clusterName string) (string, error)
  • func (m *MockProvider) ListClusters(query string) ([]*spi.Cluster, error)
  • func (m *MockProvider) LoadUserCaBundleData(file string) (string, error)
  • func (m *MockProvider) Logs(clusterID string) (map[string][]byte, error)
  • func (m *MockProvider) Metrics(clusterID string) (bool, error)
  • func (m *MockProvider) RemoveClusterProxy(clusterId string) error
  • func (m *MockProvider) RemoveUserCABundle(clusterId string) error
  • func (o *MockProvider) Resume(id string) bool
  • func (m *MockProvider) ScaleCluster(clusterID string, numComputeNodes int) error
  • func (m *MockProvider) SetVersionList(list *spi.VersionList)
  • func (m *MockProvider) Type() string
  • func (m *MockProvider) UpdateSchedule(clusterID string, version string, t time.Time, policyID string) error
  • func (m *MockProvider) Upgrade(clusterID string, version string, t time.Time) error
  • func (m *MockProvider) UpgradeSource() spi.UpgradeSource
  • func (m *MockProvider) VersionGateLabel() string
  • func (m *MockProvider) Versions() (*spi.VersionList, error)

Constants

const (
	// MockCloudProvider indicates that the cloud provider is just a mock.
	MockCloudProvider = "mock"

	// MockRegion indicates that the region used is just a mock.
	MockRegion = "mock-region"

	// MockProduct indicates a product that is just a mock.
	MockProduct = "mock-product"
)

const (
	// Env is the mock environment.
	Env = "mock.env"
)

Types

type MockProvider

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

MockProvider for unit testing.

func New

func New() (*MockProvider, error)

New creates a new MockProvider.

func (*MockProvider) AddClusterProxy

func (m *MockProvider) AddClusterProxy(clusterId string, httpsProxy string, httpProxy string, userCABundle string) error

AddClusterProxy adds a proxy to a cluster

func (*MockProvider) AddGateAgreement

func (m *MockProvider) AddGateAgreement(clusterID string, versionGateID string) error

AddGateAgreement adds the gate agreement to the cluster for cluster upgrades

func (*MockProvider) AddProperty

func (m *MockProvider) AddProperty(cluster *spi.Cluster, tag string, value string) error

AddProperty mocks an add new cluster property operation.

func (*MockProvider) CheckQuota

func (m *MockProvider) CheckQuota(sku string) (bool, error)

CheckQuota mocks a check quota operation.

func (*MockProvider) CincinnatiChannel

func (m *MockProvider) CincinnatiChannel() spi.CincinnatiChannel

CincinnatiChannel mocks a cincinnati channel operation.

func (*MockProvider) ClusterKubeconfig

func (m *MockProvider) ClusterKubeconfig(clusterID string) ([]byte, error)

ClusterKubeconfig mocks a cluster kubeconfig operation.

func (*MockProvider) DeleteCluster

func (m *MockProvider) DeleteCluster(clusterID string) error

DeleteCluster mocks a delete cluster operation.

func (*MockProvider) DetermineMachineType

func (m *MockProvider) DetermineMachineType(cloudProvider string) (string, error)

DetermineMachineType returns a random machine type for a given cluster

func (*MockProvider) Environment

func (m *MockProvider) Environment() string

Environment mocks an environment operation.

func (*MockProvider) Expire

func (m *MockProvider) Expire(clusterID string, duration time.Duration) error

Expire mocks an expire cluster expiry operation.

func (*MockProvider) ExtendExpiry

func (m *MockProvider) ExtendExpiry(clusterID string, hours uint64, minutes uint64, seconds uint64) error

ExtendExpiry mocks an extend cluster expiry operation.

func (*MockProvider) GetCluster

func (m *MockProvider) GetCluster(clusterID string) (*spi.Cluster, error)

GetCluster mocks a get cluster operation.

func (*MockProvider) GetProperty

func (m *MockProvider) GetProperty(clusterID string, property string) (string, error)

GetProperty mocks getting a property from the properties field of an existing cluster.

func (*MockProvider) GetUpgradePolicyID

func (m *MockProvider) GetUpgradePolicyID(clusterID string) (string, error)

Get upgrade policy ID mocks fetch the upgrade policy for a cluster

func (*MockProvider) GetVersionGateID

func (m *MockProvider) GetVersionGateID(version string, label string) (string, error)

GetVersionGateID checks to see if a version gate exists for the cluster version provided

func (*MockProvider) Hibernate

func (o *MockProvider) Hibernate(id string) bool

Hibernate resumes a cluster via OCM

func (*MockProvider) InstallAddons

func (m *MockProvider) InstallAddons(clusterID string, addonIDs []spi.AddOnID, params map[spi.AddOnID]spi.AddOnParams) (int, error)

InstallAddons mocks an install addons operation.

func (*MockProvider) IsValidClusterName

func (m *MockProvider) IsValidClusterName(clusterName string) (bool, error)

IsValidClusterName mocks a validation of cluster name

func (*MockProvider) LaunchCluster

func (m *MockProvider) LaunchCluster(clusterName string) (string, error)

LaunchCluster mocks a launch cluster operation.

func (*MockProvider) ListClusters

func (m *MockProvider) ListClusters(query string) ([]*spi.Cluster, error)

ListClusters mocks a list cluster operation.

func (*MockProvider) LoadUserCaBundleData

func (m *MockProvider) LoadUserCaBundleData(file string) (string, error)

LoadUserCaBundleData loads CA contents from CA cert file

func (*MockProvider) Logs

func (m *MockProvider) Logs(clusterID string) (map[string][]byte, error)

Logs mocks a logs operation.

func (*MockProvider) Metrics

func (m *MockProvider) Metrics(clusterID string) (bool, error)

Metrics is a stub function for now

func (*MockProvider) RemoveClusterProxy

func (m *MockProvider) RemoveClusterProxy(clusterId string) error

RemoveClusterProxy removes a proxy from a cluster

func (*MockProvider) RemoveUserCABundle

func (m *MockProvider) RemoveUserCABundle(clusterId string) error

RemoveUserCABundle removes a CA Bundle from a cluster

func (*MockProvider) Resume

func (o *MockProvider) Resume(id string) bool

Resume resumes a cluster via OCM

func (*MockProvider) ScaleCluster

func (m *MockProvider) ScaleCluster(clusterID string, numComputeNodes int) error

ScaleCluster mocks a scale cluster operation.

func (*MockProvider) SetVersionList

func (m *MockProvider) SetVersionList(list *spi.VersionList)

SetVersionList lets us provide novel versions allowing us to properly flex version selection using the Mock provider

func (*MockProvider) Type

func (m *MockProvider) Type() string

Type returns the provisioner type: mock

func (*MockProvider) UpdateSchedule

func (m *MockProvider) UpdateSchedule(clusterID string, version string, t time.Time, policyID string) error

UpdateSchedule mocks reschedule the upgrade

func (*MockProvider) Upgrade

func (m *MockProvider) Upgrade(clusterID string, version string, t time.Time) error

Upgrade mocks initiates a cluster upgrade to the given version

func (*MockProvider) UpgradeSource

func (m *MockProvider) UpgradeSource() spi.UpgradeSource

UpgradeSource mocks an environment source operation.

func (*MockProvider) VersionGateLabel

func (m *MockProvider) VersionGateLabel() string

VersionGateLabel returns the provider version gate label

func (*MockProvider) Versions

func (m *MockProvider) Versions() (*spi.VersionList, error)

Versions mocks a versions operation.