dependency

Documentation

Index

• func WithExternalDependencies(f func(input *go_hook.HookInput, dc Container) error) func(input *go_hook.HookInput) error
• type Container
  • func NewDependencyContainer() Container
• type MockedContainer
  • func NewMockedContainer() *MockedContainer
  • func (c *MockedContainer) GetClientConfig() (*rest.Config, error)
  • func (c *MockedContainer) GetClock() clockwork.Clock
  • func (c *MockedContainer) GetEtcdClient(_ []string, _ ...etcd.Option) (etcd.Client, error)
  • func (c *MockedContainer) GetFakeClock() clockwork.FakeClock
  • func (c *MockedContainer) GetHTTPClient(_ ...http.Option) http.Client
  • func (c *MockedContainer) GetHelmClient(_ string, _ ...helm.Option) (helm.Client, error)
  • func (c *MockedContainer) GetK8sClient(_ ...k8s.Option) (k8s.Client, error)
  • func (c *MockedContainer) GetRegistryClient(_ string, _ ...cr.Option) (cr.Client, error)
  • func (c *MockedContainer) GetVsphereClient(_ *vsphere.ProviderClusterConfiguration) (vsphere.Client, error)
  • func (c *MockedContainer) MustGetEtcdClient(_ []string, _ ...etcd.Option) etcd.Client
  • func (c *MockedContainer) MustGetK8sClient(options ...k8s.Option) k8s.Client
  • func (c *MockedContainer) SetK8sVersion(ver k8s.FakeClusterVersion)

Functions

func WithExternalDependencies

func WithExternalDependencies(f func(input *go_hook.HookInput, dc Container) error) func(input *go_hook.HookInput) error

WithExternalDependencies decorate function with external dependencies

Types

type Container

type Container interface {
	GetHTTPClient(options ...http.Option) http.Client
	GetEtcdClient(endpoints []string, options ...etcd.Option) (etcd.Client, error)
	MustGetEtcdClient(endpoints []string, options ...etcd.Option) etcd.Client
	GetK8sClient(options ...k8s.Option) (k8s.Client, error)
	MustGetK8sClient(options ...k8s.Option) k8s.Client
	GetRegistryClient(repo string, options ...cr.Option) (cr.Client, error)
	GetVsphereClient(config *vsphere.ProviderClusterConfiguration) (vsphere.Client, error)
	GetHelmClient(namespace string, options ...helm.Option) (helm.Client, error)
	GetClientConfig() (*rest.Config, error)
	GetClock() clockwork.Clock
}

Container with external dependencies

func NewDependencyContainer

func NewDependencyContainer() Container

NewDependencyContainer creates new Dependency container with external clients

type MockedContainer

type MockedContainer struct {
	HelmClient    *helm.ClientMock
	HTTPClient    *http.ClientMock
	EtcdClient    *etcd.ClientMock
	K8sClient     k8s.Client
	CRClient      *cr.ClientMock
	VsphereClient *vsphere.ClientMock
	// contains filtered or unexported fields
}

Mocks

var (
	TestDC       *MockedContainer
	TestTimeZone = time.UTC
)

func NewMockedContainer

func NewMockedContainer() *MockedContainer

func (*MockedContainer) GetClientConfig

func (c *MockedContainer) GetClientConfig() (*rest.Config, error)

func (*MockedContainer) GetClock

func (c *MockedContainer) GetClock() clockwork.Clock

func (*MockedContainer) GetEtcdClient

func (c *MockedContainer) GetEtcdClient(_ []string, _ ...etcd.Option) (etcd.Client, error)

func (*MockedContainer) GetFakeClock

func (c *MockedContainer) GetFakeClock() clockwork.FakeClock

func (*MockedContainer) GetHTTPClient

func (c *MockedContainer) GetHTTPClient(_ ...http.Option) http.Client

func (*MockedContainer) GetHelmClient

func (c *MockedContainer) GetHelmClient(_ string, _ ...helm.Option) (helm.Client, error)

func (*MockedContainer) GetK8sClient

func (c *MockedContainer) GetK8sClient(_ ...k8s.Option) (k8s.Client, error)

func (*MockedContainer) GetRegistryClient

func (c *MockedContainer) GetRegistryClient(_ string, _ ...cr.Option) (cr.Client, error)

func (*MockedContainer) GetVsphereClient

func (c *MockedContainer) GetVsphereClient(_ *vsphere.ProviderClusterConfiguration) (vsphere.Client, error)

func (*MockedContainer) MustGetEtcdClient

func (c *MockedContainer) MustGetEtcdClient(_ []string, _ ...etcd.Option) etcd.Client

func (*MockedContainer) MustGetK8sClient

func (c *MockedContainer) MustGetK8sClient(options ...k8s.Option) k8s.Client

func (*MockedContainer) SetK8sVersion

func (c *MockedContainer) SetK8sVersion(ver k8s.FakeClusterVersion)

SetK8sVersion change FakeCluster versions. KubeClient returns with resources of specified version