k8s

Documentation

Index

• type K8sStateProvider
  • func (s *K8sStateProvider) Delete(ctx context.Context, request states.DeleteRequest) error
  • func (s *K8sStateProvider) Get(ctx context.Context, request states.GetRequest) (states.StateEntry, error)
  • func (i *K8sStateProvider) Init(config providers.IProviderConfig) error
  • func (i *K8sStateProvider) InitWithMap(properties map[string]string) error
  • func (s *K8sStateProvider) List(ctx context.Context, request states.ListRequest) ([]states.StateEntry, string, error)
  • func (s *K8sStateProvider) ListAllNamespaces(ctx context.Context, version string) ([]string, error)
  • func (s *K8sStateProvider) SetContext(ctx *contexts.ManagerContext)
  • func (s *K8sStateProvider) Upsert(ctx context.Context, entry states.UpsertRequest) (string, error)
• type K8sStateProviderConfig
  • func K8sStateProviderConfigFromMap(properties map[string]string) (K8sStateProviderConfig, error)

Types

type K8sStateProvider

type K8sStateProvider struct {
	Config        K8sStateProviderConfig
	Context       *contexts.ManagerContext
	DynamicClient dynamic.Interface
}

func (*K8sStateProvider) Delete

func (s *K8sStateProvider) Delete(ctx context.Context, request states.DeleteRequest) error

func (*K8sStateProvider) Get

func (s *K8sStateProvider) Get(ctx context.Context, request states.GetRequest) (states.StateEntry, error)

func (*K8sStateProvider) Init

func (i *K8sStateProvider) Init(config providers.IProviderConfig) error

func (*K8sStateProvider) InitWithMap

func (i *K8sStateProvider) InitWithMap(properties map[string]string) error

func (*K8sStateProvider) List

func (s *K8sStateProvider) List(ctx context.Context, request states.ListRequest) ([]states.StateEntry, string, error)

func (*K8sStateProvider) ListAllNamespaces

func (s *K8sStateProvider) ListAllNamespaces(ctx context.Context, version string) ([]string, error)

func (*K8sStateProvider) SetContext

func (s *K8sStateProvider) SetContext(ctx *contexts.ManagerContext)

func (*K8sStateProvider) Upsert

func (s *K8sStateProvider) Upsert(ctx context.Context, entry states.UpsertRequest) (string, error)

type K8sStateProviderConfig

type K8sStateProviderConfig struct {
	Name       string `json:"name"`
	ConfigType string `json:"configType,omitempty"`
	ConfigData string `json:"configData,omitempty"`
	Context    string `json:"context,omitempty"`
	InCluster  bool   `json:"inCluster"`
}

func K8sStateProviderConfigFromMap

func K8sStateProviderConfigFromMap(properties map[string]string) (K8sStateProviderConfig, error)