service

package
v0.0.0-...-f69eaad Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 1, 2020 License: GPL-3.0 Imports: 17 Imported by: 0

README

SDK层

Documentation

Index

Constants

View Source 
const (
	ErrLoginConfirmWait     = "login_confirm_wait"
	ErrLoginConfirmRejected = "login_confirm_rejected"
	ErrLoginConfirmRequired = "login_confirm_required"
	ErrMFARequired          = "mfa_required"
	ErrPasswordFailed       = "password_failed"
)
View Source 
const (
	UserProfileURL = "/api/v1/users/profile/"                            // 获取当前用户的基本信息
	UserListURL    = "/api/v1/users/users/"                              // 用户列表地址
	UserDetailURL  = "/api/v1/users/users/%s/"                           // 获取用户信息
	TokenAssetURL  = "/api/v1/authentication/connection-token/?token=%s" // Token name

	SystemUserAssetAuthURL          = "/api/v1/assets/system-users/%s/assets/%s/auth-info/" // 该系统用户对某资产的授权
	SystemUserCmdFilterRulesListURL = "/api/v1/assets/system-users/%s/cmd-filter-rules/"    // 过滤规则url
	SystemUserDetailURL             = "/api/v1/assets/system-users/%s/"                     // 某个系统用户的信息
	AssetDetailURL                  = "/api/v1/assets/assets/%s/"                           // 某一个资产信息
	DomainDetailURL                 = "/api/v1/assets/domains/%s/?gateway=1"

	TerminalRegisterURL  = "/api/v2/terminal/terminal-registrations/" // 注册当前coco
	TerminalConfigURL    = "/api/v1/terminal/terminals/config/"       // 从jumpserver获取coco的配置
	TerminalHeartBeatURL = "/api/v1/terminal/terminals/status/"

	SessionListURL    = "/api/v1/terminal/sessions/"           //上传创建的资产会话session id
	SessionDetailURL  = "/api/v1/terminal/sessions/%s/"        // finish session的时候发送
	SessionReplayURL  = "/api/v1/terminal/sessions/%s/replay/" //上传录像
	SessionCommandURL = "/api/v1/terminal/commands/"           //上传批量命令
	FinishTaskURL     = "/api/v1/terminal/tasks/%s/"

	FTPLogListURL = "/api/v1/audits/ftp-logs/" // 上传 ftp日志

	UserAssetsURL                  = "/api/v1/perms/users/%s/assets/"       //获取用户授权的所有资产
	UserNodesAssetsURL             = "/api/v1/perms/users/%s/nodes-assets/" // 获取用户授权的所有节点信息 节点分组
	UserNodesListURL               = "/api/v1/perms/users/%s/nodes/"
	UserNodeAssetsListURL          = "/api/v1/perms/users/%s/nodes/%s/assets/"
	ValidateUserAssetPermissionURL = "/api/v1/perms/asset-permissions/user/validate/" //0不使用缓存 1 使用缓存 2 刷新缓存
)
View Source 
const (
	UserTokenAuthURL   = "/api/v1/authentication/tokens/" // 用户登录验证
	UserConfirmAuthURL = "/api/v1/authentication/login-confirm-ticket/status/"

	NodeTreeWithAssetURL = "/api/v1/perms/users/%s/nodes/children-with-assets/tree/" // 资产树

	DatabaseAPPURL = "/api/v1/perms/users/%s/database-apps/" //数据库app

	UserDatabaseSystemUsersURL = "/api/v1/perms/users/%s/database-apps/%s/system-users/"

	SystemUserAuthURL = "/api/v1/assets/system-users/%s/auth-info/"

	UserAssetsTreeURL = "/api/v1/perms/users/%s/assets/tree/"

	DatabaseDetailURL = "/api/v1/applications/database-apps/%s/"

	ValidateUserDatabasePermissionURL = "/api/v1/perms/database-app-permissions/user/validate/"
)

1.5.5

View Source 
const (
	AssetGatewaysURL = "/api/v1/assets/assets/%s/gateways/"
)

1.5.7

View Source 
const (
	JoinRoomValidateURL = "/api/v1/terminal/sessions/join/validate/"
)
View Source 
const (
	UserAssetSystemUsersURL = "/api/v1/perms/users/%s/assets/%s/system-users/" // 获取用户授权资产的系统用户列表
)

Variables

View Source 
var (
	AccessKeyNotFound     = errors.New("access key not found")
	AccessKeyFileNotFound = errors.New("access key file not found")
	AccessKeyInvalid      = errors.New("access key not valid")
)

Functions

func CheckUserCookie 

func CheckUserCookie(sessionID, csrfToken string) (user *model.User, err error)

func CreateSession 

func CreateSession(data map[string]interface{}) bool

func FinishReply 

func FinishReply(sid string) bool

func FinishSession 

func FinishSession(data map[string]interface{})

func FinishTask 

func FinishTask(tid string) bool

func ForceRefreshUserPemAssets 

func ForceRefreshUserPemAssets(userID string) error

func GetAsset 

func GetAsset(assetID string) (asset model.Asset)

func GetAssetGateways 

func GetAssetGateways(assetID string) (gateways []model.Gateway)

func GetDatabase 

func GetDatabase(dbID string) (res model.Database)

func GetDomainWithGateway 

func GetDomainWithGateway(gID string) (domain model.Domain)

func GetProfile 

func GetProfile() (user *model.User, err error)

func GetSystemUser 

func GetSystemUser(systemUserID string) (info model.SystemUser)

func GetSystemUserAssetAuthInfo 

func GetSystemUserAssetAuthInfo(systemUserID, assetID string) (info model.SystemUserAuthInfo)

func GetSystemUserDatabaseAuthInfo 

func GetSystemUserDatabaseAuthInfo(systemUserID string) (info model.SystemUserAuthInfo)

func GetSystemUserFilterRules 

func GetSystemUserFilterRules(systemUserID string) (rules []model.SystemUserFilterRule, err error)

func GetTokenAsset 

func GetTokenAsset(token string) (tokenUser model.TokenUser)

func GetUserAllAssets 

func GetUserAllAssets(userID string) (assets []model.Asset)

func GetUserAssetAuthInfo 

func GetUserAssetAuthInfo(systemUserID, assetID, userID, username string) (info model.SystemUserAuthInfo)

func GetUserAssetByID 

func GetUserAssetByID(userID, assertID string) (assets []model.Asset)

func GetUserAssetSystemUsers 

func GetUserAssetSystemUsers(userID, assetID string) (sysUsers []model.SystemUser)

func GetUserAssets 

func GetUserAssets(userID string, pageSize, offset int, searches ...string) (resp model.AssetsPaginationResponse)

func GetUserByUsername 

func GetUserByUsername(username string) (user *model.User, err error)

func GetUserDatabaseSystemUsers 

func GetUserDatabaseSystemUsers(userID, assetID string) (sysUsers []model.SystemUser)

func GetUserDatabases 

func GetUserDatabases(uid string) (res []model.Database)

func GetUserDetail 

func GetUserDetail(userID string) (user *model.User)

func GetUserNodeAssets 

func GetUserNodeAssets(userID, nodeID, cachePolicy string) (assets model.AssetList)

func GetUserNodePaginationAssets 

func GetUserNodePaginationAssets(userID, nodeID string, pageSize, offset int, searches ...string) (resp model.AssetsPaginationResponse)

func GetUserNodeTreeWithAsset 

func GetUserNodeTreeWithAsset(userID, nodeID, cachePolicy string) (nodeTrees model.NodeTreeList)

func GetUserNodes 

func GetUserNodes(userID, cachePolicy string) (nodes model.NodeList)

func Initial 

func Initial(ctx context.Context)

func JoinRoomValidate 

func JoinRoomValidate(userID, sessionID string) bool

func KeepSyncConfigWithServer 

func KeepSyncConfigWithServer(ctx context.Context)

func LoadConfigFromServer 

func LoadConfigFromServer() (err error)

func MustLoadServerConfigOnce 

func MustLoadServerConfigOnce()

func PushFTPLog 

func PushFTPLog(data *model.FTPLog) (err error)

func PushSessionCommand 

func PushSessionCommand(commands []*model.Command) (err error)

func PushSessionReplay 

func PushSessionReplay(sessionID, gZipFile string) (err error)

func RegisterTerminal 

func RegisterTerminal(name, token, comment string) (res model.Terminal)

func SearchPermAsset 

func SearchPermAsset(uid, key string) (res model.NodeTreeList, err error)

func TerminalHeartBeat 

func TerminalHeartBeat(sIds []string) (res []model.TerminalTask)

func ValidateUserAssetPermission 

func ValidateUserAssetPermission(userID, assetID, systemUserID, action string) bool

func ValidateUserDatabasePermission 

func ValidateUserDatabasePermission(userID, databaseID, systemUserID string) bool

Types

type AccessKey 

type AccessKey struct {
	ID     string
	Secret string
	Path   string
	Value  string
}

func (*AccessKey) Load 

func (ak *AccessKey) Load() (err error)

LoadAccessKey 加载AccessKey用来与 Core Api 交互

func (*AccessKey) LoadAccessKeyFromFile 

func (ak *AccessKey) LoadAccessKeyFromFile(keyPath string) error

func (*AccessKey) LoadAccessKeyFromStr 

func (ak *AccessKey) LoadAccessKeyFromStr(key string) error

func (*AccessKey) Register 

func (ak *AccessKey) Register(times int) error

func (*AccessKey) SaveToFile 

func (ak *AccessKey) SaveToFile() error

func (AccessKey) Sign 

func (ak AccessKey) Sign() (string, string)

type AuthOptions 

type AuthOptions struct {
	Name string
	Url  string
}

type AuthStatus 

type AuthStatus int64
const (
	AuthSuccess AuthStatus = iota + 1
	AuthFailed
	AuthMFARequired
	AuthConfirmRequired
)

type SessionClient 

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

func NewSessionClient 

func NewSessionClient(setters ...SessionOption) SessionClient

func (*SessionClient) Authenticate 

func (u *SessionClient) Authenticate(ctx context.Context) (user model.User, authStatus AuthStatus)

func (*SessionClient) CancelConfirm 

func (u *SessionClient) CancelConfirm()

func (*SessionClient) CheckConfirm 

func (u *SessionClient) CheckConfirm(ctx context.Context) (user model.User, authStatus AuthStatus)

func (*SessionClient) CheckUserOTP 

func (u *SessionClient) CheckUserOTP(ctx context.Context, code string) (user model.User, authStatus AuthStatus)

func (*SessionClient) SetOption 

func (u *SessionClient) SetOption(setters ...SessionOption)

type SessionOption 

type SessionOption func(*SessionOptions)

func LoginType 

func LoginType(loginType string) SessionOption

func Password 

func Password(password string) SessionOption

func PublicKey 

func PublicKey(publicKey string) SessionOption

func RemoteAddr 

func RemoteAddr(remoteAddr string) SessionOption

func Username 

func Username(username string) SessionOption

type SessionOptions 

type SessionOptions struct {
	Username   string
	Password   string
	PublicKey  string
	RemoteAddr string
	LoginType  string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.