k8s

Documentation

Index

• type DefaultClient
  • func (c DefaultClient) GetK8sClient() *kubernetes.Clientset
  • func (c DefaultClient) GetK8sRestConfig() *rest.Config
• type DefaultWorkspaceGroupClientMapper
  • func NewDefaultWorkspaceGroupClientMapper(k8sStore K8sStore) (*DefaultWorkspaceGroupClientMapper, error)
  • func (d DefaultWorkspaceGroupClientMapper) GetK8sAPIURL(workspaceGroupID string) (string, error)
  • func (d DefaultWorkspaceGroupClientMapper) GetK8sClient(workspaceGroupID string) (K8sClient, error)
  • func (d DefaultWorkspaceGroupClientMapper) GetPrivateKey() string
• type K8sClient
  • func NewDefaultClient(config K8sClientConfig) (K8sClient, error)
• type K8sClientConfig
• type K8sStore
• type RemoteK8sClientConfig
  • func (k RemoteK8sClientConfig) GetCA() []byte
  • func (k RemoteK8sClientConfig) GetCert() []byte
  • func (k RemoteK8sClientConfig) GetHost() string
  • func (k RemoteK8sClientConfig) GetKey() []byte
• type WorkspaceGroupClientMapper

Types

type DefaultClient

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

func (DefaultClient) GetK8sClient

func (c DefaultClient) GetK8sClient() *kubernetes.Clientset

func (DefaultClient) GetK8sRestConfig

func (c DefaultClient) GetK8sRestConfig() *rest.Config

type DefaultWorkspaceGroupClientMapper

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

func NewDefaultWorkspaceGroupClientMapper

func NewDefaultWorkspaceGroupClientMapper(k8sStore K8sStore) (*DefaultWorkspaceGroupClientMapper, error)

func (DefaultWorkspaceGroupClientMapper) GetK8sAPIURL

func (d DefaultWorkspaceGroupClientMapper) GetK8sAPIURL(workspaceGroupID string) (string, error)

func (DefaultWorkspaceGroupClientMapper) GetK8sClient

func (d DefaultWorkspaceGroupClientMapper) GetK8sClient(workspaceGroupID string) (K8sClient, error)

func (DefaultWorkspaceGroupClientMapper) GetPrivateKey

func (d DefaultWorkspaceGroupClientMapper) GetPrivateKey() string

type K8sClient

type K8sClient interface {
	GetK8sClient() *kubernetes.Clientset
	GetK8sRestConfig() *rest.Config
}

func NewDefaultClient

func NewDefaultClient(config K8sClientConfig) (K8sClient, error)

type K8sClientConfig

type K8sClientConfig interface {
	GetHost() string
	GetCert() []byte
	GetKey() []byte
	GetCA() []byte
}

type K8sStore

type K8sStore interface {
	GetCurrentUserKeys() (*entity.UserKeys, error)
}

type RemoteK8sClientConfig

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

func (RemoteK8sClientConfig) GetCA

func (k RemoteK8sClientConfig) GetCA() []byte

func (RemoteK8sClientConfig) GetCert

func (k RemoteK8sClientConfig) GetCert() []byte

func (RemoteK8sClientConfig) GetHost

func (k RemoteK8sClientConfig) GetHost() string

func (RemoteK8sClientConfig) GetKey

func (k RemoteK8sClientConfig) GetKey() []byte

type WorkspaceGroupClientMapper

type WorkspaceGroupClientMapper interface {
	GetK8sClient(workspaceGroupID string) (K8sClient, error)
	GetK8sAPIURL(workspaceGroupID string) (string, error)
}