secret

type CreateSecretRequest struct {
	// 是否启用
	Enabled *bool `json:"enabled" gorm:"column:enabled"`
	// 名称
	Name string `json:"name" gorm:"column:name"`
	// 尝试
	Vendor resource.VENDOR `json:"vendor" gorm:"column:vendor"`
	// Vmware
	Address string `json:"address" gorm:"column:address"`
	// 需要被脱敏
	// Musk
	ApiKey string `json:"api_key" gorm:"column:api_key"`
	// ApiKey
	ApiSecret string `json:"api_secret" mask:",5,4" gorm:"column:api_secret"`
	// 资源所在区域
	Regions []string `json:"regions" gorm:"column:regions;serializer:json;type:json"`
	// 资源列表
	ResourceType []resource.TYPE `json:"resource_type" gorm:"column:resource_type;serializer:json;type:json"`
	// 同步分页大小
	SyncLimit int64 `json:"sync_limit" gorm:"column:sync_limit"`
	// contains filtered or unexported fields
}

type DescribeSecretRequest struct {
	policy.ResourceScope
	Id string `json:"id"`
}

type QuerySecretRequest struct {
	policy.ResourceScope
	// 分页请求
	*request.PageRequest
}

type QuerySyncLogRequest struct {
	TaskId int `json:"task_id"`
}

type ResourceResponse struct {
	Success    bool
	InstanceId string             `json:"instance_id"`
	Resource   *resource.Resource `json:"resource"`
	Message    string             `json:"message"`
}

type Secret struct {
	model.Meta
	CreateSecretRequest `bson:"inline"`
}

type Service interface {
	// 用于Secret的管理(后台管理员配置)
	// 创建secret
	CreateSecret(context.Context, *CreateSecretRequest) (*Secret, error)
	// 查询secret
	QuerySecret(context.Context, *QuerySecretRequest) (*types.Set[*Secret], error)
	// 查询详情, 已解密, API层需要脱敏
	DescribeSecret(context.Context, *DescribeSecretRequest) (*Secret, error)

	// 使用task模块来执行异步任务, 通过TaskId查询异步任务状态
	SyncResource(context.Context, *SyncResourceRequest) (*types.Set[*task.Task], error)
}

type SyncRecord struct {
}

type SyncResourceHandleFunc func(ResourceResponse)

type SyncResourceRequest struct {
	Id string `json:"id"`
}

type SyncResourceTask struct {
}

type Syncer interface {
	// 资源同步
	Sync(ctx context.Context, ins *Secret, region string, rt resource.TYPE) *task.Task
}