controllers

package
v0.6.1 Latest Latest
Warning

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

Go to latest
Published: Jun 17, 2018 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	REQURI_CLUSTER_GETALL     = "/cluster/queryClusters"
	REQURI_CLUSTER_GETBYID    = "/cluster/getById"
	REQURI_CLUSTER_CREATE     = "/cluster/createCluster"
	REQURI_CLUSTER_INIT       = "/cluster/initCluster"
	REQURI_CLUSTER_TOGGLEAUTO = "/cluster/toggleAuto"
)
View Source
const (
	REQURI_LOCK_NAMESPACE_GETALL = "/lock/namespace/queryList"
	REQURI_LOCK_NAMESPACE_APPLY  = "/lock/namespace/apply"
	REQURI_LOCK_CLUSTER_INFO     = "/lock/cluster/get"
	REQURI_LOCK_NAMESPACE_UPDATE = "/lock/namespace/update"
)
View Source
const (
	REQURI_MASTER_All             = "/master/queryAll"
	REQURI_MASTER_Leader          = "/master/queryLeader"
	REQURI_MASTER_LOGLEVEL_UPDATE = "/master/logLevelUpdate"
)
View Source
const (
	REQURL_META_CREATEDB        = "/metadata/createDb"
	REQURL_META_GETALLDB        = "/metadata/dbDataGetAll"
	REQURL_META_GETALLDBVIEW    = "/metadata/dbDataGetAllViewPage"
	REQURL_META_CREATETABLE     = "/metadata/createTable"
	REQURL_META_GETALLTABLE     = "/metadata/dbTablesDataGetByDbName"
	REQURL_META_DELTABLE        = "/metadata/delTable"
	REQURL_META_EDITTABLE       = "/metadata/editTable"
	REQURL_META_GETTABLECOLUMNS = "/metadata/getTableColumns"

	RANGE_GETRANGEBYDBTABLE = "/range/getRangeByBbTable"
)
View Source
const (
	NODE_NODEINFOGETALL     = "/node/nodeInfoGetAll"
	NODE_NODESTATUSUPDATE   = "/node/nodeStatusUpdate"
	NODE_NODELOGLEVELUPDATE = "/node/nodeLogLevelUpdate"
	NODE_DELETENODE         = "/node/deleteNode"
	NODE_GET_RANGE_TOPOLOGY = "/node/getRangeTopoByNode"
)
View Source
const (
	RANGE_PEERDEL              = "/range/peerDel"
	RANGE_PEERADD              = "/range/peerAdd"
	RANGE_GET_UNHEALTHY_RANGES = "/range/getUnhealthyRanges"
	RANGE_GET_UNSTABLE_RANGES  = "/range/getUnstableRanges"
	RANGE_GET_PEER_INFO        = "/range/getPeerInfo"
	RANGE_GET_RANGE_INFO_BY_ID = "/range/getRangeInfoById"
	RANGE_UPDATE_RANGE         = "/range/updateRange"
	RANGE_OFFLINE_RANGE        = "/range/offlineRange"
	RANGE_REBUILD_RANGE        = "/range/rebuildRange"
	RANGE_REPLACE_RANGE        = "/range/replaceRange"
	RANGE_DELETE_RANGE         = "/range/delete"
	RANGE_GET_TOPOLOGY         = "/range/getRangeTopoByRange"
	RANGE_BATCH_RECOVER_RANGE  = "/range/batchRecoverRange"
	RANGE_TRANSFER             = "/range/transfer"
	RANGE_CHANGE_LEADER        = "/range/changeLeader"
	RANGE_OPS_TOPN             = "/range/getOpsTopN"

	RANGE_DUPLICATE_GET = "/table/duplicateRange"

	TASK_GET_PRESENT = "/task/getPresentTaskById"
	TASK_OPERATION   = "/task/taskOperationById"
)
View Source
const (
	REQURI_SCHEDULER_GETALL    = "/scheduler/getAll"
	REQURI_SCHEDULER_GETDETAIL = "/scheduler/getDetail"
	REQURI_SCHEDULER_ADJUST    = "/scheduler/adjust"

	REQURI_TASK_GETTASKTYPEALL = "/task/getTypeAll"
)
View Source
const (
	REQURI_TOPOLOGY_CHECK          = "/topology/check"
	REQURI_TABLE_TOPOLOGY          = "/table/topology/missing"
	REQURI_TABLE_TOPOLOGY_CREATE   = "/table/topology/create"
	REQURI_CLUSTER_TOPOLOGY_GETALL = "/cluster/topology/getall"
)
View Source
const (
	REQURI_USER_ADMIN            = "/userInfo/admin"
	REQURI_USER_GETUSERLIST      = "/userInfo/getUserList"
	REQURI_USER_GETPRIVILEGELIST = "/userInfo/getPrivilegeList"
	REQURI_USER_UPDATEPRIVILEG   = "/userInfo/updatePrivilege"
	REQURI_USER_DELRIVILEGS      = "/userInfo/delPrivileges"
	REQURI_USER_GETROLELIST      = "/userInfo/getRoleList"
	REQURI_USER_ADDROLE          = "/userInfo/addRole"
	REQURI_USER_DELROLE          = "/userInfo/delRole"
)
View Source
const (
	REQURI_DB_CONSOLE_QUERY = "/db/console/query"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Action

type Action interface {
	Execute(c *gin.Context) (interface{}, error)
}

type ClusterCreateAction

type ClusterCreateAction struct {
}

*

  • 创建集群

func NewClusterCreateAction

func NewClusterCreateAction() *ClusterCreateAction

func (*ClusterCreateAction) Execute

func (ctrl *ClusterCreateAction) Execute(c *gin.Context) (interface{}, error)

type ClusterGetAllAction

type ClusterGetAllAction struct {
}

*

  • 查询集群列表

func NewClusterGetAllAction

func NewClusterGetAllAction() *ClusterGetAllAction

func (*ClusterGetAllAction) Execute

func (ctrl *ClusterGetAllAction) Execute(c *gin.Context) (interface{}, error)

type ClusterGetByIdAction

type ClusterGetByIdAction struct {
}

*

  • 查询集群详情

func NewClusterGetByIdAction

func NewClusterGetByIdAction() *ClusterGetByIdAction

func (*ClusterGetByIdAction) Execute

func (ctrl *ClusterGetByIdAction) Execute(c *gin.Context) (interface{}, error)

type ClusterInitAction

type ClusterInitAction struct {
}

*

  • 集群初始化

func NewClusterInitAction

func NewClusterInitAction() *ClusterInitAction

func (*ClusterInitAction) Execute

func (ctrl *ClusterInitAction) Execute(c *gin.Context) (interface{}, error)

type ClusterToggleAction

type ClusterToggleAction struct {
}

*

  • 集群开关

func NewClusterToggleAction

func NewClusterToggleAction() *ClusterToggleAction

func (*ClusterToggleAction) Execute

func (ctrl *ClusterToggleAction) Execute(c *gin.Context) (interface{}, error)

type CreateDbAction

type CreateDbAction struct {
}

*

  • 创建db

func NewCreateDbAction

func NewCreateDbAction() *CreateDbAction

func (*CreateDbAction) Execute

func (ctrl *CreateDbAction) Execute(c *gin.Context) (interface{}, error)

type CreateTableAction

type CreateTableAction struct {
}

*

  • 创建表

func NewCreateTableAction

func NewCreateTableAction() *CreateTableAction

func (*CreateTableAction) Execute

func (ctrl *CreateTableAction) Execute(c *gin.Context) (interface{}, error)

type DeleteTableAction

type DeleteTableAction struct {
}

*

  • 删除表

func NewDeleteTableAction

func NewDeleteTableAction() *DeleteTableAction

func (*DeleteTableAction) Execute

func (ctrl *DeleteTableAction) Execute(c *gin.Context) (interface{}, error)

type EditTableAction

type EditTableAction struct {
}

*

  • 修改表

func NewEditTableAction

func NewEditTableAction() *EditTableAction

func (*EditTableAction) Execute

func (ctrl *EditTableAction) Execute(c *gin.Context) (interface{}, error)

type GetAllDbAction

type GetAllDbAction struct {
}

*

  • 获取集群全部db

func NewGetAllDbAction

func NewGetAllDbAction() *GetAllDbAction

func (*GetAllDbAction) Execute

func (ctrl *GetAllDbAction) Execute(c *gin.Context) (interface{}, error)

type GetAllDbViewAction

type GetAllDbViewAction struct {
}

*

  • 获取集群全部db,View版本

func NewGetAllDbViewAction

func NewGetAllDbViewAction() *GetAllDbViewAction

func (*GetAllDbViewAction) Execute

func (ctrl *GetAllDbViewAction) Execute(c *gin.Context) (interface{}, error)

type GetAllTableAction

type GetAllTableAction struct {
}

*

  • 获取全部表

func NewGetAllTableAction

func NewGetAllTableAction() *GetAllTableAction

func (*GetAllTableAction) Execute

func (ctrl *GetAllTableAction) Execute(c *gin.Context) (interface{}, error)

type GetTableColumns

type GetTableColumns struct {
}

*

  • 获取某表详情

func NewGetTableColumns

func NewGetTableColumns() *GetTableColumns

func (*GetTableColumns) Execute

func (ctrl *GetTableColumns) Execute(c *gin.Context) (interface{}, error)

type GetUnhealthyRanges

type GetUnhealthyRanges struct {
}

func NewGetUnhealthyRanges

func NewGetUnhealthyRanges() *GetUnhealthyRanges

func (*GetUnhealthyRanges) Execute

func (ctrl *GetUnhealthyRanges) Execute(c *gin.Context) (interface{}, error)

type GetUnstableRanges

type GetUnstableRanges struct {
}

func NewGetUnstableRanges

func NewGetUnstableRanges() *GetUnstableRanges

func (*GetUnstableRanges) Execute

func (ctrl *GetUnstableRanges) Execute(c *gin.Context) (interface{}, error)

type LockClusterGetAction

type LockClusterGetAction struct {
}

*

  • lock cluster 刚上线的时候,锁集群是通过配置的,后期改成获取对应权限的集群列表

func NewLockClusterGetAction

func NewLockClusterGetAction() *LockClusterGetAction

func (*LockClusterGetAction) Execute

func (ctrl *LockClusterGetAction) Execute(c *gin.Context) (interface{}, error)

type LockGetAllNspAction

type LockGetAllNspAction struct {
}

*

  • 查询lock namespace 列表

func NewLockGetAllNspAction

func NewLockGetAllNspAction() *LockGetAllNspAction

func (*LockGetAllNspAction) Execute

func (ctrl *LockGetAllNspAction) Execute(c *gin.Context) (interface{}, error)

type LockNspApplyAction

type LockNspApplyAction struct {
}

*

  • 申请lock namespace

func NewLockNspApplyAction

func NewLockNspApplyAction() *LockNspApplyAction

func (*LockNspApplyAction) Execute

func (ctrl *LockNspApplyAction) Execute(c *gin.Context) (interface{}, error)

type LockNspUpdateAction

type LockNspUpdateAction struct {
}

*

  • lock namespace修改

func NewLockNspUpdateAction

func NewLockNspUpdateAction() *LockNspUpdateAction

func (*LockNspUpdateAction) Execute

func (ctrl *LockNspUpdateAction) Execute(c *gin.Context) (interface{}, error)

type MasterAllAction

type MasterAllAction struct {
}

*

  • 集群master all

func NewMasterAllAction

func NewMasterAllAction() *MasterAllAction

func (*MasterAllAction) Execute

func (ctrl *MasterAllAction) Execute(c *gin.Context) (interface{}, error)

type MasterLeaderAction

type MasterLeaderAction struct {
}

*

  • 集群master

func NewMasterLeaderAction

func NewMasterLeaderAction() *MasterLeaderAction

func (*MasterLeaderAction) Execute

func (ctrl *MasterLeaderAction) Execute(c *gin.Context) (interface{}, error)

type MasterLogLevelUpdate

type MasterLogLevelUpdate struct {
}

func NewMasterLogLevelUpdate

func NewMasterLogLevelUpdate() *MasterLogLevelUpdate

func (*MasterLogLevelUpdate) Execute

func (ctrl *MasterLogLevelUpdate) Execute(c *gin.Context) (interface{}, error)

type NodeDelete

type NodeDelete struct {
}

func NewNodeDelete

func NewNodeDelete() *NodeDelete

func (*NodeDelete) Execute

func (ctrl *NodeDelete) Execute(c *gin.Context) (interface{}, error)

type NodeLogLevelUpdate

type NodeLogLevelUpdate struct {
}

func NewNodeLogLevelUpdate

func NewNodeLogLevelUpdate() *NodeLogLevelUpdate

func (*NodeLogLevelUpdate) Execute

func (ctrl *NodeLogLevelUpdate) Execute(c *gin.Context) (interface{}, error)

type NodeRangeTopo

type NodeRangeTopo struct {
}

func NewNodeRangeTopo

func NewNodeRangeTopo() *NodeRangeTopo

func (*NodeRangeTopo) Execute

func (ctrl *NodeRangeTopo) Execute(c *gin.Context) (interface{}, error)

type NodeStatusUpdate

type NodeStatusUpdate struct {
}

func NewNodeStatusUpdate

func NewNodeStatusUpdate() *NodeStatusUpdate

func (*NodeStatusUpdate) Execute

func (ctrl *NodeStatusUpdate) Execute(c *gin.Context) (interface{}, error)

type NodeViewInfo

type NodeViewInfo struct {
}

func NewNodeViewInfo

func NewNodeViewInfo() *NodeViewInfo

func (*NodeViewInfo) Execute

func (ctrl *NodeViewInfo) Execute(c *gin.Context) (interface{}, error)

type PeerAdd

type PeerAdd struct {
}

func NewPeerAdd

func NewPeerAdd() *PeerAdd

func (*PeerAdd) Execute

func (ctrl *PeerAdd) Execute(c *gin.Context) (interface{}, error)

type PeerDelete

type PeerDelete struct {
}

func NewPeerDelete

func NewPeerDelete() *PeerDelete

func (*PeerDelete) Execute

func (ctrl *PeerDelete) Execute(c *gin.Context) (interface{}, error)

type PeerInfoView

type PeerInfoView struct {
}

func NewPeerInfoView

func NewPeerInfoView() *PeerInfoView

func (*PeerInfoView) Execute

func (ctrl *PeerInfoView) Execute(c *gin.Context) (interface{}, error)

type PrivilegeDelAction

type PrivilegeDelAction struct {
}

func NewPrivilegeDelAction

func NewPrivilegeDelAction() *PrivilegeDelAction

func (*PrivilegeDelAction) Execute

func (ctrl *PrivilegeDelAction) Execute(c *gin.Context) (interface{}, error)

type PrivilegeInfoAction

type PrivilegeInfoAction struct {
}

func NewPrivilegeInfoAction

func NewPrivilegeInfoAction() *PrivilegeInfoAction

func (*PrivilegeInfoAction) Execute

func (ctrl *PrivilegeInfoAction) Execute(c *gin.Context) (interface{}, error)

type PrivilegeUpdateAction

type PrivilegeUpdateAction struct {
}

func NewPrivilegeUpdateAction

func NewPrivilegeUpdateAction() *PrivilegeUpdateAction

func (*PrivilegeUpdateAction) Execute

func (ctrl *PrivilegeUpdateAction) Execute(c *gin.Context) (interface{}, error)

type RangeBatchRecover

type RangeBatchRecover struct {
}

func NewRangeBatchRecover

func NewRangeBatchRecover() *RangeBatchRecover

func (*RangeBatchRecover) Execute

func (ctrl *RangeBatchRecover) Execute(c *gin.Context) (interface{}, error)

type RangeDelete

type RangeDelete struct {
}

func NewRangeDelete

func NewRangeDelete() *RangeDelete

func (*RangeDelete) Execute

func (ctrl *RangeDelete) Execute(c *gin.Context) (interface{}, error)

type RangeDuplicateAction

type RangeDuplicateAction struct {
}

func NewRangeDuplicateAction

func NewRangeDuplicateAction() *RangeDuplicateAction

func (*RangeDuplicateAction) Execute

func (ctrl *RangeDuplicateAction) Execute(c *gin.Context) (interface{}, error)

type RangeInfoView

type RangeInfoView struct {
}

func NewRangeInfoView

func NewRangeInfoView() *RangeInfoView

func (*RangeInfoView) Execute

func (ctrl *RangeInfoView) Execute(c *gin.Context) (interface{}, error)

type RangeLeaderChange

type RangeLeaderChange struct {
}

切换主

func NewRangeLeaderChange

func NewRangeLeaderChange() *RangeLeaderChange

func (*RangeLeaderChange) Execute

func (ctrl *RangeLeaderChange) Execute(c *gin.Context) (interface{}, error)

type RangeOffline

type RangeOffline struct {
}

func NewRangeOffline

func NewRangeOffline() *RangeOffline

func (*RangeOffline) Execute

func (ctrl *RangeOffline) Execute(c *gin.Context) (interface{}, error)

type RangeOpsTopN

type RangeOpsTopN struct {
}

range opt topN

func NewRangeOpsTopN

func NewRangeOpsTopN() *RangeOpsTopN

func (*RangeOpsTopN) Execute

func (ctrl *RangeOpsTopN) Execute(c *gin.Context) (interface{}, error)

type RangeRebuild

type RangeRebuild struct {
}

func NewRangeRebuild

func NewRangeRebuild() *RangeRebuild

func (*RangeRebuild) Execute

func (ctrl *RangeRebuild) Execute(c *gin.Context) (interface{}, error)

type RangeReplace

type RangeReplace struct {
}

func NewRangeReplace

func NewRangeReplace() *RangeReplace

func (*RangeReplace) Execute

func (ctrl *RangeReplace) Execute(c *gin.Context) (interface{}, error)

type RangeTopo

type RangeTopo struct {
}

func NewRangeTopo

func NewRangeTopo() *RangeTopo

func (*RangeTopo) Execute

func (ctrl *RangeTopo) Execute(c *gin.Context) (interface{}, error)

type RangeTransfer

type RangeTransfer struct {
}

func NewRangeTransfer

func NewRangeTransfer() *RangeTransfer

func (*RangeTransfer) Execute

func (ctrl *RangeTransfer) Execute(c *gin.Context) (interface{}, error)

type RangeUpdate

type RangeUpdate struct {
}

func NewRangeUpdate

func NewRangeUpdate() *RangeUpdate

func (*RangeUpdate) Execute

func (ctrl *RangeUpdate) Execute(c *gin.Context) (interface{}, error)

type RangeViewInfo

type RangeViewInfo struct {
}

func NewRangeViewInfo

func NewRangeViewInfo() *RangeViewInfo

func (*RangeViewInfo) Execute

func (ctrl *RangeViewInfo) Execute(c *gin.Context) (interface{}, error)

type Response

type Response struct {
	Code int         `json:"code"`
	Msg  string      `json:"msg"`
	Data interface{} `json:"data"`
}

type RoleAddAction

type RoleAddAction struct {
}

func NewRoleAddAction

func NewRoleAddAction() *RoleAddAction

func (*RoleAddAction) Execute

func (ctrl *RoleAddAction) Execute(c *gin.Context) (interface{}, error)

type RoleDelAction

type RoleDelAction struct {
}

func NewRoleDelAction

func NewRoleDelAction() *RoleDelAction

func (*RoleDelAction) Execute

func (ctrl *RoleDelAction) Execute(c *gin.Context) (interface{}, error)

type RoleInfoAction

type RoleInfoAction struct {
}

func NewRoleInfoAction

func NewRoleInfoAction() *RoleInfoAction

func (*RoleInfoAction) Execute

func (ctrl *RoleInfoAction) Execute(c *gin.Context) (interface{}, error)

type SchedulerAdjustAction

type SchedulerAdjustAction struct {
}

*

  • 集群scheduler调整

func NewSchedulerAdjustAction

func NewSchedulerAdjustAction() *SchedulerAdjustAction

func (*SchedulerAdjustAction) Execute

func (ctrl *SchedulerAdjustAction) Execute(c *gin.Context) (interface{}, error)

type SchedulerAllAction

type SchedulerAllAction struct {
}

*

  • 查询集群正在执行的调度任务列表

func NewSchedulerAllAction

func NewSchedulerAllAction() *SchedulerAllAction

func (*SchedulerAllAction) Execute

func (ctrl *SchedulerAllAction) Execute(c *gin.Context) (interface{}, error)

type SchedulerDetailAction

type SchedulerDetailAction struct {
}

func NewSchedulerDetailAction

func NewSchedulerDetailAction() *SchedulerDetailAction

func (*SchedulerDetailAction) Execute

func (ctrl *SchedulerDetailAction) Execute(c *gin.Context) (interface{}, error)

type StoreDataQuery

type StoreDataQuery struct {
}

func NewStoreDataQuery

func NewStoreDataQuery() *StoreDataQuery

func (*StoreDataQuery) Execute

func (ctrl *StoreDataQuery) Execute(c *gin.Context) (interface{}, error)

type TableTopologyAction

type TableTopologyAction struct {
}

func NewTableTopologyAction

func NewTableTopologyAction() *TableTopologyAction

func (*TableTopologyAction) Execute

func (ctrl *TableTopologyAction) Execute(c *gin.Context) (interface{}, error)

type TaskOperation

type TaskOperation struct {
}

func NewTaskOperation

func NewTaskOperation() *TaskOperation

func (*TaskOperation) Execute

func (t *TaskOperation) Execute(c *gin.Context) (interface{}, error)

type TaskPresent

type TaskPresent struct {
}

func NewTaskPresent

func NewTaskPresent() *TaskPresent

func (*TaskPresent) Execute

func (t *TaskPresent) Execute(c *gin.Context) (interface{}, error)

type TaskTypeAllAction

type TaskTypeAllAction struct {
}

func NewTaskTypeAllAction

func NewTaskTypeAllAction() *TaskTypeAllAction

func (*TaskTypeAllAction) Execute

func (ctrl *TaskTypeAllAction) Execute(c *gin.Context) (interface{}, error)

type TopologyAction

type TopologyAction struct {
}

func NewTopologyAction

func NewTopologyAction() *TopologyAction

func (*TopologyAction) Execute

func (ctrl *TopologyAction) Execute(c *gin.Context) (interface{}, error)

type TopologyRangeCreateAction

type TopologyRangeCreateAction struct {
}

func NewTopologyRangeCreateAction

func NewTopologyRangeCreateAction() *TopologyRangeCreateAction

func (*TopologyRangeCreateAction) Execute

func (ctrl *TopologyRangeCreateAction) Execute(c *gin.Context) (interface{}, error)

type TopologyViewAction

type TopologyViewAction struct {
}

func NewTopologyViewAction

func NewTopologyViewAction() *TopologyViewAction

func (*TopologyViewAction) Execute

func (ctrl *TopologyViewAction) Execute(c *gin.Context) (interface{}, error)

type UserAdminAction

type UserAdminAction struct {
}

func NewUserAdminAction

func NewUserAdminAction() *UserAdminAction

func (*UserAdminAction) Execute

func (ctrl *UserAdminAction) Execute(c *gin.Context) (interface{}, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL