calcium

package
v0.0.0-...-ff909ee Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2024 License: MIT Imports: 43 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Calcium 

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

Calcium implement the cluster

func New 

func New(ctx context.Context, config types.Config, t *testing.T) (*Calcium, error)

New returns a new cluster config

func (*Calcium) AddNode 

func (c *Calcium) AddNode(ctx context.Context, opts *types.AddNodeOptions) (*types.Node, error)

AddNode adds a node node with resource info

func (*Calcium) AddPod 

func (c *Calcium) AddPod(ctx context.Context, podname, desc string) (*types.Pod, error)

AddPod add pod

func (*Calcium) BuildImage 

func (c *Calcium) BuildImage(ctx context.Context, opts *types.BuildOptions) (ch chan *types.BuildImageMessage, err error)

BuildImage will build image

func (*Calcium) CacheImage 

func (c *Calcium) CacheImage(ctx context.Context, opts *types.ImageOptions) (chan *types.CacheImageMessage, error)

CacheImage cache Image 在podname上cache这个image 实际上就是在所有的node上去pull一次

func (*Calcium) CalculateCapacity 

func (c *Calcium) CalculateCapacity(ctx context.Context, opts *types.DeployOptions) (*types.CapacityMessage, error)

CalculateCapacity calculates capacity

func (*Calcium) ConnectNetwork 

func (c *Calcium) ConnectNetwork(ctx context.Context, network, target, ipv4, ipv6 string) ([]string, error)

ConnectNetwork connect to a network

func (*Calcium) ControlWorkload 

func (c *Calcium) ControlWorkload(ctx context.Context, IDs []string, typ string, force bool) (chan *types.ControlWorkloadMessage, error)

ControlWorkload control workloads status

func (*Calcium) Copy 

func (c *Calcium) Copy(ctx context.Context, opts *types.CopyOptions) (chan *types.CopyMessage, error)

Copy uses VirtualizationCopyFrom cp to copy specified things and send to remote

func (*Calcium) CreateWorkload 

func (c *Calcium) CreateWorkload(ctx context.Context, opts *types.DeployOptions) (chan *types.CreateWorkloadMessage, error)

CreateWorkload use options to create workloads

func (*Calcium) DisasterRecover 

func (c *Calcium) DisasterRecover(ctx context.Context)

DisasterRecover .

func (*Calcium) DisconnectNetwork 

func (c *Calcium) DisconnectNetwork(ctx context.Context, network, target string, force bool) error

DisconnectNetwork connect to a network

func (*Calcium) DissociateWorkload 

func (c *Calcium) DissociateWorkload(ctx context.Context, IDs []string) (chan *types.DissociateWorkloadMessage, error)

DissociateWorkload dissociate workload from eru, return it resource but not modity it

func (*Calcium) ExecuteWorkload 

func (c *Calcium) ExecuteWorkload(ctx context.Context, opts *types.ExecuteWorkloadOptions, inCh <-chan []byte) chan *types.AttachWorkloadMessage

ExecuteWorkload executes commands in running workloads

func (*Calcium) Finalizer 

func (c *Calcium) Finalizer()

Finalizer use for defer

func (*Calcium) GetIdentifier 

func (c *Calcium) GetIdentifier() string

GetIdentifier returns the identifier of calcium

func (*Calcium) GetNode 

func (c *Calcium) GetNode(ctx context.Context, nodename string) (node *types.Node, err error)

GetNode get node node with resource info

func (*Calcium) GetNodeEngineInfo 

func (c *Calcium) GetNodeEngineInfo(ctx context.Context, nodename string) (*enginetypes.Info, error)

GetNodeEngineInfo get node engine

func (*Calcium) GetNodeStatus 

func (c *Calcium) GetNodeStatus(ctx context.Context, nodename string) (*types.NodeStatus, error)

GetNodeStatus set status of a node it's used to report whether a node is still alive

func (*Calcium) GetPod 

func (c *Calcium) GetPod(ctx context.Context, podname string) (*types.Pod, error)

GetPod get one pod

func (*Calcium) GetStore 

func (c *Calcium) GetStore() store.Store

func (*Calcium) GetWorkload 

func (c *Calcium) GetWorkload(ctx context.Context, ID string) (workload *types.Workload, err error)

GetWorkload get a workload

func (*Calcium) GetWorkloads 

func (c *Calcium) GetWorkloads(ctx context.Context, IDs []string) (workloads []*types.Workload, err error)

GetWorkloads get workloads

func (*Calcium) GetWorkloadsStatus 

func (c *Calcium) GetWorkloadsStatus(ctx context.Context, IDs []string) ([]*types.StatusMeta, error)

GetWorkloadsStatus get workload status

func (*Calcium) InitMetrics 

func (c *Calcium) InitMetrics(ctx context.Context)

InitMetrics .

func (*Calcium) ListImage 

func (c *Calcium) ListImage(ctx context.Context, opts *types.ImageOptions) (chan *types.ListImageMessage, error)

ListImage list Image on a pod or some nodes.

func (*Calcium) ListNetworks 

func (c *Calcium) ListNetworks(ctx context.Context, podname string, driver string) ([]*enginetypes.Network, error)

ListNetworks by podname get one node from a pod and list networks only get those driven by network driver

func (*Calcium) ListNodeWorkloads 

func (c *Calcium) ListNodeWorkloads(ctx context.Context, nodename string, labels map[string]string) (workloads []*types.Workload, err error)

ListNodeWorkloads list workloads belong to one node

func (*Calcium) ListPodNodes 

func (c *Calcium) ListPodNodes(ctx context.Context, opts *types.ListNodesOptions) (<-chan *types.Node, error)

ListPodNodes list nodes belong to pod node with resource info

func (*Calcium) ListPods 

func (c *Calcium) ListPods(ctx context.Context) ([]*types.Pod, error)

ListPods show pods

func (*Calcium) ListWorkloads 

func (c *Calcium) ListWorkloads(ctx context.Context, opts *types.ListWorkloadsOptions) (workloads []*types.Workload, err error)

ListWorkloads list workloads

func (*Calcium) LogStream 

func (c *Calcium) LogStream(ctx context.Context, opts *types.LogStreamOptions) (chan *types.LogStreamMessage, error)

LogStream log stream for one workload

func (*Calcium) NodeResource 

func (c *Calcium) NodeResource(ctx context.Context, nodename string, fix bool) (*types.NodeResourceInfo, error)

NodeResource check node's workload and resource

func (*Calcium) NodeStatusStream 

func (c *Calcium) NodeStatusStream(ctx context.Context) chan *types.NodeStatus

NodeStatusStream returns a stream of node status for subscribing

func (*Calcium) PodResource 

func (c *Calcium) PodResource(ctx context.Context, podname string) (chan *types.NodeResourceInfo, error)

PodResource show pod resource usage

func (*Calcium) RawEngine 

func (c *Calcium) RawEngine(ctx context.Context, opts *types.RawEngineOptions) (msg *types.RawEngineMessage, err error)

func (*Calcium) ReallocResource 

func (c *Calcium) ReallocResource(ctx context.Context, opts *types.ReallocOptions) (err error)

ReallocResource updates workload resource dynamically

func (*Calcium) RegisterService 

func (c *Calcium) RegisterService(ctx context.Context) (unregister func(), err error)

RegisterService writes self service address in store

func (*Calcium) RemapResourceAndLog 

func (c *Calcium) RemapResourceAndLog(ctx context.Context, logger *log.Fields, node *types.Node)

RemapResourceAndLog called on changes of resource binding, such as cpu binding as an internal api, remap doesn't lock node, the responsibility of that should be taken on by caller

func (*Calcium) RemoveImage 

func (c *Calcium) RemoveImage(ctx context.Context, opts *types.ImageOptions) (chan *types.RemoveImageMessage, error)

RemoveImage remove images

func (*Calcium) RemoveNode 

func (c *Calcium) RemoveNode(ctx context.Context, nodename string) error

RemoveNode remove a node

func (*Calcium) RemovePod 

func (c *Calcium) RemovePod(ctx context.Context, podname string) error

RemovePod remove pod

func (*Calcium) RemoveWorkload 

func (c *Calcium) RemoveWorkload(ctx context.Context, IDs []string, force bool) (chan *types.RemoveWorkloadMessage, error)

RemoveWorkload remove workloads returns a channel that contains removing responses

func (*Calcium) RemoveWorkloadSync 

func (c *Calcium) RemoveWorkloadSync(ctx context.Context, IDs []string) error

RemoveWorkloadSync .

func (*Calcium) ReplaceWorkload 

func (c *Calcium) ReplaceWorkload(ctx context.Context, opts *types.ReplaceOptions) (chan *types.ReplaceWorkloadMessage, error)

ReplaceWorkload replace workloads with same resource

func (*Calcium) RunAndWait 

func (c *Calcium) RunAndWait(ctx context.Context, opts *types.DeployOptions, inCh <-chan []byte) ([]string, <-chan *types.AttachWorkloadMessage, error)

RunAndWait implement lambda

func (*Calcium) Send 

func (c *Calcium) Send(ctx context.Context, opts *types.SendOptions) (chan *types.SendMessage, error)

Send files to workload

func (*Calcium) SendLargeFile 

func (c *Calcium) SendLargeFile(ctx context.Context, inputChan chan *types.SendLargeFileOptions) chan *types.SendMessage

SendLargeFile send large files by stream to workload

func (*Calcium) SetNode 

func (c *Calcium) SetNode(ctx context.Context, opts *types.SetNodeOptions) (*types.Node, error)

SetNode set node available or not node with resource info

func (*Calcium) SetNodeStatus 

func (c *Calcium) SetNodeStatus(ctx context.Context, nodename string, ttl int64) error

SetNodeStatus set status of a node it's used to report whether a node is still alive

func (*Calcium) SetWorkloadsStatus 

func (c *Calcium) SetWorkloadsStatus(ctx context.Context, statusMetas []*types.StatusMeta, ttls map[string]int64) ([]*types.StatusMeta, error)

SetWorkloadsStatus set workloads status

func (*Calcium) WatchServiceStatus 

func (c *Calcium) WatchServiceStatus(ctx context.Context) (<-chan types.ServiceStatus, error)

WatchServiceStatus returns chan of available service address

func (*Calcium) WorkloadStatusStream 

func (c *Calcium) WorkloadStatusStream(ctx context.Context, appname, entrypoint, nodename string, labels map[string]string) chan *types.WorkloadStatus

WorkloadStatusStream stream workload status

type CreateLambdaHandler 

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

CreateLambdaHandler indicates event handler for creating lambda.

func (*CreateLambdaHandler) Check 

func (h *CreateLambdaHandler) Check(context.Context, any) (bool, error)

Check .

func (*CreateLambdaHandler) Decode 

func (h *CreateLambdaHandler) Decode(bs []byte) (any, error)

Decode .

func (*CreateLambdaHandler) Encode 

func (h *CreateLambdaHandler) Encode(raw any) ([]byte, error)

Encode .

func (*CreateLambdaHandler) Handle 

func (h *CreateLambdaHandler) Handle(ctx context.Context, raw any) error

Handle .

func (*CreateLambdaHandler) Typ 

func (h *CreateLambdaHandler) Typ() string

Event .

type CreateWorkloadHandler 

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

CreateWorkloadHandler indicates event handler for creating workload.

func (*CreateWorkloadHandler) Check 

func (h *CreateWorkloadHandler) Check(_ context.Context, raw any) (handle bool, err error)

Check .

func (*CreateWorkloadHandler) Decode 

func (h *CreateWorkloadHandler) Decode(bs []byte) (any, error)

Decode .

func (*CreateWorkloadHandler) Encode 

func (h *CreateWorkloadHandler) Encode(raw any) ([]byte, error)

Encode .

func (*CreateWorkloadHandler) Handle 

func (h *CreateWorkloadHandler) Handle(ctx context.Context, raw any) (err error)

Handle will remove instance, remove meta, restore resource

func (*CreateWorkloadHandler) Typ 

func (h *CreateWorkloadHandler) Typ() string

Event .

type ProcessingCreatedHandler 

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

ProcessingCreatedHandler .

func (ProcessingCreatedHandler) Check 

func (h ProcessingCreatedHandler) Check(_ context.Context, raw any) (bool, error)

Check .

func (*ProcessingCreatedHandler) Decode 

func (h *ProcessingCreatedHandler) Decode(bs []byte) (any, error)

Decode .

func (*ProcessingCreatedHandler) Encode 

func (h *ProcessingCreatedHandler) Encode(raw any) ([]byte, error)

Encode .

func (*ProcessingCreatedHandler) Handle 

func (h *ProcessingCreatedHandler) Handle(ctx context.Context, raw any) (err error)

Handle .

func (*ProcessingCreatedHandler) Typ 

func (h *ProcessingCreatedHandler) Typ() string

Event .

type WorkloadResourceAllocatedHandler 

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

WorkloadResourceAllocatedHandler .

func (*WorkloadResourceAllocatedHandler) Check 

func (h *WorkloadResourceAllocatedHandler) Check(_ context.Context, raw any) (bool, error)

Check .

func (*WorkloadResourceAllocatedHandler) Decode 

func (h *WorkloadResourceAllocatedHandler) Decode(bytes []byte) (any, error)

Decode .

func (*WorkloadResourceAllocatedHandler) Encode 

func (h *WorkloadResourceAllocatedHandler) Encode(raw any) ([]byte, error)

Encode .

func (*WorkloadResourceAllocatedHandler) Handle 

func (h *WorkloadResourceAllocatedHandler) Handle(ctx context.Context, raw any) (err error)

Handle .

func (*WorkloadResourceAllocatedHandler) Typ 

func (h *WorkloadResourceAllocatedHandler) Typ() string

Event .

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.