local

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: 20 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func NewPodLogger

func NewPodLogger(p *Provider) *podLogger

Types

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 {
	*k8s.Provider

	Registry string
	Secret   string
}

func FromEnv

func FromEnv() (*Provider, error)

func (*Provider) AppIdles

func (p *Provider) AppIdles(name string) (bool, error)

func (*Provider) AppLogs

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

func (*Provider) BuildExport

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

func (*Provider) BuildImport

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

func (*Provider) BuildLogs

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

func (*Provider) DeploymentTimeout

func (p *Provider) DeploymentTimeout() int

func (*Provider) Heartbeat

func (p *Provider) Heartbeat() (map[string]interface{}, error)

func (*Provider) IngressAnnotations

func (p *Provider) IngressAnnotations(certDuration string) (map[string]string, error)

func (*Provider) IngressClass

func (p *Provider) IngressClass() string

func (*Provider) IngressInternalClass

func (p *Provider) IngressInternalClass() string

func (*Provider) Initialize

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

func (*Provider) Log

func (p *Provider) Log(app, stream string, ts time.Time, message string) error

func (*Provider) ManifestValidate

func (p *Provider) ManifestValidate(m *manifest.Manifest) error

func (*Provider) ProcessLogs

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

func (*Provider) RepositoryAuth

func (p *Provider) RepositoryAuth(app string) (string, string, error)

func (*Provider) RepositoryHost

func (p *Provider) RepositoryHost(app string) (string, bool, error)

func (*Provider) RepositoryPrefix

func (p *Provider) RepositoryPrefix() string

func (*Provider) SystemHost

func (p *Provider) SystemHost() string

func (*Provider) SystemLogs

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

func (*Provider) SystemStatus

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

func (*Provider) WithContext

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

Jump to

Keyboard shortcuts

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