kube

package

v0.1.2 Latest Latest Go to latest Published: Jul 31, 2026 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Doout/runwake

Links

Open Source Insights

Documentation ¶

Index ¶

func EncodeInClusterKubeconfig(server string, caData []byte, token string) []byte
func FlattenKubeconfig(source []byte, contextName string, policy string, allowlist []string) ([]byte, error)
type InClusterProvider
- func NewInClusterProvider(connectionID, connectionName string, namespaces []string, tailLines int) (*InClusterProvider, error)
- func NewKubeconfigProvider(connection model.Connection, secrets *store.SecretStore, ...) (*InClusterProvider, error)
type KubectlProvider
- func NewKubectlProvider(connection model.Connection, secrets *store.SecretStore, ...) *KubectlProvider

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func EncodeInClusterKubeconfig ¶

func EncodeInClusterKubeconfig(server string, caData []byte, token string) []byte

func FlattenKubeconfig ¶ added in v0.1.1

func FlattenKubeconfig(source []byte, contextName string, policy string, allowlist []string) ([]byte, error)

Types ¶

type InClusterProvider ¶

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

func NewInClusterProvider ¶

func NewInClusterProvider(connectionID, connectionName string, namespaces []string, tailLines int) (*InClusterProvider, error)

func NewKubeconfigProvider ¶ added in v0.1.1

func NewKubeconfigProvider(connection model.Connection, secrets *store.SecretStore, settings func() model.Settings) (*InClusterProvider, error)

func (*InClusterProvider) ListMetrics ¶

func (p *InClusterProvider) ListMetrics(ctx context.Context) ([]model.WorkloadMetric, error)

func (*InClusterProvider) ListWorkloads ¶

func (p *InClusterProvider) ListWorkloads(ctx context.Context) ([]model.Workload, error)

func (*InClusterProvider) Namespaces ¶

func (p *InClusterProvider) Namespaces(ctx context.Context) ([]string, error)

func (*InClusterProvider) Stream ¶

func (p *InClusterProvider) Stream(ctx context.Context, request model.StreamRequest, out chan<- model.ActivityRecord) error

func (*InClusterProvider) StreamMetrics ¶

func (p *InClusterProvider) StreamMetrics(ctx context.Context, request model.MetricRequest, out chan<- model.WorkloadMetric) error

func (*InClusterProvider) StreamWorkloads ¶

func (p *InClusterProvider) StreamWorkloads(ctx context.Context, out chan<- model.Workload) error

func (*InClusterProvider) Test ¶

func (p *InClusterProvider) Test(ctx context.Context) (model.ProviderInfo, error)

type KubectlProvider ¶

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

func NewKubectlProvider ¶

func NewKubectlProvider(connection model.Connection, secrets *store.SecretStore, settings func() model.Settings) *KubectlProvider

func (*KubectlProvider) ApplyManifest ¶

func (p *KubectlProvider) ApplyManifest(ctx context.Context, manifest string) error

func (*KubectlProvider) DeleteManifest ¶

func (p *KubectlProvider) DeleteManifest(ctx context.Context, manifest string) error

func (*KubectlProvider) FlattenKubeconfig ¶

func (p *KubectlProvider) FlattenKubeconfig(ctx context.Context, source []byte, contextName string, policy string, allowlist []string, environment map[string]string) ([]byte, error)

func (*KubectlProvider) ListMetrics ¶

func (p *KubectlProvider) ListMetrics(ctx context.Context) ([]model.WorkloadMetric, error)

func (*KubectlProvider) ListWorkloads ¶

func (p *KubectlProvider) ListWorkloads(ctx context.Context) ([]model.Workload, error)

func (*KubectlProvider) Namespaces ¶

func (p *KubectlProvider) Namespaces(ctx context.Context) ([]string, error)

func (*KubectlProvider) Stream ¶

func (p *KubectlProvider) Stream(ctx context.Context, request model.StreamRequest, out chan<- model.ActivityRecord) error

func (*KubectlProvider) StreamMetrics ¶

func (p *KubectlProvider) StreamMetrics(ctx context.Context, request model.MetricRequest, out chan<- model.WorkloadMetric) error

func (*KubectlProvider) StreamWorkloads ¶

func (p *KubectlProvider) StreamWorkloads(ctx context.Context, out chan<- model.Workload) error

func (*KubectlProvider) Test ¶

func (p *KubectlProvider) Test(ctx context.Context) (model.ProviderInfo, error)

Source Files ¶

View all Source files

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