k8s

package
v0.0.0-...-8e3368f Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 57 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ScannerStartSize = 4096
	ScannerMaxSize   = 20 * 1024 * 1024
)
View Source 
const (
	BuildMax = 30
)

Variables

This section is empty.

Functions

func Apply 

func Apply(data []byte, args ...string) error

func ApplyLabels 

func ApplyLabels(data []byte, labels string) ([]byte, error)

func NewPodLogger 

func NewPodLogger(p *Provider) *podLogger

Types

type DeploymentController 

type DeploymentController struct {
	Controller *kctl.Controller
	Provider   *Provider
}

func NewDeploymentController 

func NewDeploymentController(p *Provider) (*DeploymentController, error)

func (*DeploymentController) Add 

func (c *DeploymentController) Add(obj interface{}) error

func (*DeploymentController) Client 

func (c *DeploymentController) Client() kubernetes.Interface

func (*DeploymentController) Delete 

func (c *DeploymentController) Delete(obj interface{}) error

func (*DeploymentController) ListOptions 

func (c *DeploymentController) ListOptions(opts *am.ListOptions)

func (*DeploymentController) Run 

func (c *DeploymentController) Run()

func (*DeploymentController) Start 

func (c *DeploymentController) Start() error

func (*DeploymentController) Stop 

func (c *DeploymentController) Stop() error

func (*DeploymentController) Update 

func (c *DeploymentController) Update(prev, cur interface{}) error

type Engine 

type Engine interface {
	AppIdles(app string) (bool, error)
	AppStatus(app string) (string, error)
	Log(app, stream string, ts time.Time, message string) error
	ReleasePromote(app, id string, opts structs.ReleasePromoteOptions) error
	RepositoryAuth(app string) (string, string, error)
	RepositoryHost(app string) (string, bool, error)
	ResourceRender(app string, r manifest.Resource) ([]byte, error)
	Resolver() (string, error)
	ServiceHost(app string, s manifest.Service) string
	// SystemAnnotations(service string) map[string]string
	SystemHost() string
	SystemStatus() (string, error)
}

type EventController 

type EventController struct {
	Controller *kctl.Controller
	Provider   *Provider
	// contains filtered or unexported fields
}

func NewEventController 

func NewEventController(p *Provider) (*EventController, error)

func (*EventController) Add 

func (c *EventController) Add(obj interface{}) error

func (*EventController) Client 

func (c *EventController) Client() kubernetes.Interface

func (*EventController) Delete 

func (c *EventController) Delete(obj interface{}) error

func (*EventController) ListOptions 

func (c *EventController) ListOptions(opts *am.ListOptions)

func (*EventController) Run 

func (c *EventController) Run()

func (*EventController) Start 

func (c *EventController) Start() error

func (*EventController) Stop 

func (c *EventController) Stop() error

func (*EventController) Update 

func (c *EventController) Update(prev, cur interface{}) error

type NodeController 

type NodeController struct {
	Controller *kctl.Controller
	Provider   *Provider
}

func NewNodeController 

func NewNodeController(p *Provider) (*NodeController, error)

func (*NodeController) Add 

func (c *NodeController) Add(obj interface{}) error

func (*NodeController) Client 

func (c *NodeController) Client() kubernetes.Interface

func (*NodeController) Delete 

func (c *NodeController) Delete(obj interface{}) error

func (*NodeController) ListOptions 

func (c *NodeController) ListOptions(opts *am.ListOptions)

func (*NodeController) Run 

func (c *NodeController) Run()

func (*NodeController) Start 

func (c *NodeController) Start() error

func (*NodeController) Stop 

func (c *NodeController) Stop() error

func (*NodeController) Update 

func (c *NodeController) Update(prev, cur interface{}) error

type PodController 

type PodController struct {
	Controller *kctl.Controller
	Provider   *Provider
	// contains filtered or unexported fields
}

func NewPodController 

func NewPodController(p *Provider) (*PodController, error)

func (*PodController) Add 

func (c *PodController) Add(obj interface{}) error

func (*PodController) Client 

func (c *PodController) Client() kubernetes.Interface

func (*PodController) Delete 

func (c *PodController) Delete(obj interface{}) error

func (*PodController) ListOptions 

func (c *PodController) ListOptions(opts *am.ListOptions)

func (*PodController) Run 

func (c *PodController) Run()

func (*PodController) Start 

func (c *PodController) Start() error

func (*PodController) Stop 

func (c *PodController) Stop() error

func (*PodController) Update 

func (c *PodController) Update(prev, cur interface{}) error

type Provider 

type Provider struct {
	Config   *rest.Config
	Cluster  kubernetes.Interface
	ID       string
	Image    string
	Engine   Engine
	Metrics  metrics.Interface
	Password string
	Provider string
	Rack     string
	Socket   string
	Storage  string
	Version  string
	// contains filtered or unexported fields
}

func FromEnv 

func FromEnv() (*Provider, error)

func (*Provider) AppCancel 

func (p *Provider) AppCancel(name string) error

func (*Provider) AppCreate 

func (p *Provider) AppCreate(name string, opts structs.AppCreateOptions) (*structs.App, error)

func (*Provider) AppDelete 

func (p *Provider) AppDelete(name string) error

func (*Provider) AppGet 

func (p *Provider) AppGet(name string) (*structs.App, error)

func (*Provider) AppList 

func (p *Provider) AppList() (structs.Apps, error)

func (*Provider) AppLogs 

func (p *Provider) AppLogs(name string, opts structs.LogsOptions) (io.ReadCloser, error)

func (*Provider) AppMetrics 

func (p *Provider) AppMetrics(name string, opts structs.MetricsOptions) (structs.Metrics, error)

func (*Provider) AppNamespace 

func (p *Provider) AppNamespace(app string) string

func (*Provider) AppUpdate 

func (p *Provider) AppUpdate(name string, opts structs.AppUpdateOptions) error

func (*Provider) Apply 

func (p *Provider) Apply(namespace, name, version string, data []byte, labels string, timeout int32) error

func (*Provider) ApplyWait 

func (p *Provider) ApplyWait(namespace, name, version string, data []byte, labels string, timeout int32) error

func (*Provider) AtomWait 

func (p *Provider) AtomWait(namespace, name string) error

func (*Provider) BuildCreate 

func (p *Provider) BuildCreate(app, url string, opts structs.BuildCreateOptions) (*structs.Build, error)

func (*Provider) BuildExport 

func (p *Provider) BuildExport(app, id string, w io.Writer) error

func (*Provider) BuildGet 

func (p *Provider) BuildGet(app, id string) (*structs.Build, error)

func (*Provider) BuildImport 

func (p *Provider) BuildImport(app string, r io.Reader) (*structs.Build, error)

func (*Provider) BuildList 

func (p *Provider) BuildList(app string, opts structs.BuildListOptions) (structs.Builds, error)

func (*Provider) BuildLogs 

func (p *Provider) BuildLogs(app, id string, opts structs.LogsOptions) (io.ReadCloser, error)

func (*Provider) BuildUpdate 

func (p *Provider) BuildUpdate(app, id string, opts structs.BuildUpdateOptions) (*structs.Build, error)

func (*Provider) CapacityGet 

func (p *Provider) CapacityGet() (*structs.Capacity, error)

func (*Provider) CertificateApply 

func (p *Provider) CertificateApply(app, service string, port int, id string) error

func (*Provider) CertificateCreate 

func (p *Provider) CertificateCreate(pub, key string, opts structs.CertificateCreateOptions) (*structs.Certificate, error)

func (*Provider) CertificateDelete 

func (p *Provider) CertificateDelete(id string) error

func (*Provider) CertificateGenerate 

func (p *Provider) CertificateGenerate(domains []string) (*structs.Certificate, error)

func (*Provider) CertificateList 

func (p *Provider) CertificateList() (structs.Certificates, error)

func (*Provider) Context 

func (p *Provider) Context() context.Context

func (*Provider) EventSend 

func (p *Provider) EventSend(action string, opts structs.EventSendOptions) error

func (*Provider) FilesDelete 

func (p *Provider) FilesDelete(app, pid string, files []string) error

func (*Provider) FilesDownload 

func (p *Provider) FilesDownload(app, pid, file string) (io.Reader, error)

func (*Provider) FilesUpload 

func (p *Provider) FilesUpload(app, pid string, r io.Reader) error

func (*Provider) Initialize 

func (p *Provider) Initialize(opts structs.ProviderOptions) error

func (*Provider) InstanceKeyroll 

func (p *Provider) InstanceKeyroll() error

func (*Provider) InstanceList 

func (p *Provider) InstanceList() (structs.Instances, error)

func (*Provider) InstanceShell 

func (p *Provider) InstanceShell(id string, rw io.ReadWriter, opts structs.InstanceShellOptions) (int, error)

func (*Provider) InstanceTerminate 

func (p *Provider) InstanceTerminate(id string) error

func (*Provider) ObjectDelete 

func (p *Provider) ObjectDelete(app, key string) error

func (*Provider) ObjectExists 

func (p *Provider) ObjectExists(app, key string) (bool, error)

func (*Provider) ObjectFetch 

func (p *Provider) ObjectFetch(app, key string) (io.ReadCloser, error)

func (*Provider) ObjectList 

func (p *Provider) ObjectList(app, prefix string) ([]string, error)

func (*Provider) ObjectStore 

func (p *Provider) ObjectStore(app, key string, r io.Reader, opts structs.ObjectStoreOptions) (*structs.Object, error)

func (*Provider) ProcessExec 

func (p *Provider) ProcessExec(app, pid, command string, rw io.ReadWriter, opts structs.ProcessExecOptions) (int, error)

func (*Provider) ProcessGet 

func (p *Provider) ProcessGet(app, pid string) (*structs.Process, error)

func (*Provider) ProcessList 

func (p *Provider) ProcessList(app string, opts structs.ProcessListOptions) (structs.Processes, error)

func (*Provider) ProcessLogs 

func (p *Provider) ProcessLogs(app, pid string, opts structs.LogsOptions) (io.ReadCloser, error)

func (*Provider) ProcessRun 

func (p *Provider) ProcessRun(app, service string, opts structs.ProcessRunOptions) (*structs.Process, error)

func (*Provider) ProcessStop 

func (p *Provider) ProcessStop(app, pid string) error

func (*Provider) ProcessWait 

func (p *Provider) ProcessWait(app, pid string) (int, error)

func (*Provider) Proxy 

func (p *Provider) Proxy(host string, port int, rw io.ReadWriter, opts structs.ProxyOptions) error

func (*Provider) RegistryAdd 

func (p *Provider) RegistryAdd(server, username, password string) (*structs.Registry, error)

func (*Provider) RegistryList 

func (p *Provider) RegistryList() (structs.Registries, error)

func (*Provider) RegistryRemove 

func (p *Provider) RegistryRemove(server string) error

func (*Provider) ReleaseCreate 

func (p *Provider) ReleaseCreate(app string, opts structs.ReleaseCreateOptions) (*structs.Release, error)

func (*Provider) ReleaseGet 

func (p *Provider) ReleaseGet(app, id string) (*structs.Release, error)

func (*Provider) ReleaseList 

func (p *Provider) ReleaseList(app string, opts structs.ReleaseListOptions) (structs.Releases, error)

func (*Provider) ReleasePromote 

func (p *Provider) ReleasePromote(app, id string, opts structs.ReleasePromoteOptions) error

func (*Provider) RenderTemplate 

func (p *Provider) RenderTemplate(name string, params map[string]interface{}) ([]byte, error)

func (*Provider) ResourceGet 

func (p *Provider) ResourceGet(app, name string) (*structs.Resource, error)

func (*Provider) ResourceList 

func (p *Provider) ResourceList(app string) (structs.Resources, error)

func (*Provider) ServiceList 

func (p *Provider) ServiceList(app string) (structs.Services, error)

TODO finish

func (*Provider) ServiceMetrics 

func (p *Provider) ServiceMetrics(app, name string, opts structs.MetricsOptions) (structs.Metrics, error)

func (*Provider) ServiceRestart 

func (p *Provider) ServiceRestart(app, name string) error

func (*Provider) ServiceUpdate 

func (p *Provider) ServiceUpdate(app, name string, opts structs.ServiceUpdateOptions) error

func (*Provider) Sync 

func (p *Provider) Sync(name string) error

func (*Provider) SyncInstancesIpInSecurityGroup 

func (p *Provider) SyncInstancesIpInSecurityGroup() error

func (*Provider) SystemGet 

func (p *Provider) SystemGet() (*structs.System, error)

func (*Provider) SystemInstall 

func (p *Provider) SystemInstall(w io.Writer, opts structs.SystemInstallOptions) (string, error)

func (*Provider) SystemJwtSignKey 

func (p *Provider) SystemJwtSignKey() (string, error)

func (*Provider) SystemJwtSignKeyRotate 

func (p *Provider) SystemJwtSignKeyRotate() (string, error)

func (*Provider) SystemLogs 

func (p *Provider) SystemLogs(opts structs.LogsOptions) (io.ReadCloser, error)

func (*Provider) SystemMetrics 

func (p *Provider) SystemMetrics(opts structs.MetricsOptions) (structs.Metrics, error)

func (*Provider) SystemProcesses 

func (p *Provider) SystemProcesses(opts structs.SystemProcessesOptions) (structs.Processes, error)

func (*Provider) SystemReleases 

func (p *Provider) SystemReleases() (structs.Releases, error)

func (*Provider) SystemResourceCreate 

func (p *Provider) SystemResourceCreate(kind string, opts structs.ResourceCreateOptions) (*structs.Resource, error)

func (*Provider) SystemResourceDelete 

func (p *Provider) SystemResourceDelete(name string) error

func (*Provider) SystemResourceGet 

func (p *Provider) SystemResourceGet(name string) (*structs.Resource, error)
func (p *Provider) SystemResourceLink(name, app string) (*structs.Resource, error)

func (*Provider) SystemResourceList 

func (p *Provider) SystemResourceList() (structs.Resources, error)

func (*Provider) SystemResourceTypes 

func (p *Provider) SystemResourceTypes() (structs.ResourceTypes, error)
func (p *Provider) SystemResourceUnlink(name, app string) (*structs.Resource, error)

func (*Provider) SystemResourceUpdate 

func (p *Provider) SystemResourceUpdate(name string, opts structs.ResourceUpdateOptions) (*structs.Resource, error)

func (*Provider) SystemTemplate 

func (p *Provider) SystemTemplate(version string) ([]byte, error)

func (*Provider) SystemTemplateLocal 

func (p *Provider) SystemTemplateLocal(provider, version string) ([]byte, error)

func (*Provider) SystemTemplateRemote 

func (p *Provider) SystemTemplateRemote(provider, version string) ([]byte, error)

func (*Provider) SystemUninstall 

func (p *Provider) SystemUninstall(name string, w io.Writer, opts structs.SystemUninstallOptions) error

func (*Provider) SystemUpdate 

func (p *Provider) SystemUpdate(opts structs.SystemUpdateOptions) error

func (*Provider) WithContext 

func (p *Provider) WithContext(ctx context.Context) structs.Provider

func (*Provider) Workers 

func (p *Provider) Workers() error

Source Files

View all Source files

Directories

Path Synopsis
pkg
apis/convox
apis/convox/v1
+groupName=convox.com
 +groupName=convox.com
client/clientset/versioned
This package has the automatically generated clientset.
 This package has the automatically generated clientset.
client/clientset/versioned/fake
This package has the automatically generated fake clientset.
 This package has the automatically generated fake clientset.
client/clientset/versioned/scheme
This package contains the scheme of the automatically generated clientset.
 This package contains the scheme of the automatically generated clientset.
client/clientset/versioned/typed/convox/v1
This package has the automatically generated typed clients.
 This package has the automatically generated typed clients.
client/clientset/versioned/typed/convox/v1/fake
Package fake has the automatically generated clients.
 Package fake has the automatically generated clients.
client/informers/externalversions
client/informers/externalversions/convox
client/informers/externalversions/convox/v1
client/informers/externalversions/internalinterfaces
client/listers/convox/v1

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.