http

Documentation

Index

• Constants
• Variables
• func SetupHTTPServer(ctx context.Context, p Provider, certPEMBlock, keyPEMBlock []byte) (_ func(), retErr error)
• type LogsExecProvider
  • func (p *LogsExecProvider) GetContainerLogs(ctx context.Context, namespace, podName, containerName string, ...) (io.ReadCloser, error)
  • func (p *LogsExecProvider) RunInContainer(ctx context.Context, namespace, name, container string, cmd []string, ...) error
• type Provider

Constants

const (
	DefaultKubeletAddr = ":10250"
)

Variables

var AcceptedCiphers = []uint16{
	tls.TLS_ECDHE_ECDSA_WITH_AES_256_CBC_SHA,
	tls.TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA,
	tls.TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA,
	tls.TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA,

	tls.TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384,
	tls.TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384,
	tls.TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,
	tls.TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,
}

AcceptedCiphers is the list of accepted TLS ciphers, with known weak ciphers elided Note this list should be a moving target.

Functions

func SetupHTTPServer

func SetupHTTPServer(ctx context.Context, p Provider, certPEMBlock, keyPEMBlock []byte) (_ func(), retErr error)

Types

type LogsExecProvider

type LogsExecProvider struct {
	SourceClient  kubernetes.Interface
	TargetConfigs map[string]*rest.Config
	TargetClients map[string]kubernetes.Interface
}

func (*LogsExecProvider) GetContainerLogs

func (p *LogsExecProvider) GetContainerLogs(ctx context.Context, namespace, podName, containerName string, opts api.ContainerLogOpts) (io.ReadCloser, error)

GetContainerLogs retrieves the logs of a container by name from the provider.

func (*LogsExecProvider) RunInContainer

func (p *LogsExecProvider) RunInContainer(ctx context.Context, namespace, name, container string, cmd []string, attach api.AttachIO) error

RunInContainer executes a command in a container in the pod, copying data between in/out/err and the container's stdin/stdout/stderr.

type Provider

type Provider interface {
	RunInContainer(ctx context.Context, namespace, podName, containerName string, cmd []string, attach api.AttachIO) error
	GetContainerLogs(ctx context.Context, namespace, podName, containerName string, opts api.ContainerLogOpts) (io.ReadCloser, error)
}