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) Read(object string, field string) (string, error)
- func (s *K8sStateProvider) ReadObject(object string) (map[string]string, error)
- func (s *K8sStateProvider) Remove(object string, field string, namespace string) error
- func (s *K8sStateProvider) RemoveObject(object string, namespace string) error
- func (s *K8sStateProvider) Set(object string, field string, value string, namespace string) error
- func (s *K8sStateProvider) SetContext(ctx *contexts.ManagerContext)
- func (s *K8sStateProvider) SetObject(object string, values map[string]string, namespace string) error
- func (s *K8sStateProvider) Upsert(ctx context.Context, entry states.UpsertRequest) (string, error)
- type K8sStateProviderConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*K8sStateProvider) Read ¶
func (s *K8sStateProvider) Read(object string, field string) (string, error)
Implmeement the IConfigProvider interface
func (*K8sStateProvider) ReadObject ¶
func (s *K8sStateProvider) ReadObject(object string) (map[string]string, error)
func (*K8sStateProvider) Remove ¶
func (s *K8sStateProvider) Remove(object string, field string, namespace string) error
func (*K8sStateProvider) RemoveObject ¶
func (s *K8sStateProvider) RemoveObject(object string, namespace 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)
Source Files
Click to show internal directories.
Click to hide internal directories.