Documentation
¶
Index ¶
- type Client
- func (sClient *Client) CreateConfigMap(ctx context.Context, nodeName, namespace string) (cm *corev1.ConfigMap, err error)
- func (sClient *Client) GetConfigMap(ctx context.Context, nodeName, namespace string) (*corev1.ConfigMap, error)
- func (sClient *Client) InitConfigMap(storePath, nodeName, namespace string) error
- func (sClient *Client) SetClientSet(c kubernetes.Interface)
- func (sClient *Client) UpdateConfigMap(ctx context.Context, data []subscriber.Subscriber, nodeName, namespace string) error
- type StorageTypeType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client has info on how to connect to the kubernetes cluster
func (*Client) CreateConfigMap ¶
func (sClient *Client) CreateConfigMap(ctx context.Context, nodeName, namespace string) (cm *corev1.ConfigMap, err error)
CreateConfigMap ... create configmap
func (*Client) GetConfigMap ¶
func (sClient *Client) GetConfigMap(ctx context.Context, nodeName, namespace string) (*corev1.ConfigMap, error)
GetConfigMap .. get configmap
func (*Client) InitConfigMap ¶
InitConfigMap ... using configmap
func (*Client) SetClientSet ¶
func (sClient *Client) SetClientSet(c kubernetes.Interface)
SetClientSet .. set clientset
func (*Client) UpdateConfigMap ¶
func (sClient *Client) UpdateConfigMap(ctx context.Context, data []subscriber.Subscriber, nodeName, namespace string) error
UpdateConfigMap ... update configmap
type StorageTypeType ¶
type StorageTypeType string
StorageTypeType define storage type
const ( // EmptyDir Default storage type EmptyDir StorageTypeType = "EMPTY_DIR" // ConfigMap as storage ConfigMap StorageTypeType = "CONFIGMAP" )
Source Files
Click to show internal directories.
Click to hide internal directories.