k8s

package
v0.0.0-...-173f4c4 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	ScannerStartSize = 4096
	ScannerMaxSize   = 1024 * 1024
)
View Source 
const (
	CURRENT_CM_VERSION     = "v1.10.3"
	MAX_RETRIES_UPDATE_CM  = 10
	CERT_MANAGER_NAMESPACE = "cert-manager"
)
View Source 
const (
	BuildMax = 30
)
View Source 
const ConvoxJwtSecretName = "convox-jwt-key"
View Source 
const (
	LETSENCRYPT_CONFIG = "letsencrypt-config"
)

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 Delete 

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

Types

type Engine 

type Engine interface {
	AppIdles(app string) (bool, error)
	AppParameters() map[string]string
	Heartbeat() (map[string]interface{}, error)
	IngressAnnotations(certDuration string) (map[string]string, error)
	IngressClass() string
	IngressInternalClass() string
	Log(app, stream string, ts time.Time, message string) error
	ManifestValidate(m *manifest.Manifest) error
	RegistryAuth(host, username, password string) (string, string, error)
	RepositoryAuth(app string) (string, string, error)
	RepositoryHost(app string) (string, bool, error)
	RepositoryPrefix() string
	ResolverHost() (string, error)
	ServiceHost(app string, s manifest.Service) 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) Informer 

func (c *EventController) Informer() cache.SharedInformer

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 MetricScraperClient 

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

func NewMetricScraperClient 

func NewMetricScraperClient(cluster kubernetes.Interface, host string) *MetricScraperClient

func (*MetricScraperClient) GetNodesMetrics 

func (m *MetricScraperClient) GetNodesMetrics(nodeNames string, metricType structs.ScraperMetricType) (*structs.ScraperMetricList, error)

nodeNames: single or comma seperated node names

func (*MetricScraperClient) GetRackMetrics 

func (m *MetricScraperClient) GetRackMetrics(opts structs.MetricsOptions) (structs.Metrics, error)

type Patch 

type Patch struct {
	Op    string      `json:"op"`
	Path  string      `json:"path"`
	Value interface{} `json:"value"`
}

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) Informer 

func (c *PodController) Informer() cache.SharedInformer

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 {
	Atom                       atom.Interface
	BuildkitEnabled            string
	BuildNodeEnabled           string
	CertManager                bool
	CertManagerRoleArn         string
	Cluster                    kubernetes.Interface
	Config                     *rest.Config
	Convox                     cv.Interface
	ConvoxDomainTLSCertDisable bool
	CertManagerClient          cmclient.Interface
	DiscoveryClient            discovery.DiscoveryInterface
	Domain                     string
	DomainInternal             string
	DynamicClient              dynamic.Interface
	Engine                     Engine
	Image                      string
	JwtMngr                    *jwt.JwtManager
	Name                       string
	MetricScraper              *MetricScraperClient
	MetricsClient              metricsclientset.Interface
	Namespace                  string
	Password                   string
	Provider                   string
	RackName                   string
	Resolver                   string
	RestClient                 rest.Interface
	Router                     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) AppIdles 

func (p *Provider) AppIdles(name string) (bool, 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) AppParameters 

func (p *Provider) AppParameters() map[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) BalancerList 

func (p *Provider) BalancerList(app string) (structs.Balancers, 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 (*Provider) CertificateApply(_, _ string, _ int, _ 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) CertificateRenew 

func (p *Provider) CertificateRenew(app string) 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() (*structs.KeyPair, 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) LetsEncryptConfigApply 

func (p *Provider) LetsEncryptConfigApply(config structs.LetsEncryptConfig) error

func (*Provider) LetsEncryptConfigGet 

func (p *Provider) LetsEncryptConfigGet() (*structs.LetsEncryptConfig, error)

func (*Provider) NamespaceApp 

func (p *Provider) NamespaceApp(namespace string) (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) RackParams 

func (p *Provider) RackParams() map[string]interface{}

func (*Provider) RegistryAdd 

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

func (*Provider) RegistryAuth 

func (p *Provider) RegistryAuth(host, username, password string) (string, string, error)

override this function to provider infrastructure-specific authentication, such as token swapping for ecr

func (*Provider) RegistryList 

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

func (*Provider) RegistryProxy 

func (p *Provider) RegistryProxy(c *stdapi.Context) 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) ResolverHost 

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

func (*Provider) ResourceConsole 

func (p *Provider) ResourceConsole(app, name string, rw io.ReadWriter, opts structs.ResourceConsoleOptions) error

func (*Provider) ResourceExport 

func (p *Provider) ResourceExport(app, name string) (io.ReadCloser, error)

func (*Provider) ResourceGet 

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

func (*Provider) ResourceImport 

func (p *Provider) ResourceImport(app, name string, r io.Reader) error

func (*Provider) ResourceList 

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

func (*Provider) ServiceHost 

func (p *Provider) ServiceHost(app string, s manifest.Service) string

func (*Provider) ServiceList 

func (p *Provider) ServiceList(app string) (structs.Services, 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) Start 

func (p *Provider) Start() 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) 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

type Webhook 

type Webhook struct {
	Name string
	URL  string
}

type WebhookController 

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

func NewWebhookController 

func NewWebhookController(p *Provider) (*WebhookController, error)

func (*WebhookController) Add 

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

func (*WebhookController) Client 

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

func (*WebhookController) Delete 

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

func (*WebhookController) Informer 

func (c *WebhookController) Informer() cache.SharedInformer

func (*WebhookController) ListOptions 

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

func (*WebhookController) Run 

func (c *WebhookController) Run()

func (*WebhookController) Start 

func (c *WebhookController) Start() error

func (*WebhookController) Stop 

func (c *WebhookController) Stop() error

func (*WebhookController) Update 

func (c *WebhookController) Update(prev, cur interface{}) 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.