fake_core

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 1, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Action

type Action struct {
	NowFn                func() error
	AsyncFn              func() error
	CancellableWaitForFn func(string, time.Duration, time.Duration, func() (bool, error)) error
	GetStatusFn          func() *model.ActionStatus
}

func (*Action) Async

func (a *Action) Async() error

func (*Action) CancellableWaitFor

func (a *Action) CancellableWaitFor(desc string, d time.Duration, i time.Duration, fn func() (bool, error)) error

func (*Action) GetStatus

func (a *Action) GetStatus() *model.ActionStatus

func (*Action) Now

func (a *Action) Now() error

type DB

type DB struct {
	CreateFn  func(model.Model) error
	SaveFn    func(model.Model) error
	FindFn    func(out interface{}, where ...interface{}) error
	FirstFn   func(out interface{}, where ...interface{}) error
	DeleteFn  func(m model.Model) error
	PreloadFn func(column string, conditions ...interface{}) core.DBInterface
	WhereFn   func(query interface{}, args ...interface{}) core.DBInterface
	LimitFn   func(limit interface{}) core.DBInterface
	OffsetFn  func(offset interface{}) core.DBInterface
	ModelFn   func(value interface{}) core.DBInterface
	UpdateFn  func(attrs ...interface{}) error
	CountFn   func(interface{}) error
}

func (*DB) Count

func (db *DB) Count(value interface{}) error

func (*DB) Create

func (db *DB) Create(m model.Model) error

func (*DB) Delete

func (db *DB) Delete(m model.Model) error

func (*DB) Find

func (db *DB) Find(out interface{}, where ...interface{}) error

func (*DB) First

func (db *DB) First(out interface{}, where ...interface{}) error

func (*DB) Limit

func (db *DB) Limit(limit interface{}) core.DBInterface

func (*DB) Model

func (db *DB) Model(value interface{}) core.DBInterface

func (*DB) Offset

func (db *DB) Offset(offset interface{}) core.DBInterface

func (*DB) Preload

func (db *DB) Preload(column string, conditions ...interface{}) core.DBInterface

func (*DB) Save

func (db *DB) Save(m model.Model) error

func (*DB) Update

func (db *DB) Update(attrs ...interface{}) error

func (*DB) Where

func (db *DB) Where(query interface{}, args ...interface{}) core.DBInterface

type KubeResources

type KubeResources struct {
	PopulateFn        func() error
	CreateFn          func(*model.KubeResource) error
	GetFn             func(*int64, model.Model) error
	GetWithIncludesFn func(*int64, model.Model, []string) error
	UpdateFn          func(*int64, *model.KubeResource, *model.KubeResource) error
	DeleteFn          func(*int64, *model.KubeResource) core.ActionInterface
	StartFn           func(*int64, *model.KubeResource) core.ActionInterface
	StopFn            func(*int64, *model.KubeResource) core.ActionInterface
	RefreshFn         func(*model.KubeResource) error
}

func (*KubeResources) Create

func (c *KubeResources) Create(m *model.KubeResource) error

func (*KubeResources) Delete

func (*KubeResources) Get

func (c *KubeResources) Get(id *int64, m model.Model) error

func (*KubeResources) GetWithIncludes

func (c *KubeResources) GetWithIncludes(id *int64, m model.Model, includes []string) error

func (*KubeResources) Populate added in v0.14.0

func (c *KubeResources) Populate() error

func (*KubeResources) Refresh

func (c *KubeResources) Refresh(m *model.KubeResource) error

func (*KubeResources) Start

func (*KubeResources) Stop

func (*KubeResources) Update

func (c *KubeResources) Update(id *int64, oldM *model.KubeResource, m *model.KubeResource) error

type KubernetesClient

type KubernetesClient struct {
	EnsureNamespaceFn                func(name string) error
	GetResourceFn                    func(apiVersion, kind, namespace, name string, out interface{}) error
	CreateResourceFn                 func(apiVersion, kind, namespace string, in, out interface{}) error
	UpdateResourceFn                 func(apiVersion, kind, namespace, name string, objIn interface{}, out interface{}) error
	DeleteResourceFn                 func(apiVersion, kind, namespace, name string) error
	ListNamespacesFn                 func(query string) ([]*kubernetes.Namespace, error)
	ListEventsFn                     func(query string) ([]*kubernetes.Event, error)
	ListNodesFn                      func(query string) ([]*kubernetes.Node, error)
	ListPodsFn                       func(query string) ([]*kubernetes.Pod, error)
	ListServicesFn                   func(query string) ([]*kubernetes.Service, error)
	ListPersistentVolumesFn          func(query string) ([]*kubernetes.PersistentVolume, error)
	ListNodeHeapsterStatsFn          func(node string) ([]string, error)
	ListPodHeapsterCPUUsageMetricsFn func(namespace, name string) ([]*kubernetes.HeapsterMetric, error)
	ListPodHeapsterRAMUsageMetricsFn func(namespace, name string) ([]*kubernetes.HeapsterMetric, error)
	GetPodLogFn                      func(namespace, name string) (string, error)
	GetKubeHeapsterStatsfn           func(metricPath string) (kubernetes.HeapsterMetrics, error)
	GetNodeHeapsterStatsfn           func(node string, metricPath string) (kubernetes.HeapsterMetrics, error)
	ListKubeHeapsterStatsfn          func() ([]string, error)
}

func (*KubernetesClient) CreateResource

func (k *KubernetesClient) CreateResource(apiVersion string, kind string, namespace string, objIn interface{}, out interface{}) error

func (*KubernetesClient) DeleteResource

func (k *KubernetesClient) DeleteResource(apiVersion string, kind string, namespace string, name string) error

func (*KubernetesClient) EnsureNamespace

func (k *KubernetesClient) EnsureNamespace(name string) error

func (*KubernetesClient) GetKubeHeapsterStats added in v1.0.0

func (k *KubernetesClient) GetKubeHeapsterStats(metricPath string) (kubernetes.HeapsterMetrics, error)

func (*KubernetesClient) GetNodeHeapsterStats added in v1.0.0

func (k *KubernetesClient) GetNodeHeapsterStats(node string, metricPath string) (kubernetes.HeapsterMetrics, error)

func (*KubernetesClient) GetPodLog added in v0.14.0

func (k *KubernetesClient) GetPodLog(namespace string, name string) (string, error)

func (*KubernetesClient) GetResource

func (k *KubernetesClient) GetResource(apiVersion string, kind string, namespace string, name string, out interface{}) error

func (*KubernetesClient) ListEvents

func (k *KubernetesClient) ListEvents(query string) ([]*kubernetes.Event, error)

func (*KubernetesClient) ListKubeHeapsterStats added in v1.0.0

func (k *KubernetesClient) ListKubeHeapsterStats() ([]string, error)

func (*KubernetesClient) ListNamespaces

func (k *KubernetesClient) ListNamespaces(query string) ([]*kubernetes.Namespace, error)

func (*KubernetesClient) ListNodeHeapsterStats

func (k *KubernetesClient) ListNodeHeapsterStats(node string) ([]string, error)

func (*KubernetesClient) ListNodes

func (k *KubernetesClient) ListNodes(query string) ([]*kubernetes.Node, error)

func (*KubernetesClient) ListPersistentVolumes added in v0.14.0

func (k *KubernetesClient) ListPersistentVolumes(query string) ([]*kubernetes.PersistentVolume, error)

func (*KubernetesClient) ListPodHeapsterCPUUsageMetrics

func (k *KubernetesClient) ListPodHeapsterCPUUsageMetrics(namespace string, name string) ([]*kubernetes.HeapsterMetric, error)

func (*KubernetesClient) ListPodHeapsterRAMUsageMetrics

func (k *KubernetesClient) ListPodHeapsterRAMUsageMetrics(namespace string, name string) ([]*kubernetes.HeapsterMetric, error)

func (*KubernetesClient) ListPods

func (k *KubernetesClient) ListPods(query string) ([]*kubernetes.Pod, error)

func (*KubernetesClient) ListServices added in v0.14.0

func (k *KubernetesClient) ListServices(query string) ([]*kubernetes.Service, error)

func (*KubernetesClient) UpdateResource added in v0.14.0

func (k *KubernetesClient) UpdateResource(apiVersion string, kind string, namespace string, name string, objIn interface{}, out interface{}) error

type Nodes added in v0.11.2

type Nodes struct {
	CreateFn                       func(*model.Node) error
	ProvisionFn                    func(*int64, *model.Node) core.ActionInterface
	GetFn                          func(*int64, model.Model) error
	GetWithIncludesFn              func(*int64, model.Model, []string) error
	UpdateFn                       func(*int64, model.Model, model.Model) error
	DeleteFn                       func(*int64, *model.Node) core.ActionInterface
	HasPodsWithReservedResourcesFn func(*model.Node) (bool, error)
}

func (*Nodes) Create added in v0.11.2

func (c *Nodes) Create(m *model.Node) error

func (*Nodes) Delete added in v0.11.2

func (c *Nodes) Delete(id *int64, m *model.Node) core.ActionInterface

func (*Nodes) Get added in v0.11.2

func (c *Nodes) Get(id *int64, m model.Model) error

func (*Nodes) GetWithIncludes added in v0.11.2

func (c *Nodes) GetWithIncludes(id *int64, m model.Model, includes []string) error

func (*Nodes) HasPodsWithReservedResources added in v0.11.2

func (c *Nodes) HasPodsWithReservedResources(m *model.Node) (bool, error)

func (*Nodes) Provision added in v0.11.4

func (c *Nodes) Provision(id *int64, m *model.Node) core.ActionInterface

func (*Nodes) Update added in v0.11.2

func (c *Nodes) Update(id *int64, oldM model.Model, m model.Model) error

type Provider

type Provider struct {
	ValidateAccountFn    func(*model.CloudAccount) error
	CreateKubeFn         func(*model.Kube, *core.Action) error
	DeleteKubeFn         func(*model.Kube, *core.Action) error
	CreateNodeFn         func(*model.Node, *core.Action) error
	DeleteNodeFn         func(*model.Node, *core.Action) error
	CreateLoadBalancerFn func(*model.LoadBalancer, *core.Action) error
	UpdateLoadBalancerFn func(*model.LoadBalancer, *core.Action) error
	DeleteLoadBalancerFn func(*model.LoadBalancer, *core.Action) error
}

func (*Provider) CreateKube

func (p *Provider) CreateKube(m *model.Kube, a *core.Action) error

func (*Provider) CreateLoadBalancer added in v0.14.0

func (p *Provider) CreateLoadBalancer(m *model.LoadBalancer, a *core.Action) error

func (*Provider) CreateNode

func (p *Provider) CreateNode(m *model.Node, a *core.Action) error

func (*Provider) DeleteKube

func (p *Provider) DeleteKube(m *model.Kube, a *core.Action) error

func (*Provider) DeleteLoadBalancer added in v0.14.0

func (p *Provider) DeleteLoadBalancer(m *model.LoadBalancer, a *core.Action) error

func (*Provider) DeleteNode

func (p *Provider) DeleteNode(m *model.Node, a *core.Action) error

func (*Provider) UpdateLoadBalancer added in v0.14.0

func (p *Provider) UpdateLoadBalancer(m *model.LoadBalancer, a *core.Action) error

func (*Provider) ValidateAccount

func (p *Provider) ValidateAccount(m *model.CloudAccount) error

type Provisioner

type Provisioner struct {
	ProvisionFn func(*model.KubeResource) error
	IsRunningFn func(*model.KubeResource) (bool, error)
	TeardownFn  func(*model.KubeResource) error
}

func (*Provisioner) IsRunning

func (p *Provisioner) IsRunning(m *model.KubeResource) (bool, error)

func (*Provisioner) Provision

func (p *Provisioner) Provision(m *model.KubeResource) error

func (*Provisioner) Teardown

func (p *Provisioner) Teardown(m *model.KubeResource) error

type Sessions added in v0.11.2

type Sessions struct {
	ClientFn func(id string) *client.Client
	ListFn   func() []*model.Session
	CreateFn func(*model.Session) error
	GetFn    func(id string, m *model.Session) error
	DeleteFn func(id string) error
}

func (*Sessions) Client added in v0.11.2

func (f *Sessions) Client(id string) *client.Client

func (*Sessions) Create added in v0.11.2

func (f *Sessions) Create(m *model.Session) error

func (*Sessions) Delete added in v0.11.2

func (f *Sessions) Delete(id string) error

func (*Sessions) Get added in v0.11.2

func (f *Sessions) Get(id string, m *model.Session) error

func (*Sessions) List added in v0.11.2

func (f *Sessions) List() []*model.Session

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL