client

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

type Common struct {
	Name              string    `gorm:"primaryKey;type:varchar(60);not null"`
	Namespace         string    `gorm:"primaryKey;type:varchar(60);not null"`
	UID               string    `gorm:"uniqueIndex;type:varchar(36)"`
	CreationTimestamp time.Time `gorm:"not null"`
	DeletionTimestamp time.Time
	Labels            datatypes.JSON
	Annotations       datatypes.JSON
	OwnerReferences   datatypes.JSON
	Spec              datatypes.JSON
	Status            datatypes.JSON
}

type CommonResourceIfe interface {
	GetKind() string
	GetID() uint
	GetTenantID() uint
	GetProjectID() uint
	GetEnvironmentID() uint
	GetVirtualSpaceID() uint
	GetName() string
	GetCluster() string
	GetNamespace() string
	GetOwners() []CommonResourceIfe
}

type CommonUser struct {
	ID           uint
	Username     string
	Email        string
	Phone        string
	Password     string
	IsActive     *bool
	Kind         string
	Source       string
	CreatedAt    *time.Time
	LastLoginAt  *time.Time
	SystemRole   *SystemRole
	SystemRoleID uint
}

type CommonUserIfe interface {
	GetID() uint
	GetSystemRoleID() uint
	GetUsername() string
	GetUserKind() string
	GetEmail() string
	GetSource() string
	SetLastLogin(*time.Time)
	UnmarshalBinary(data []byte) error
	MarshalBinary() (data []byte, err error)
}

type Cond struct {
	Field string
	Op    ConditionOperator
	Value interface{}
}

type ConditionOperator string

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

type HookPhase string

type KubeClientIfe interface {
	GetEnvironment(cluster, name string, _ map[string]string) (*v1beta1.Environment, error)
	PatchEnvironment(cluster, name string, data *v1beta1.Environment) (*v1beta1.Environment, error)
	DeleteEnvironment(clustername, environment string) error
	CreateOrUpdateEnvironment(clustername, environment string, spec v1beta1.EnvironmentSpec) error

	CreateOrUpdateTenant(clustername, tenantname string, admins, members []string) error
	CreateOrUpdateTenantResourceQuota(clustername, tenantname string, content []byte) error
	CreateOrUpdateSecret(clustername, namespace, name string, data map[string][]byte) error
	DeleteSecretIfExist(clustername, namespace, name string) error
	DeleteTenant(clustername, tenantname string) error
	ClusterResourceStatistics(cluster string, ret interface{}) error
	GetServiceAccount(cluster, namespace, name string, labels map[string]string) (*v1.ServiceAccount, error)
	PatchServiceAccount(cluster, namespace, name string, data *v1.ServiceAccount) (*v1.ServiceAccount, error)
}

type ModelCacheIfe interface {
	// 构建缓存
	BuildCache() error

	// 资源相关
	UpsertTenant(tid uint, name string)
	DelTenant(tid uint)
	UpsertProject(tid, pid uint, name string) error
	DelProject(tid, pid uint) error
	UpsertEnvironment(pid, eid uint, name, cluster, namespace string) error
	DelEnvironment(pid, eid uint) error
	UpsertVirtualSpace(vid uint, name string)
	DelVirtualSpace(vid uint)
	FindParents(kind string, id uint) []CommonResourceIfe
	FindResource(kind string, id uint) CommonResourceIfe
	FindEnvironment(cluster, namespace string) CommonResourceIfe

	// 普通用户相关
	GetUserAuthority(user CommonUserIfe) UserAuthorityIfe
	FlushUserAuthority(user CommonUserIfe) UserAuthorityIfe

	CacheUserInfo(userinfo CommonUserIfe) error
	GetUserInfo(username string, user CommonUserIfe) error

	// openapi 相关用户
	CacheUserInfoViaToken(token string, user CommonUserIfe, ex time.Duration) error
	GetUserInfoViaToken(token string, username string, user CommonUserIfe) error
	UserRequestLimitAllow(user CommonUserIfe, d time.Duration, rate int) (bool, error)
}

type ModelClientIface interface {
	Create(ctx context.Context, obj Object, opts ...Option) error
	Get(ctx context.Context, obj Object, opts ...Option) error
	Update(ctx context.Context, obj Object, opts ...Option) error
	Delete(ctx context.Context, obj Object, opts ...Option) error
	CreateInBatches(ctx context.Context, objs ObjectListIface, opts ...Option) error
	List(ctx context.Context, olist ObjectListIface, opts ...Option) error
	Count(ctx context.Context, o ObjectTypeIface, t *int64, opts ...Option) error
}

type Object interface {
	ObjectTypeIface
	PrimaryKeyValue() interface{}
	PreloadFields() *[]string
}

type ObjectListIface interface {
	ObjectTypeIface
	GetPageSize() (*int64, *int64)
	GetTotal() *int64
	SetPageSize(int64, int64)
	SetTotal(int64)
	DataPtr() interface{}
}

type ObjectTypeIface interface {
	GetKind() *string
	PrimaryKeyField() *string
}

type Option interface {
	Apply(*Query)
}

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

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

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

type Query struct {
	Page            int64
	Size            int64
	Search          string
	SearchFields    []string
	Orders          []string
	Preloads        []string
	Where           []*Cond
	Belong          []Object
	RelationOptions []RelationCondition
}

type Relation struct {
	Key  string
	Kind RelationKind
	Via  ObjectTypeIface
}

type RelationCondition struct {
	Key    string
	Value  interface{}
	Target Object
}

type RelationKind string

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

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

type SystemRole struct {
	ID       uint
	RoleName string
	RoleCode string
}

type UserAuthorityIfe interface {
	// 资源角色
	GetResourceRole(kind string, id uint) string
	// 是否是系统管理员
	IsSystemAdmin() bool
	// 是否是租户管理员
	IsTenantAdmin(tenantid uint) bool
	// 是否是租户成员
	IsTenantMember(tenantid uint) bool
	// 是否是项目管理员
	IsProjectAdmin(projectid uint) bool
	// 是否是项目开发
	IsProjectDev(projectid uint) bool
	// 是否是项目测试
	IsProjectTest(projectid uint) bool
	// 是否是项目运维
	IsProjectOps(projectid uint) bool
	// 是否是环境op
	IsEnvironmentOperator(envid uint) bool
	// 是否是环境reader
	IsEnvironmentReader(envid uint) bool
	// 是否是虚拟空间管理员
	IsVirtualSpaceAdmin(vsid uint) bool
	// 是否是虚拟空间成员
	IsVirtualSpaceMember(vsid uint) bool
	// 是否是一个租户的管理员
	IsAnyTenantAdmin() bool
}

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