driver

Documentation

Index

• Constants
• type CRDDriver
  • func (d *CRDDriver) DeleteConfig(ctx context.Context, keys []string) error
  • func (d *CRDDriver) GetConfig(ctx context.Context, key string) (string, bool, error)
  • func (d *CRDDriver) ListConfig(ctx context.Context, keys []string) (map[string]string, error)
  • func (d *CRDDriver) SetConfig(ctx context.Context, data map[string]string) error
• type Config
• type Driver
  • func NewCRDDriver(ctx context.Context, conf *Config) (Driver, error)
  • func NewDriver(ctx context.Context, conf *Config) (Driver, error)

Constants

const (
	CRDDriverType = "crd"
)

Types

type CRDDriver

type CRDDriver struct {
	Ctx context.Context
	*Config
	ConfigMapLister listers.ConfigMapLister
}

func (*CRDDriver) DeleteConfig

func (d *CRDDriver) DeleteConfig(ctx context.Context, keys []string) error

func (*CRDDriver) GetConfig

func (d *CRDDriver) GetConfig(ctx context.Context, key string) (string, bool, error)

func (*CRDDriver) ListConfig

func (d *CRDDriver) ListConfig(ctx context.Context, keys []string) (map[string]string, error)

func (*CRDDriver) SetConfig

func (d *CRDDriver) SetConfig(ctx context.Context, data map[string]string) error

type Config

type Config struct {
	Driver     string
	DomainID   string
	ConfigName string
	// enable cache means getting data in local cache with k8s configmap lister
	// otherwise will use kubeClient to get configmap
	// for kuscia config command, will disable cache
	DisableCache bool
	KubeClient   kubernetes.Interface
	DomainKey    *rsa.PrivateKey
}

type Driver

type Driver interface {
	GetConfig(ctx context.Context, key string) (string, bool, error)
	SetConfig(ctx context.Context, data map[string]string) error
	ListConfig(ctx context.Context, keys []string) (map[string]string, error)
	DeleteConfig(ctx context.Context, keys []string) error
}

func NewCRDDriver

func NewCRDDriver(ctx context.Context, conf *Config) (Driver, error)

func NewDriver

func NewDriver(ctx context.Context, conf *Config) (Driver, error)