adapter

Documentation

Index

• func GetKubeResourceByName(name, namespace string, clusterType domain.DbClusterType) (metav1.Object, error)
• func NewMdpAccountRepository(logger logr.Logger) *commonadapter.AccountRepository
• func NewMpdEngineParamsRepository(logger logr.Logger) *commonadapter.EngineParamsRepository
• type EnvPort
  • func (r *EnvPort) ToString() (string, error)
• type LocalStorageClusterEnvGetStrategy
  • func NewLocalStorageClusterEnvGetStrategy(logger logr.Logger, accountRepository commondomain.IAccountRepository) *LocalStorageClusterEnvGetStrategy
  • func (d *LocalStorageClusterEnvGetStrategy) GetInstallEngineEnvirons(ctx context.Context) (string, error)
  • func (d *LocalStorageClusterEnvGetStrategy) Load(domainModel interface{}, ins *commondomain.DbIns) error
• type LocalStorageClusterRepository
  • func NewLocalStorageClusterRepository(logger logr.Logger) *LocalStorageClusterRepository
  • func (r *LocalStorageClusterRepository) Create(cluster *domain.LocalStorageCluster) error
  • func (r *LocalStorageClusterRepository) GetAll() ([]*domain.LocalStorageCluster, error)
  • func (r *LocalStorageClusterRepository) GetByData(data interface{}, useModifyClass bool, useUpgradeVersion bool) *domain.LocalStorageCluster
  • func (r *LocalStorageClusterRepository) GetByName(name, namespace string) (*domain.LocalStorageCluster, error)
  • func (r *LocalStorageClusterRepository) Update(cluster *domain.LocalStorageCluster) error
  • func (r *LocalStorageClusterRepository) UpdateRunningStatus(name, namespace string) error
• type LocalStoragePodManager
  • func NewLocalStoragePodManager(logger logr.Logger) *LocalStoragePodManager
  • func (q *LocalStoragePodManager) CreatePodAndWaitReady(ctx context.Context) error
  • func (q *LocalStoragePodManager) Init(domainModel interface{})
• type Port
• type SharedStorageClusterEnvGetStrategy
  • func NewSharedStorageClusterEnvGetStrategy(logger logr.Logger, accountRepository commondomain.IAccountRepository) *SharedStorageClusterEnvGetStrategy
  • func (d *SharedStorageClusterEnvGetStrategy) GetClusterName() string
  • func (d *SharedStorageClusterEnvGetStrategy) GetFlushEnvConfigMap() (*v1.ConfigMap, error)
  • func (d *SharedStorageClusterEnvGetStrategy) GetInstallEngineEnvirons(ctx context.Context) (string, error)
  • func (d *SharedStorageClusterEnvGetStrategy) Load(domainModel interface{}, ins *commondomain.DbIns) error
• type SharedStorageClusterRepository
  • func NewSharedStorageClusterRepository(logger logr.Logger) *SharedStorageClusterRepository
  • func (r *SharedStorageClusterRepository) Create(cluster *domain.SharedStorageCluster) error
  • func (r *SharedStorageClusterRepository) GetAll() ([]*domain.SharedStorageCluster, error)
  • func (r *SharedStorageClusterRepository) GetByData(data interface{}, useModifyClass bool, useUpgradeVersion bool) *domain.SharedStorageCluster
  • func (r *SharedStorageClusterRepository) GetByName(name, namespace string) (*domain.SharedStorageCluster, error)
  • func (r *SharedStorageClusterRepository) Update(cluster *domain.SharedStorageCluster) error
  • func (r *SharedStorageClusterRepository) UpdateInsStatus(cluster *domain.SharedStorageCluster) error
  • func (r *SharedStorageClusterRepository) UpdateRunningStatus(name, namespace string) error
  • func (r *SharedStorageClusterRepository) UpdateWithResourceVersion(cluster *domain.SharedStorageCluster) error
• type SharedStoragePodManager
  • func NewSharedStoragePodManager(logger logr.Logger) *SharedStoragePodManager
  • func (q *SharedStoragePodManager) CreatePodAndWaitReady(ctx context.Context) error
  • func (q *SharedStoragePodManager) Init(domainModel interface{})

Functions

func GetKubeResourceByName

func GetKubeResourceByName(name, namespace string, clusterType domain.DbClusterType) (metav1.Object, error)

func NewMdpAccountRepository

func NewMdpAccountRepository(logger logr.Logger) *commonadapter.AccountRepository

func NewMpdEngineParamsRepository

func NewMpdEngineParamsRepository(logger logr.Logger) *commonadapter.EngineParamsRepository

Types

type EnvPort

type EnvPort map[string]*Port

EnvPort map[string]*Port hostins id -> _port

func (*EnvPort) ToString

func (r *EnvPort) ToString() (string, error)

type LocalStorageClusterEnvGetStrategy

type LocalStorageClusterEnvGetStrategy struct {
	commonadapter.EnvGetStrategyBase
	// contains filtered or unexported fields
}

func NewLocalStorageClusterEnvGetStrategy

func NewLocalStorageClusterEnvGetStrategy(logger logr.Logger, accountRepository commondomain.IAccountRepository) *LocalStorageClusterEnvGetStrategy

func (*LocalStorageClusterEnvGetStrategy) GetInstallEngineEnvirons

func (d *LocalStorageClusterEnvGetStrategy) GetInstallEngineEnvirons(ctx context.Context) (string, error)

func (*LocalStorageClusterEnvGetStrategy) Load

func (d *LocalStorageClusterEnvGetStrategy) Load(domainModel interface{}, ins *commondomain.DbIns) error

type LocalStorageClusterRepository

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

func NewLocalStorageClusterRepository

func NewLocalStorageClusterRepository(logger logr.Logger) *LocalStorageClusterRepository

func (*LocalStorageClusterRepository) Create

func (r *LocalStorageClusterRepository) Create(cluster *domain.LocalStorageCluster) error

func (*LocalStorageClusterRepository) GetAll

func (r *LocalStorageClusterRepository) GetAll() ([]*domain.LocalStorageCluster, error)

func (*LocalStorageClusterRepository) GetByData

func (r *LocalStorageClusterRepository) GetByData(data interface{}, useModifyClass bool, useUpgradeVersion bool) *domain.LocalStorageCluster

func (*LocalStorageClusterRepository) GetByName

func (r *LocalStorageClusterRepository) GetByName(name, namespace string) (*domain.LocalStorageCluster, error)

func (*LocalStorageClusterRepository) Update

func (r *LocalStorageClusterRepository) Update(cluster *domain.LocalStorageCluster) error

func (*LocalStorageClusterRepository) UpdateRunningStatus

func (r *LocalStorageClusterRepository) UpdateRunningStatus(name, namespace string) error

type LocalStoragePodManager

type LocalStoragePodManager struct {
	commonadapter.PodManagerBase
	// contains filtered or unexported fields
}

func NewLocalStoragePodManager

func NewLocalStoragePodManager(logger logr.Logger) *LocalStoragePodManager

func (*LocalStoragePodManager) CreatePodAndWaitReady

func (q *LocalStoragePodManager) CreatePodAndWaitReady(ctx context.Context) error

func (*LocalStoragePodManager) Init

func (q *LocalStoragePodManager) Init(domainModel interface{})

type Port

type Port struct {
	Link        []int `json:"link"`
	Access_port []int `json:"access_port"`
	Perf_port   []int `json:"perf_port"`
}

type SharedStorageClusterEnvGetStrategy

type SharedStorageClusterEnvGetStrategy struct {
	commonadapter.EnvGetStrategyBase
	// contains filtered or unexported fields
}

func NewSharedStorageClusterEnvGetStrategy

func NewSharedStorageClusterEnvGetStrategy(logger logr.Logger, accountRepository commondomain.IAccountRepository) *SharedStorageClusterEnvGetStrategy

func (*SharedStorageClusterEnvGetStrategy) GetClusterName

func (d *SharedStorageClusterEnvGetStrategy) GetClusterName() string

func (*SharedStorageClusterEnvGetStrategy) GetFlushEnvConfigMap

func (d *SharedStorageClusterEnvGetStrategy) GetFlushEnvConfigMap() (*v1.ConfigMap, error)

func (*SharedStorageClusterEnvGetStrategy) GetInstallEngineEnvirons

func (d *SharedStorageClusterEnvGetStrategy) GetInstallEngineEnvirons(ctx context.Context) (string, error)

func (*SharedStorageClusterEnvGetStrategy) Load

func (d *SharedStorageClusterEnvGetStrategy) Load(domainModel interface{}, ins *commondomain.DbIns) error

type SharedStorageClusterRepository

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

func NewSharedStorageClusterRepository

func NewSharedStorageClusterRepository(logger logr.Logger) *SharedStorageClusterRepository

func (*SharedStorageClusterRepository) Create

func (r *SharedStorageClusterRepository) Create(cluster *domain.SharedStorageCluster) error

func (*SharedStorageClusterRepository) GetAll

func (r *SharedStorageClusterRepository) GetAll() ([]*domain.SharedStorageCluster, error)

func (*SharedStorageClusterRepository) GetByData

func (r *SharedStorageClusterRepository) GetByData(data interface{}, useModifyClass bool, useUpgradeVersion bool) *domain.SharedStorageCluster

func (*SharedStorageClusterRepository) GetByName

func (r *SharedStorageClusterRepository) GetByName(name, namespace string) (*domain.SharedStorageCluster, error)

func (*SharedStorageClusterRepository) Update

func (r *SharedStorageClusterRepository) Update(cluster *domain.SharedStorageCluster) error

func (*SharedStorageClusterRepository) UpdateInsStatus

func (r *SharedStorageClusterRepository) UpdateInsStatus(cluster *domain.SharedStorageCluster) error

func (*SharedStorageClusterRepository) UpdateRunningStatus

func (r *SharedStorageClusterRepository) UpdateRunningStatus(name, namespace string) error

func (*SharedStorageClusterRepository) UpdateWithResourceVersion

func (r *SharedStorageClusterRepository) UpdateWithResourceVersion(cluster *domain.SharedStorageCluster) error

type SharedStoragePodManager

type SharedStoragePodManager struct {
	commonadapter.PodManagerBase
	// contains filtered or unexported fields
}

func NewSharedStoragePodManager

func NewSharedStoragePodManager(logger logr.Logger) *SharedStoragePodManager

func (*SharedStoragePodManager) CreatePodAndWaitReady

func (q *SharedStoragePodManager) CreatePodAndWaitReady(ctx context.Context) error

func (*SharedStoragePodManager) Init

func (q *SharedStoragePodManager) Init(domainModel interface{})