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 (p *InClusterProvider) ListMetrics(ctx context.Context) ([]model.WorkloadMetric, error)
- func (p *InClusterProvider) ListWorkloads(ctx context.Context) ([]model.Workload, error)
- func (p *InClusterProvider) Namespaces(ctx context.Context) ([]string, error)
- func (p *InClusterProvider) Stream(ctx context.Context, request model.StreamRequest, ...) error
- func (p *InClusterProvider) StreamMetrics(ctx context.Context, request model.MetricRequest, ...) error
- func (p *InClusterProvider) StreamWorkloads(ctx context.Context, out chan<- model.Workload) error
- func (p *InClusterProvider) Test(ctx context.Context) (model.ProviderInfo, error)
- type KubectlProvider
- func (p *KubectlProvider) ApplyManifest(ctx context.Context, manifest string) error
- func (p *KubectlProvider) DeleteManifest(ctx context.Context, manifest string) error
- func (p *KubectlProvider) FlattenKubeconfig(ctx context.Context, source []byte, contextName string, policy string, ...) ([]byte, error)
- func (p *KubectlProvider) ListMetrics(ctx context.Context) ([]model.WorkloadMetric, error)
- func (p *KubectlProvider) ListWorkloads(ctx context.Context) ([]model.Workload, error)
- func (p *KubectlProvider) Namespaces(ctx context.Context) ([]string, error)
- func (p *KubectlProvider) Stream(ctx context.Context, request model.StreamRequest, ...) error
- func (p *KubectlProvider) StreamMetrics(ctx context.Context, request model.MetricRequest, ...) error
- func (p *KubectlProvider) StreamWorkloads(ctx context.Context, out chan<- model.Workload) error
- func (p *KubectlProvider) Test(ctx context.Context) (model.ProviderInfo, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 (*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 (*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 (*KubectlProvider) ListMetrics ¶
func (p *KubectlProvider) ListMetrics(ctx context.Context) ([]model.WorkloadMetric, error)
func (*KubectlProvider) ListWorkloads ¶
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 (*KubectlProvider) Test ¶
func (p *KubectlProvider) Test(ctx context.Context) (model.ProviderInfo, error)
Source Files
Click to show internal directories.
Click to hide internal directories.