k8s

Documentation

Index

• func MockSecret(name, namespace string, data map[string][]byte) *corev1.Secret
• func NewMockClient(obj ...runtime.Object) *kube.K8sClient
• type Service
  • func NewService(deploymentID string, client *kube.K8sClient, encryptor types.Encryptor) (*Service, error)
  • func (ss *Service) DeleteEntry(appName, scope, name string) error
  • func (ss *Service) GetCurrentVersion(appName, scope string) (int64, error)
  • func (ss *Service) GetEntries(appName, scope string) (map[string]interface{}, error)
  • func (ss *Service) GetEntry(appName, scope, name string) (interface{}, error)
  • func (ss *Service) GetLatestVersion(appName, scope string) (int64, error)
  • func (ss *Service) ListAppNames() ([]string, error)
  • func (ss *Service) ListEntries(appName, scope string) ([]string, error)
  • func (ss *Service) Read(appName, scope string) error
  • func (ss *Service) SetEntries(appName, scope string, data map[string]interface{}) error
  • func (ss *Service) SetEntry(appName, scope, name string, value interface{}) error
  • func (ss *Service) Write(appName, scope string) error

Functions

func MockSecret

func MockSecret(name, namespace string, data map[string][]byte) *corev1.Secret

func NewMockClient

func NewMockClient(obj ...runtime.Object) *kube.K8sClient

NewMockClient returns an initialized Mock Client object

Types

type Service

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

Service contains a K8s client

func NewService

func NewService(deploymentID string, client *kube.K8sClient, encryptor types.Encryptor) (*Service, error)

func (*Service) DeleteEntry

func (ss *Service) DeleteEntry(appName, scope, name string) error

func (*Service) GetCurrentVersion

func (ss *Service) GetCurrentVersion(appName, scope string) (int64, error)

func (*Service) GetEntries

func (ss *Service) GetEntries(appName, scope string) (map[string]interface{}, error)

func (*Service) GetEntry

func (ss *Service) GetEntry(appName, scope, name string) (interface{}, error)

func (*Service) GetLatestVersion

func (ss *Service) GetLatestVersion(appName, scope string) (int64, error)

func (*Service) ListAppNames

func (ss *Service) ListAppNames() ([]string, error)

func (*Service) ListEntries

func (ss *Service) ListEntries(appName, scope string) ([]string, error)

func (*Service) Read

func (ss *Service) Read(appName, scope string) error

func (*Service) SetEntries

func (ss *Service) SetEntries(appName, scope string, data map[string]interface{}) error

func (*Service) SetEntry

func (ss *Service) SetEntry(appName, scope, name string, value interface{}) error

func (*Service) Write

func (ss *Service) Write(appName, scope string) error