db

func (*DBService) AddAuthorizedKey ¶

func (d *DBService) AddAuthorizedKey(username string, pub string) error

addAuthorizedKey

func (*DBService) AddBroadcast ¶

func (d *DBService) AddBroadcast(req model.CreateBroadcastRequest) error

add broadcast

func (*DBService) AddGroupsToPolicy ¶

func (d *DBService) AddGroupsToPolicy(name string, groups []string) error

func (*DBService) AddKey ¶

func (d *DBService) AddKey(req model.AddKeyRequest) (string, error)

支持判断 key_id 是否存在

func (*DBService) AddScpRecord ¶

func (d *DBService) AddScpRecord(req *model.AddScpRecordRequest) (err error)

func (*DBService) AddServerLoginRecord ¶

func (d *DBService) AddServerLoginRecord(req *model.AddSshLoginRequest) (err error)

登录记录入库

func (*DBService) AddUsersToPolicy ¶

func (d *DBService) AddUsersToPolicy(name string, usernames []string) error

func (*DBService) ApprovePolicy ¶

func (d *DBService) ApprovePolicy(policyName, Approver string, IsEnabled bool) error

func (*DBService) AuthKey ¶

func (d *DBService) AuthKey(username string, pub ssh.PublicKey) bool

支持单个用户多个公钥认证

func (*DBService) CreatePolicy ¶

func (d *DBService) CreatePolicy(req *model.PolicyRequest) (string, error)

func (*DBService) CreateProfile ¶

func (d *DBService) CreateProfile(req model.CreateProfileRequest) (string, error)

func (*DBService) CreateProxy ¶

func (d *DBService) CreateProxy(req model.CreateProxyRequest) (model.Proxy, error)

func (*DBService) CreateShellTask ¶

func (d *DBService) CreateShellTask(req CreateShellTaskRequest) (string, error)

func (*DBService) CreateShellTaskRecord ¶

func (d *DBService) CreateShellTaskRecord(req *CreateShellTaskRecordRequest) error

func (*DBService) CreateUser ¶

func (d *DBService) CreateUser(req *UserRequest) (string, error)

自带校验是否存在

func (*DBService) DeleteKey ¶

func (d *DBService) DeleteKey(uuid string) error

func (*DBService) DeletePolicy ¶

func (d *DBService) DeletePolicy(id string) error

func (*DBService) DeleteProfile ¶

func (d *DBService) DeleteProfile(uuid string) error

func (*DBService) DeleteProxy ¶

func (d *DBService) DeleteProxy(uuid string) error

func (*DBService) DeleteShellTask ¶

func (d *DBService) DeleteShellTask(uuid string) error

func (*DBService) DescribeUser ¶

func (d *DBService) DescribeUser(name string) (User, error)

func (*DBService) GetBroadcast ¶

func (d *DBService) GetBroadcast() (*model.Broadcast, error)

get broadcast

func (*DBService) GetKeyByUsername ¶

func (d *DBService) GetKeyByUsername(username string) ([]model.AuthorizedKey, error)

func (*DBService) GetProxyByIP ¶

func (d *DBService) GetProxyByIP(ip string) (*model.CreateProxyRequest, error)

func (*DBService) GetShellTask ¶

func (d *DBService) GetShellTask(uuid string) (*ShellTask, error)

func (*DBService) InternalLoadKey ¶

func (d *DBService) InternalLoadKey() ([]model.AddKeyRequest, error)

func (*DBService) ListKey ¶

func (d *DBService) ListKey() ([]model.Key, error)

func (*DBService) ListProfile ¶

func (d *DBService) ListProfile() ([]model.Profile, error)

func (*DBService) ListProxy ¶

func (d *DBService) ListProxy() ([]model.CreateProxyRequest, error)

func (*DBService) ListScpRecord ¶

func (d *DBService) ListScpRecord(req model.QueryScpRequest) (records []model.ScpRecord, err error)

ListScpRecord

func (*DBService) ListServerLoginRecord ¶

func (d *DBService) ListServerLoginRecord(req model.QueryLoginRequest) (records []model.SSHLoginRecord, err error)

ListServerLoginRecord

func (*DBService) ListShellTask ¶

func (d *DBService) ListShellTask() ([]ShellTask, error)

TODO: 支持条件查询

func (*DBService) LoadProfile ¶

func (d *DBService) LoadProfile() ([]model.CreateProfileRequest, error)

内部服务调用，不隐藏敏感信息

func (*DBService) Login ¶

func (d *DBService) Login(username, password string) (bool, error)

login,

func (*DBService) NeedApprove ¶

func (d *DBService) NeedApprove(username string) ([]*Policy, error)

func (*DBService) PatchUserGroup ¶

func (d *DBService) PatchUserGroup(id string, req *UserPatchMut) error

func (*DBService) QueryAllPolicy ¶

func (d *DBService) QueryAllPolicy() ([]model.Policy, error)

func (*DBService) QueryAllPolicyOld ¶

func (d *DBService) QueryAllPolicyOld() ([]model.PolicyOld, error)

查询所有

func (*DBService) QueryAllUser ¶

func (d *DBService) QueryAllUser() ([]User, error)

func (*DBService) QueryPolicyById ¶

func (d *DBService) QueryPolicyById(id string) (*model.Policy, error)

QueryPolicyById

func (*DBService) QueryPolicyByName ¶

func (d *DBService) QueryPolicyByName(name string) ([]model.Policy, error)

查询策略名称

func (*DBService) QueryPolicyByUser ¶

func (d *DBService) QueryPolicyByUser(username string) ([]model.Policy, error)

只查询用户的策略 支持policy users 包含*的情况，表示都能命中

func (*DBService) QueryShellTaskRecord ¶

func (d *DBService) QueryShellTaskRecord(query *QueryRecordRequest) ([]ShellTaskRecord, error)

func (*DBService) QueryUserByGroup ¶

func (d *DBService) QueryUserByGroup(group string) ([]User, error)

func (*DBService) RemoveGroupsFromPolicy ¶

func (d *DBService) RemoveGroupsFromPolicy(name string, groups []string) error

RemoveGroupsFromPolicy

func (*DBService) RemoveUsersFromPolicy ¶

func (d *DBService) RemoveUsersFromPolicy(name string, usernames []string) error

func (*DBService) SyncToTargetDB ¶

func (d *DBService) SyncToTargetDB(targetRdb *gorm.DB, talbeNames []string) error

SyncToTargetDB 同步到备份数据库 会删除备份库的表再创建

func (*DBService) UpdateActionsOfPolicy ¶

func (d *DBService) UpdateActionsOfPolicy(name string, actions []string) error

func (*DBService) UpdatePolicy ¶

func (d *DBService) UpdatePolicy(id string, mut *model.PolicyRequest) error

func (*DBService) UpdatePolicyStatus ¶

func (d *DBService) UpdatePolicyStatus(id string, mut model.ApprovalResult) error

func (*DBService) UpdateProfile ¶

func (d *DBService) UpdateProfile(uuid string, req model.CreateProfileRequest) error

func (*DBService) UpdateProxy ¶

func (d *DBService) UpdateProxy(uuid string, req model.CreateProxyRequest) (model.Proxy, error)

func (*DBService) UpdateShellTask ¶

func (d *DBService) UpdateShellTask(uuid string, req *CreateShellTaskRequest) error

func (*DBService) UpdateShellTaskStatus ¶

func (d *DBService) UpdateShellTaskStatus(uuid string, status Status, output string) error

func (*DBService) UpdateUser ¶

func (d *DBService) UpdateUser(id string, req UserRequest) error

支持如果没有用户则报错