kubernetes

Documentation

Index

• type Client
  • func NewClient() (*Client, error)
  • func (sClient *Client) CreateConfigMap(ctx context.Context, apiVersion, 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(apiVersion, 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

Types

type Client

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

Client has info on how to connect to the kubernetes cluster

func NewClient

func NewClient() (*Client, error)

NewClient .. create new client

func (*Client) CreateConfigMap

func (sClient *Client) CreateConfigMap(ctx context.Context, apiVersion, 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

func (sClient *Client) InitConfigMap(apiVersion, storePath, nodeName, namespace string) error

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"
)