kubefactory

Documentation

Overview

Package kubefactory implement some minimal kubernetes runtime.

Index

• type Etcd
  • func NewEmbeddedEtcd(ctx context.Context, path string, logger *zap.Logger) (*Etcd, error)
  • func (e *Etcd) Client() *clientv3.Client
  • func (e *Etcd) Stop() error
• type Kubernetes
  • func New(ctx context.Context, dataDir string, logger *zap.Logger) (*Kubernetes, error)
  • func (k *Kubernetes) DeleteEtcdState(ctx context.Context, clusterID string) error
  • func (k *Kubernetes) RunAPIService(ctx context.Context, address, iface, machineID, clusterID string) error

Types

type Etcd

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

Etcd represents a single running embedded etcd server.

func NewEmbeddedEtcd

func NewEmbeddedEtcd(ctx context.Context, path string, logger *zap.Logger) (*Etcd, error)

NewEmbeddedEtcd creates new embedded etcd instance.

func (*Etcd) Client

func (e *Etcd) Client() *clientv3.Client

Client creates a client for the server.

func (*Etcd) Stop

func (e *Etcd) Stop() error

Stop the etcd server.

type Kubernetes

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

Kubernetes is a mini fake kubelet.

func New

func New(ctx context.Context, dataDir string, logger *zap.Logger) (*Kubernetes, error)

New creates a kubernetes simulator.

func (*Kubernetes) DeleteEtcdState

func (k *Kubernetes) DeleteEtcdState(ctx context.Context, clusterID string) error

DeleteEtcdState removes all keys related to the cluster with the specified id.

func (*Kubernetes) RunAPIService

func (k *Kubernetes) RunAPIService(ctx context.Context, address, iface, machineID, clusterID string) error

RunAPIService spawns an api service on the specified address and using etcd state for the cluster ID.