crm

type Basic struct {
	UpdatedAt time.Time `gorm:"column:update_at" json:"-"`
	Disabled  bool      `gorm:"column:disabled;default:false;index" json:"-"`
}

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

type BrokerParam struct {
	Param           ResourceParam
	Instance        int
	FitFunc         BrokerParamFitFunction
	ReleaseLoop     bool
	IdleKeepSeconds int
}

type BrokerParamFitFunction func(brokerParam, requestParam ResourceParam) bool

type BrokerSet struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type BrokerStrategy interface {
	// ask strategy now how many resources should we adjust? more(>0) or less(<0)
	Ask(param interface{}) int
}

type HandlerWithUser interface {
	Init(resourceID string, param ResourceParam) error
	Launch(resourceID, city string, function op.InstanceFilterFunction) error
	Scale(resourceID string, function op.InstanceFilterFunction) error
	GetServiceInfo(resourceID string) (*op.ServiceInfo, error)
	IsServicePreparing(resourceID string) (bool, error)
	Release(resourceID string) error
	AddBroker(name string, strategyType StrategyType, strategy BrokerStrategy,
		param BrokerParam) error
	GetInstanceType(platform, group string) *config.InstanceType
	GetNamespace() string
}

type InstanceFilterFunction func(availableInstance int) (int, error)

type MySQL interface {
	ListResource(opts commonMySQL.ListOptions) ([]*TableResource, int64, error)
	GetResource(resourceID string) (*TableResource, error)
	CreateResource(tr *TableResource) error
	PutResource(tr *TableResource) error
	DeleteResource(resourceID string) error
}

type MySQLConf struct {
	MySQLStorage     string
	MySQLDatabase    string
	MySQLTable       string
	MySQLUser        string
	MySQLPwd         string
	Charset          string
	MysqlTableOption string
	SkipEnsure       bool
}

type ResourceManager interface {
	// RegisterUser receive a user and return a HandlerWithUser which operates under this user.
	RegisterUser(user string) (HandlerWithUser, error)

	// GetResourceDetail return details of resource description.
	GetResourceDetail() *rsc.Details

	// Run the manager.
	Run() error
}

type ResourceParam struct {
	City string `json:"city"`

	Platform string `json:"platform"`

	// env key-values which will be inserted into containers
	Env map[string]string `json:"env"`

	// ports that implements with port_name:protocol
	// such as my_port_alpha:http, my_port_beta:tcp
	// port numbers are all generated by container scheduler with cnm HOST
	Ports map[string]string `json:"ports"`

	// volumes implements the hostPath volumes with name:settings
	Volumes map[string]op.BcsVolume

	// container images
	Image string `json:"image"`

	// if it is a broker resource, then broker name should be specified
	BrokerName string `json:"broker_name"`
}

type StrategyType int

type TableResource struct {
	Basic
	ResourceID string `gorm:"column:resource_id;primary_key" json:"resource_id"`
	User       string `gorm:"column:user" json:"user"`
	Param      string `gorm:"column:param" sql:"type:text" json:"param"`

	ResourceBlockKey string `gorm:"column:resource_block_key" json:"resource_block_key"`
	NoReadyInstance  int    `gorm:"column:no_ready_instance" json:"no_ready_instance"`
	RequestInstance  int    `gorm:"column:request_instance" json:"request_instance"`
	Status           int    `gorm:"column:status;index" json:"status"`

	// broker attributes
	BrokerResourceID string `gorm:"column:broker_resource_id;index" json:"broker_resource_id"`
	BrokerName       string `gorm:"column:broker_name;index" json:"broker_name"`
	BrokerSold       bool   `gorm:"column:broker_sold;index" json:"broker_sold"`
	// contains filtered or unexported fields
}