admin

package
v0.0.0-...-c4c90f7 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2020 License: Apache-2.0 Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AlterTableArgs_TableSpec_DEFAULT *table.TableSpec
View Source 
var AlterTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var AppInfo_AppId_DEFAULT string
View Source 
var AppInfo_AppName_DEFAULT string
View Source 
var AppInfo_DeveloperId_DEFAULT string
View Source 
var AppInfo_OauthAppMapping_DEFAULT map[string]string
View Source 
var AppInfo_TableMappings_DEFAULT map[string]string
View Source 
var CancelSnapshotTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var ClientMetrics_MetricDataList_DEFAULT []*MetricData
View Source 
var CloneTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var CreateTableArgs_TableSpec_DEFAULT *table.TableSpec
View Source 
var CreateTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var CreateTableResult_Success_DEFAULT *table.TableInfo
View Source 
var DeleteSnapshotResult_Se_DEFAULT *errors.ServiceException
View Source 
var DescribeTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var DescribeTableResult_Success_DEFAULT *table.TableSpec
View Source 
var DisableTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var DropTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var EnableTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var FindAllAppInfoResult_Se_DEFAULT *errors.ServiceException
View Source 
var FindAllAppInfoResult_Success_DEFAULT []*AppInfo
View Source 
var FindAllAppsResult_Se_DEFAULT *errors.ServiceException
View Source 
var FindAllAppsResult_Success_DEFAULT []*AppInfo
View Source 
var FindAllTablesResult_Se_DEFAULT *errors.ServiceException
View Source 
var FindAllTablesResult_Success_DEFAULT []*table.TableInfo
View Source 
var GetAppInfoResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetCeilStreamCheckpointResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetDefaultColdStandByResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetDefaultColdStandByResult_Success_DEFAULT *table.ColdStandBy
View Source 
var GetDevelopIdResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetDevelopIdResult_Success_DEFAULT string
View Source 
var GetFloorStreamCheckpointResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetGrantRuleResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetIndexTableSplitsResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetIndexTableSplitsResult_Success_DEFAULT []*table.TableSplit
View Source 
var GetLatestStreamCheckpointResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetQuotaInfoResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetSnapshotStateResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetSnapshotStateResult_Success_DEFAULT table.SnapshotState
View Source 
var GetTableHistorySizeResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetTableHistorySizeResult_Success_DEFAULT map[int64]int64
View Source 
var GetTableSizeResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetTableSizeResult_Success_DEFAULT int64
View Source 
var GetTableSplitsResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetTableSplitsResult_Success_DEFAULT []*table.TableSplit
View Source 
var GetTableStateResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetTableStateResult_Success_DEFAULT table.TableState
View Source 
var GetTableStatusResult_Se_DEFAULT *errors.ServiceException
View Source 
var GetTableStatusResult_Success_DEFAULT *table.TableStatus
View Source 
var GoUnusedProtection__ int
View Source 
var ListAllDeletedTablesResult_Se_DEFAULT *errors.ServiceException
View Source 
var ListAllDeletedTablesResult_Success_DEFAULT []*table.TableInfo
View Source 
var ListAllSnapshotsResult_Se_DEFAULT *errors.ServiceException
View Source 
var ListAllSnapshotsResult_Success_DEFAULT []*SnapshotTableView
View Source 
var ListSnapshotsResult_Se_DEFAULT *errors.ServiceException
View Source 
var ListSubscribedEmailResult_Se_DEFAULT *errors.ServiceException
View Source 
var ListSubscribedEmailResult_Success_DEFAULT []string
View Source 
var ListSubscribedPhoneResult_Se_DEFAULT *errors.ServiceException
View Source 
var ListSubscribedPhoneResult_Success_DEFAULT []string
View Source 
var MetricData_MetricName_DEFAULT string
View Source 
var MetricData_TimeStamp_DEFAULT int64
View Source 
var MetricData_Value_DEFAULT int64
View Source 
var MetricQueryRequest_DownsampleInterval_DEFAULT int32
View Source 
var MetricQueryRequest_StartTime_DEFAULT int64
View Source 
var MetricQueryRequest_StopTime_DEFAULT int64
View Source 
var MetricQueryRequest_TableName_DEFAULT string
View Source 
var PutClientMetricsResult_Se_DEFAULT *errors.ServiceException
View Source 
var QueryMetricResult_Se_DEFAULT *errors.ServiceException
View Source 
var QueryMetricsResult_Se_DEFAULT *errors.ServiceException
View Source 
var QueryMetricsResult_Success_DEFAULT []*TimeSeriesData
View Source 
var QuotaInfo_AccountId_DEFAULT string
View Source 
var QuotaInfo_ReadCapacityUsed_DEFAULT int64
View Source 
var QuotaInfo_ReadCapacity_DEFAULT int64
View Source 
var QuotaInfo_SlaveReadCapacityUsed_DEFAULT int64
View Source 
var QuotaInfo_SlaveReadCapacity_DEFAULT int64
View Source 
var QuotaInfo_SlaveWriteCapacityUsed_DEFAULT int64
View Source 
var QuotaInfo_SlaveWriteCapacity_DEFAULT int64
View Source 
var QuotaInfo_SpaceUsed_DEFAULT int64
View Source 
var QuotaInfo_Space_DEFAULT int64
View Source 
var QuotaInfo_TableNumUsed_DEFAULT int32
View Source 
var QuotaInfo_TableNum_DEFAULT int32
View Source 
var QuotaInfo_WriteCapacityUsed_DEFAULT int64
View Source 
var QuotaInfo_WriteCapacity_DEFAULT int64
View Source 
var RecoverTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var RenameTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var RestoreSnapshotResult_Se_DEFAULT *errors.ServiceException
View Source 
var RestoreTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var SaveAppInfoResult_Se_DEFAULT *errors.ServiceException
View Source 
var SetGrantRuleResult_Se_DEFAULT *errors.ServiceException
View Source 
var SetSpaceIdResult_Se_DEFAULT *errors.ServiceException
View Source 
var SnapshotTableResult_Se_DEFAULT *errors.ServiceException
View Source 
var SnapshotTableView_TableExist_DEFAULT bool
View Source 
var SnapshotTableView_TableName_DEFAULT string
View Source 
var Snapshot_SnapshotName_DEFAULT string
View Source 
var Snapshot_SnapshotState_DEFAULT table.SnapshotState
View Source 
var StreamCheckpoint_PartitionStates_DEFAULT []*TopicPartitionState
View Source 
var StreamCheckpoint_Timestamp_DEFAULT int64
View Source 
var StreamCheckpoint_TopicName_DEFAULT string
View Source 
var SubscribeEmailAlertResult_Se_DEFAULT *errors.ServiceException
View Source 
var SubscribePhoneAlertResult_Se_DEFAULT *errors.ServiceException
View Source 
var TableSnapshots_ColdStandBySnapshots_DEFAULT []*Snapshot
View Source 
var TableSnapshots_PitrSnapshots_DEFAULT []*Snapshot
View Source 
var TableSnapshots_SysSnapshots_DEFAULT []*Snapshot
View Source 
var TableSnapshots_TableName_DEFAULT string
View Source 
var TableSnapshots_UserSnapshots_DEFAULT []*Snapshot
View Source 
var TimeSeriesData_Data_DEFAULT map[int64]float64
View Source 
var TimeSeriesData_TableName_DEFAULT string
View Source 
var TopicPartitionState_Offset_DEFAULT int64
View Source 
var TopicPartitionState_PartitionId_DEFAULT int32
View Source 
var UnsubscribeEmailAlertResult_Se_DEFAULT *errors.ServiceException
View Source 
var UnsubscribePhoneAlertResult_Se_DEFAULT *errors.ServiceException

Functions

This section is empty.

Types

type AdminService 

type AdminService interface {
	common.BaseService

	// 保存应用信息，用于注册第三方应用OAuth信息
	//
	// Parameters:
	//  - AppInfo
	SaveAppInfo(appInfo *AppInfo) (err error)
	// 查询应用信息
	//
	// Parameters:
	//  - AppId
	GetAppInfo(appId string) (r *AppInfo, err error)
	// 查询指定用户所有应用信息
	FindAllApps() (r []*AppInfo, err error)
	// 获取指定用户所有表信息
	FindAllTables() (r []*table.TableInfo, err error)
	// 创建表
	//
	// Parameters:
	//  - TableName
	//  - TableSpec
	CreateTable(tableName string, tableSpec *table.TableSpec) (r *table.TableInfo, err error)
	// 删除表
	//
	// Parameters:
	//  - TableName
	DropTable(tableName string) (err error)
	// 修改表
	//
	// Parameters:
	//  - TableName
	//  - TableSpec
	AlterTable(tableName string, tableSpec *table.TableSpec) (err error)
	// 克隆表
	//
	// Parameters:
	//  - SrcTableName
	//  - DestTableName
	//  - FlushTable
	CloneTable(srcTableName string, destTableName string, flushTable bool) (err error)
	// 关闭表读写操作
	//
	// Parameters:
	//  - TableName
	DisableTable(tableName string) (err error)
	// 打开表读写操作
	//
	// Parameters:
	//  - TableName
	EnableTable(tableName string) (err error)
	// 获取表定义
	//
	// Parameters:
	//  - TableName
	DescribeTable(tableName string) (r *table.TableSpec, err error)
	// 获取表状态等元信息
	//
	// Parameters:
	//  - TableName
	GetTableStatus(tableName string) (r *table.TableStatus, err error)
	// 获取表状态
	//
	// Parameters:
	//  - TableName
	GetTableState(tableName string) (r table.TableState, err error)
	// 获取表分布信息，如用于MapReduce应用
	//
	// Parameters:
	//  - TableName
	//  - StartKey
	//  - StopKey
	GetTableSplits(tableName string, startKey table.Dictionary, stopKey table.Dictionary) (r []*table.TableSplit, err error)
	// 获取全局二级索引表的表分布信息，如用于MapReduce应用
	//
	// Parameters:
	//  - TableName
	//  - IndexName
	//  - StartKey
	//  - StopKey
	GetIndexTableSplits(tableName string, indexName string, startKey table.Dictionary, stopKey table.Dictionary) (r []*table.TableSplit, err error)
	// 查询表统计指标
	//
	// Parameters:
	//  - Query
	QueryMetric(query *MetricQueryRequest) (r *TimeSeriesData, err error)
	// 批量查询表统计指标
	//
	// Parameters:
	//  - Queries
	QueryMetrics(queries []*MetricQueryRequest) (r []*TimeSeriesData, err error)
	// 获取AppInfo列表,只包括appId和appName
	FindAllAppInfo() (r []*AppInfo, err error)
	// 获取表空间大小
	//
	// Parameters:
	//  - TableName
	GetTableSize(tableName string) (r int64, err error)
	// 上传客户端metrics
	//
	// Parameters:
	//  - ClientMetrics
	PutClientMetrics(clientMetrics *ClientMetrics) (err error)
	// 添加关注电话
	//
	// Parameters:
	//  - PhoneNumber
	//  - SpaceId
	SubscribePhoneAlert(phoneNumber string, spaceId string) (err error)
	// 取消关注电话
	//
	// Parameters:
	//  - PhoneNumber
	//  - SpaceId
	UnsubscribePhoneAlert(phoneNumber string, spaceId string) (err error)
	// 添加关注邮箱
	//
	// Parameters:
	//  - Email
	//  - SpaceId
	SubscribeEmailAlert(email string, spaceId string) (err error)
	// 取消关注邮箱
	//
	// Parameters:
	//  - Email
	//  - SpaceId
	UnsubscribeEmailAlert(email string, spaceId string) (err error)
	// 查看所有关注电话
	//
	// Parameters:
	//  - SpaceId
	ListSubscribedPhone(spaceId string) (r []string, err error)
	// 查看所有关注邮箱地址
	//
	// Parameters:
	//  - SpaceId
	ListSubscribedEmail(spaceId string) (r []string, err error)
	// 获取表空间历史大小
	//
	// Parameters:
	//  - TableName
	//  - StartDate
	//  - StopDate
	GetTableHistorySize(tableName string, startDate int64, stopDate int64) (r map[int64]int64, err error)
	// 表重命名
	//
	// Parameters:
	//  - SrcName
	//  - DestName
	RenameTable(srcName string, destName string) (err error)
	// 查询表的所有snapshot
	//
	// Parameters:
	//  - TableName
	ListSnapshots(tableName string) (r *TableSnapshots, err error)
	// 生成表快照
	//
	// Parameters:
	//  - TableName
	//  - SnapshotName
	SnapshotTable(tableName string, snapshotName string) (err error)
	// 删除某个快照
	//
	// Parameters:
	//  - TableName
	//  - SnapshotName
	DeleteSnapshot(tableName string, snapshotName string) (err error)
	// 从快照恢复表
	//
	// Parameters:
	//  - TableName
	//  - SnapshotName
	//  - DestTableName
	//  - SnapshotType
	RestoreSnapshot(tableName string, snapshotName string, destTableName string, snapshotType table.SnapshotType) (err error)
	// 列出用户的所有表快照
	//
	// Parameters:
	//  - SpaceId
	ListAllSnapshots(spaceId string) (r []*SnapshotTableView, err error)
	// 取消生成快照
	//
	// Parameters:
	//  - TableName
	//  - SnapshotName
	CancelSnapshotTable(tableName string, snapshotName string) (err error)
	// 查询快照状态
	//
	// Parameters:
	//  - TableName
	//  - SnapshotName
	GetSnapshotState(tableName string, snapshotName string) (r table.SnapshotState, err error)
	// 查询用户各种quota的使用情况
	//
	// Parameters:
	//  - SpaceId
	GetQuotaInfo(spaceId string) (r *QuotaInfo, err error)
	// 查询developer帐号id
	GetDevelopId() (r string, err error)
	// 查询最近的stream checkpoint
	//
	// Parameters:
	//  - TableName
	//  - TopicName
	GetLatestStreamCheckpoint(tableName string, topicName string) (r *StreamCheckpoint, err error)
	// 查询小于等于timestamp的最大stream checkpoint
	//
	// Parameters:
	//  - TableName
	//  - TopicName
	//  - Timestamp
	GetFloorStreamCheckpoint(tableName string, topicName string, timestamp int64) (r *StreamCheckpoint, err error)
	// 查询大于等于timestamp的最小stream checkpoint
	//
	// Parameters:
	//  - TableName
	//  - TopicName
	//  - Timestamp
	GetCeilStreamCheckpoint(tableName string, topicName string, timestamp int64) (r *StreamCheckpoint, err error)
	// 恢复表到指定timestamp的状态，destTableName由系统根据最近快照创建，异步操作
	//
	// Parameters:
	//  - SrcTableName
	//  - DestTableName
	//  - TopicName
	//  - Timestamp
	RecoverTable(srcTableName string, destTableName string, topicName string, timestamp int64) (err error)
	// Parameters:
	//  - SpaceId
	ListAllDeletedTables(spaceId string) (r []*table.TableInfo, err error)
	// Parameters:
	//  - DeletedTableName
	//  - DestTableName
	RestoreTable(deletedTableName string, destTableName string) (err error)
	GetDefaultColdStandBy() (r *table.ColdStandBy, err error)
	// Parameters:
	//  - SpaceId
	GetGrantRule(spaceId string) (r *GrantRule, err error)
	// Parameters:
	//  - SpaceId
	//  - GrantRule
	SetGrantRule(spaceId string, grantRule *GrantRule) (err error)
	// Parameters:
	//  - TableName
	//  - SpaceId
	SetSpaceId(tableName string, spaceId string) (err error)
}

type AdminServiceClient 

type AdminServiceClient struct {
	*common.BaseServiceClient
}

结构化存储管理接口

func NewAdminServiceClientFactory 

func NewAdminServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AdminServiceClient

func NewAdminServiceClientProtocol 

func NewAdminServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AdminServiceClient

func (*AdminServiceClient) AlterTable 

func (p *AdminServiceClient) AlterTable(tableName string, tableSpec *table.TableSpec) (err error)

修改表

Parameters:

  • TableName
  • TableSpec

func (*AdminServiceClient) CancelSnapshotTable 

func (p *AdminServiceClient) CancelSnapshotTable(tableName string, snapshotName string) (err error)

取消生成快照

Parameters:

  • TableName
  • SnapshotName

func (*AdminServiceClient) CloneTable 

func (p *AdminServiceClient) CloneTable(srcTableName string, destTableName string, flushTable bool) (err error)

克隆表

Parameters:

  • SrcTableName
  • DestTableName
  • FlushTable

func (*AdminServiceClient) CreateTable 

func (p *AdminServiceClient) CreateTable(tableName string, tableSpec *table.TableSpec) (r *table.TableInfo, err error)

创建表

Parameters:

  • TableName
  • TableSpec

func (*AdminServiceClient) DeleteSnapshot 

func (p *AdminServiceClient) DeleteSnapshot(tableName string, snapshotName string) (err error)

删除某个快照

Parameters:

  • TableName
  • SnapshotName

func (*AdminServiceClient) DescribeTable 

func (p *AdminServiceClient) DescribeTable(tableName string) (r *table.TableSpec, err error)

获取表定义

Parameters:

  • TableName

func (*AdminServiceClient) DisableTable 

func (p *AdminServiceClient) DisableTable(tableName string) (err error)

关闭表读写操作

Parameters:

  • TableName

func (*AdminServiceClient) DropTable 

func (p *AdminServiceClient) DropTable(tableName string) (err error)

删除表

Parameters:

  • TableName

func (*AdminServiceClient) EnableTable 

func (p *AdminServiceClient) EnableTable(tableName string) (err error)

打开表读写操作

Parameters:

  • TableName

func (*AdminServiceClient) FindAllAppInfo 

func (p *AdminServiceClient) FindAllAppInfo() (r []*AppInfo, err error)

获取AppInfo列表,只包括appId和appName

func (*AdminServiceClient) FindAllApps 

func (p *AdminServiceClient) FindAllApps() (r []*AppInfo, err error)

查询指定用户所有应用信息

func (*AdminServiceClient) FindAllTables 

func (p *AdminServiceClient) FindAllTables() (r []*table.TableInfo, err error)

获取指定用户所有表信息

func (*AdminServiceClient) GetAppInfo 

func (p *AdminServiceClient) GetAppInfo(appId string) (r *AppInfo, err error)

查询应用信息

Parameters:

  • AppId

func (*AdminServiceClient) GetCeilStreamCheckpoint 

func (p *AdminServiceClient) GetCeilStreamCheckpoint(tableName string, topicName string, timestamp int64) (r *StreamCheckpoint, err error)

查询大于等于timestamp的最小stream checkpoint

Parameters:

  • TableName
  • TopicName
  • Timestamp

func (*AdminServiceClient) GetDefaultColdStandBy 

func (p *AdminServiceClient) GetDefaultColdStandBy() (r *table.ColdStandBy, err error)

func (*AdminServiceClient) GetDevelopId 

func (p *AdminServiceClient) GetDevelopId() (r string, err error)

查询developer帐号id

func (*AdminServiceClient) GetFloorStreamCheckpoint 

func (p *AdminServiceClient) GetFloorStreamCheckpoint(tableName string, topicName string, timestamp int64) (r *StreamCheckpoint, err error)

查询小于等于timestamp的最大stream checkpoint

Parameters:

  • TableName
  • TopicName
  • Timestamp

func (*AdminServiceClient) GetGrantRule 

func (p *AdminServiceClient) GetGrantRule(spaceId string) (r *GrantRule, err error)

Parameters:

  • SpaceId

func (*AdminServiceClient) GetIndexTableSplits 

func (p *AdminServiceClient) GetIndexTableSplits(tableName string, indexName string, startKey table.Dictionary, stopKey table.Dictionary) (r []*table.TableSplit, err error)

获取全局二级索引表的表分布信息，如用于MapReduce应用

Parameters:

  • TableName
  • IndexName
  • StartKey
  • StopKey

func (*AdminServiceClient) GetLatestStreamCheckpoint 

func (p *AdminServiceClient) GetLatestStreamCheckpoint(tableName string, topicName string) (r *StreamCheckpoint, err error)

查询最近的stream checkpoint

Parameters:

  • TableName
  • TopicName

func (*AdminServiceClient) GetQuotaInfo 

func (p *AdminServiceClient) GetQuotaInfo(spaceId string) (r *QuotaInfo, err error)

查询用户各种quota的使用情况

Parameters:

  • SpaceId

func (*AdminServiceClient) GetSnapshotState 

func (p *AdminServiceClient) GetSnapshotState(tableName string, snapshotName string) (r table.SnapshotState, err error)

查询快照状态

Parameters:

  • TableName
  • SnapshotName

func (*AdminServiceClient) GetTableHistorySize 

func (p *AdminServiceClient) GetTableHistorySize(tableName string, startDate int64, stopDate int64) (r map[int64]int64, err error)

获取表空间历史大小

Parameters:

  • TableName
  • StartDate
  • StopDate

func (*AdminServiceClient) GetTableSize 

func (p *AdminServiceClient) GetTableSize(tableName string) (r int64, err error)

获取表空间大小

Parameters:

  • TableName

func (*AdminServiceClient) GetTableSplits 

func (p *AdminServiceClient) GetTableSplits(tableName string, startKey table.Dictionary, stopKey table.Dictionary) (r []*table.TableSplit, err error)

获取表分布信息，如用于MapReduce应用

Parameters:

  • TableName
  • StartKey
  • StopKey

func (*AdminServiceClient) GetTableState 

func (p *AdminServiceClient) GetTableState(tableName string) (r table.TableState, err error)

获取表状态

Parameters:

  • TableName

func (*AdminServiceClient) GetTableStatus 

func (p *AdminServiceClient) GetTableStatus(tableName string) (r *table.TableStatus, err error)

获取表状态等元信息

Parameters:

  • TableName

func (*AdminServiceClient) ListAllDeletedTables 

func (p *AdminServiceClient) ListAllDeletedTables(spaceId string) (r []*table.TableInfo, err error)

Parameters:

  • SpaceId

func (*AdminServiceClient) ListAllSnapshots 

func (p *AdminServiceClient) ListAllSnapshots(spaceId string) (r []*SnapshotTableView, err error)

列出用户的所有表快照

Parameters:

  • SpaceId

func (*AdminServiceClient) ListSnapshots 

func (p *AdminServiceClient) ListSnapshots(tableName string) (r *TableSnapshots, err error)

查询表的所有snapshot

Parameters:

  • TableName

func (*AdminServiceClient) ListSubscribedEmail 

func (p *AdminServiceClient) ListSubscribedEmail(spaceId string) (r []string, err error)

查看所有关注邮箱地址

Parameters:

  • SpaceId

func (*AdminServiceClient) ListSubscribedPhone 

func (p *AdminServiceClient) ListSubscribedPhone(spaceId string) (r []string, err error)

查看所有关注电话

Parameters:

  • SpaceId

func (*AdminServiceClient) PutClientMetrics 

func (p *AdminServiceClient) PutClientMetrics(clientMetrics *ClientMetrics) (err error)

上传客户端metrics

Parameters:

  • ClientMetrics

func (*AdminServiceClient) QueryMetric 

func (p *AdminServiceClient) QueryMetric(query *MetricQueryRequest) (r *TimeSeriesData, err error)

查询表统计指标

Parameters:

  • Query

func (*AdminServiceClient) QueryMetrics 

func (p *AdminServiceClient) QueryMetrics(queries []*MetricQueryRequest) (r []*TimeSeriesData, err error)

批量查询表统计指标

Parameters:

  • Queries

func (*AdminServiceClient) RecoverTable 

func (p *AdminServiceClient) RecoverTable(srcTableName string, destTableName string, topicName string, timestamp int64) (err error)

恢复表到指定timestamp的状态，destTableName由系统根据最近快照创建，异步操作

Parameters:

  • SrcTableName
  • DestTableName
  • TopicName
  • Timestamp

func (*AdminServiceClient) RenameTable 

func (p *AdminServiceClient) RenameTable(srcName string, destName string) (err error)

表重命名

Parameters:

  • SrcName
  • DestName

func (*AdminServiceClient) RestoreSnapshot 

func (p *AdminServiceClient) RestoreSnapshot(tableName string, snapshotName string, destTableName string, snapshotType table.SnapshotType) (err error)

从快照恢复表

Parameters:

  • TableName
  • SnapshotName
  • DestTableName
  • SnapshotType

func (*AdminServiceClient) RestoreTable 

func (p *AdminServiceClient) RestoreTable(deletedTableName string, destTableName string) (err error)

Parameters:

  • DeletedTableName
  • DestTableName

func (*AdminServiceClient) SaveAppInfo 

func (p *AdminServiceClient) SaveAppInfo(appInfo *AppInfo) (err error)

保存应用信息，用于注册第三方应用OAuth信息

Parameters:

  • AppInfo

func (*AdminServiceClient) SetGrantRule 

func (p *AdminServiceClient) SetGrantRule(spaceId string, grantRule *GrantRule) (err error)

Parameters:

  • SpaceId
  • GrantRule

func (*AdminServiceClient) SetSpaceId 

func (p *AdminServiceClient) SetSpaceId(tableName string, spaceId string) (err error)

Parameters:

  • TableName
  • SpaceId

func (*AdminServiceClient) SnapshotTable 

func (p *AdminServiceClient) SnapshotTable(tableName string, snapshotName string) (err error)

生成表快照

Parameters:

  • TableName
  • SnapshotName

func (*AdminServiceClient) SubscribeEmailAlert 

func (p *AdminServiceClient) SubscribeEmailAlert(email string, spaceId string) (err error)

添加关注邮箱

Parameters:

  • Email
  • SpaceId

func (*AdminServiceClient) SubscribePhoneAlert 

func (p *AdminServiceClient) SubscribePhoneAlert(phoneNumber string, spaceId string) (err error)

添加关注电话

Parameters:

  • PhoneNumber
  • SpaceId

func (*AdminServiceClient) UnsubscribeEmailAlert 

func (p *AdminServiceClient) UnsubscribeEmailAlert(email string, spaceId string) (err error)

取消关注邮箱

Parameters:

  • Email
  • SpaceId

func (*AdminServiceClient) UnsubscribePhoneAlert 

func (p *AdminServiceClient) UnsubscribePhoneAlert(phoneNumber string, spaceId string) (err error)

取消关注电话

Parameters:

  • PhoneNumber
  • SpaceId

type AdminServiceProcessor 

type AdminServiceProcessor struct {
	*common.BaseServiceProcessor
}

func NewAdminServiceProcessor 

func NewAdminServiceProcessor(handler AdminService) *AdminServiceProcessor

type AlterTableArgs 

type AlterTableArgs struct {
	TableName string           `thrift:"tableName,1" json:"tableName"`
	TableSpec *table.TableSpec `thrift:"tableSpec,2" json:"tableSpec"`
}

func NewAlterTableArgs 

func NewAlterTableArgs() *AlterTableArgs

func (*AlterTableArgs) GetTableName 

func (p *AlterTableArgs) GetTableName() string

func (*AlterTableArgs) GetTableSpec 

func (p *AlterTableArgs) GetTableSpec() *table.TableSpec

func (*AlterTableArgs) IsSetTableSpec 

func (p *AlterTableArgs) IsSetTableSpec() bool

func (*AlterTableArgs) Read 

func (p *AlterTableArgs) Read(iprot thrift.TProtocol) error

func (*AlterTableArgs) ReadField1 

func (p *AlterTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*AlterTableArgs) ReadField2 

func (p *AlterTableArgs) ReadField2(iprot thrift.TProtocol) error

func (*AlterTableArgs) String 

func (p *AlterTableArgs) String() string

func (*AlterTableArgs) Write 

func (p *AlterTableArgs) Write(oprot thrift.TProtocol) error

type AlterTableResult 

type AlterTableResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewAlterTableResult 

func NewAlterTableResult() *AlterTableResult

func (*AlterTableResult) GetSe 

func (p *AlterTableResult) GetSe() *errors.ServiceException

func (*AlterTableResult) IsSetSe 

func (p *AlterTableResult) IsSetSe() bool

func (*AlterTableResult) Read 

func (p *AlterTableResult) Read(iprot thrift.TProtocol) error

func (*AlterTableResult) ReadField1 

func (p *AlterTableResult) ReadField1(iprot thrift.TProtocol) error

func (*AlterTableResult) String 

func (p *AlterTableResult) String() string

func (*AlterTableResult) Write 

func (p *AlterTableResult) Write(oprot thrift.TProtocol) error

type AppInfo 

type AppInfo struct {
	AppId           *string           `thrift:"appId,1" json:"appId"`
	DeveloperId     *string           `thrift:"developerId,2" json:"developerId"`
	TableMappings   map[string]string `thrift:"tableMappings,3" json:"tableMappings"`
	OauthAppMapping map[string]string `thrift:"oauthAppMapping,4" json:"oauthAppMapping"`
	AppName         *string           `thrift:"appName,5" json:"appName"`
}
var GetAppInfoResult_Success_DEFAULT *AppInfo
var SaveAppInfoArgs_AppInfo_DEFAULT *AppInfo

func NewAppInfo 

func NewAppInfo() *AppInfo

func (*AppInfo) GetAppId 

func (p *AppInfo) GetAppId() string

func (*AppInfo) GetAppName 

func (p *AppInfo) GetAppName() string

func (*AppInfo) GetDeveloperId 

func (p *AppInfo) GetDeveloperId() string

func (*AppInfo) GetOauthAppMapping 

func (p *AppInfo) GetOauthAppMapping() map[string]string

func (*AppInfo) GetTableMappings 

func (p *AppInfo) GetTableMappings() map[string]string

func (*AppInfo) IsSetAppId 

func (p *AppInfo) IsSetAppId() bool

func (*AppInfo) IsSetAppName 

func (p *AppInfo) IsSetAppName() bool

func (*AppInfo) IsSetDeveloperId 

func (p *AppInfo) IsSetDeveloperId() bool

func (*AppInfo) IsSetOauthAppMapping 

func (p *AppInfo) IsSetOauthAppMapping() bool

func (*AppInfo) IsSetTableMappings 

func (p *AppInfo) IsSetTableMappings() bool

func (*AppInfo) Read 

func (p *AppInfo) Read(iprot thrift.TProtocol) error

func (*AppInfo) ReadField1 

func (p *AppInfo) ReadField1(iprot thrift.TProtocol) error

func (*AppInfo) ReadField2 

func (p *AppInfo) ReadField2(iprot thrift.TProtocol) error

func (*AppInfo) ReadField3 

func (p *AppInfo) ReadField3(iprot thrift.TProtocol) error

func (*AppInfo) ReadField4 

func (p *AppInfo) ReadField4(iprot thrift.TProtocol) error

func (*AppInfo) ReadField5 

func (p *AppInfo) ReadField5(iprot thrift.TProtocol) error

func (*AppInfo) String 

func (p *AppInfo) String() string

func (*AppInfo) Write 

func (p *AppInfo) Write(oprot thrift.TProtocol) error

type CancelSnapshotTableArgs 

type CancelSnapshotTableArgs struct {
	TableName    string `thrift:"tableName,1" json:"tableName"`
	SnapshotName string `thrift:"snapshotName,2" json:"snapshotName"`
}

func NewCancelSnapshotTableArgs 

func NewCancelSnapshotTableArgs() *CancelSnapshotTableArgs

func (*CancelSnapshotTableArgs) GetSnapshotName 

func (p *CancelSnapshotTableArgs) GetSnapshotName() string

func (*CancelSnapshotTableArgs) GetTableName 

func (p *CancelSnapshotTableArgs) GetTableName() string

func (*CancelSnapshotTableArgs) Read 

func (p *CancelSnapshotTableArgs) Read(iprot thrift.TProtocol) error

func (*CancelSnapshotTableArgs) ReadField1 

func (p *CancelSnapshotTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*CancelSnapshotTableArgs) ReadField2 

func (p *CancelSnapshotTableArgs) ReadField2(iprot thrift.TProtocol) error

func (*CancelSnapshotTableArgs) String 

func (p *CancelSnapshotTableArgs) String() string

func (*CancelSnapshotTableArgs) Write 

func (p *CancelSnapshotTableArgs) Write(oprot thrift.TProtocol) error

type CancelSnapshotTableResult 

type CancelSnapshotTableResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewCancelSnapshotTableResult 

func NewCancelSnapshotTableResult() *CancelSnapshotTableResult

func (*CancelSnapshotTableResult) GetSe 

func (p *CancelSnapshotTableResult) GetSe() *errors.ServiceException

func (*CancelSnapshotTableResult) IsSetSe 

func (p *CancelSnapshotTableResult) IsSetSe() bool

func (*CancelSnapshotTableResult) Read 

func (p *CancelSnapshotTableResult) Read(iprot thrift.TProtocol) error

func (*CancelSnapshotTableResult) ReadField1 

func (p *CancelSnapshotTableResult) ReadField1(iprot thrift.TProtocol) error

func (*CancelSnapshotTableResult) String 

func (p *CancelSnapshotTableResult) String() string

func (*CancelSnapshotTableResult) Write 

func (p *CancelSnapshotTableResult) Write(oprot thrift.TProtocol) error

type ClientMetricType 

type ClientMetricType int64

客户端metrics的类型 

const (
	ClientMetricType_Letency ClientMetricType = 1
)
var MetricData_ClientMetricType_DEFAULT ClientMetricType

func ClientMetricTypeFromString 

func ClientMetricTypeFromString(s string) (ClientMetricType, error)

func ClientMetricTypePtr 

func ClientMetricTypePtr(v ClientMetricType) *ClientMetricType

func (ClientMetricType) String 

func (p ClientMetricType) String() string

type ClientMetrics 

type ClientMetrics struct {
	MetricDataList []*MetricData `thrift:"metricDataList,1" json:"metricDataList"`
}
var PutClientMetricsArgs_ClientMetrics_DEFAULT *ClientMetrics

func NewClientMetrics 

func NewClientMetrics() *ClientMetrics

func (*ClientMetrics) GetMetricDataList 

func (p *ClientMetrics) GetMetricDataList() []*MetricData

func (*ClientMetrics) IsSetMetricDataList 

func (p *ClientMetrics) IsSetMetricDataList() bool

func (*ClientMetrics) Read 

func (p *ClientMetrics) Read(iprot thrift.TProtocol) error

func (*ClientMetrics) ReadField1 

func (p *ClientMetrics) ReadField1(iprot thrift.TProtocol) error

func (*ClientMetrics) String 

func (p *ClientMetrics) String() string

func (*ClientMetrics) Write 

func (p *ClientMetrics) Write(oprot thrift.TProtocol) error

type CloneTableArgs 

type CloneTableArgs struct {
	SrcTableName  string `thrift:"srcTableName,1" json:"srcTableName"`
	DestTableName string `thrift:"destTableName,2" json:"destTableName"`
	FlushTable    bool   `thrift:"flushTable,3" json:"flushTable"`
}

func NewCloneTableArgs 

func NewCloneTableArgs() *CloneTableArgs

func (*CloneTableArgs) GetDestTableName 

func (p *CloneTableArgs) GetDestTableName() string

func (*CloneTableArgs) GetFlushTable 

func (p *CloneTableArgs) GetFlushTable() bool

func (*CloneTableArgs) GetSrcTableName 

func (p *CloneTableArgs) GetSrcTableName() string

func (*CloneTableArgs) Read 

func (p *CloneTableArgs) Read(iprot thrift.TProtocol) error

func (*CloneTableArgs) ReadField1 

func (p *CloneTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*CloneTableArgs) ReadField2 

func (p *CloneTableArgs) ReadField2(iprot thrift.TProtocol) error

func (*CloneTableArgs) ReadField3 

func (p *CloneTableArgs) ReadField3(iprot thrift.TProtocol) error

func (*CloneTableArgs) String 

func (p *CloneTableArgs) String() string

func (*CloneTableArgs) Write 

func (p *CloneTableArgs) Write(oprot thrift.TProtocol) error

type CloneTableResult 

type CloneTableResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewCloneTableResult 

func NewCloneTableResult() *CloneTableResult

func (*CloneTableResult) GetSe 

func (p *CloneTableResult) GetSe() *errors.ServiceException

func (*CloneTableResult) IsSetSe 

func (p *CloneTableResult) IsSetSe() bool

func (*CloneTableResult) Read 

func (p *CloneTableResult) Read(iprot thrift.TProtocol) error

func (*CloneTableResult) ReadField1 

func (p *CloneTableResult) ReadField1(iprot thrift.TProtocol) error

func (*CloneTableResult) String 

func (p *CloneTableResult) String() string

func (*CloneTableResult) Write 

func (p *CloneTableResult) Write(oprot thrift.TProtocol) error

type CreateTableArgs 

type CreateTableArgs struct {
	TableName string           `thrift:"tableName,1" json:"tableName"`
	TableSpec *table.TableSpec `thrift:"tableSpec,2" json:"tableSpec"`
}

func NewCreateTableArgs 

func NewCreateTableArgs() *CreateTableArgs

func (*CreateTableArgs) GetTableName 

func (p *CreateTableArgs) GetTableName() string

func (*CreateTableArgs) GetTableSpec 

func (p *CreateTableArgs) GetTableSpec() *table.TableSpec

func (*CreateTableArgs) IsSetTableSpec 

func (p *CreateTableArgs) IsSetTableSpec() bool

func (*CreateTableArgs) Read 

func (p *CreateTableArgs) Read(iprot thrift.TProtocol) error

func (*CreateTableArgs) ReadField1 

func (p *CreateTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*CreateTableArgs) ReadField2 

func (p *CreateTableArgs) ReadField2(iprot thrift.TProtocol) error

func (*CreateTableArgs) String 

func (p *CreateTableArgs) String() string

func (*CreateTableArgs) Write 

func (p *CreateTableArgs) Write(oprot thrift.TProtocol) error

type CreateTableResult 

type CreateTableResult struct {
	Success *table.TableInfo         `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewCreateTableResult 

func NewCreateTableResult() *CreateTableResult

func (*CreateTableResult) GetSe 

func (p *CreateTableResult) GetSe() *errors.ServiceException

func (*CreateTableResult) GetSuccess 

func (p *CreateTableResult) GetSuccess() *table.TableInfo

func (*CreateTableResult) IsSetSe 

func (p *CreateTableResult) IsSetSe() bool

func (*CreateTableResult) IsSetSuccess 

func (p *CreateTableResult) IsSetSuccess() bool

func (*CreateTableResult) Read 

func (p *CreateTableResult) Read(iprot thrift.TProtocol) error

func (*CreateTableResult) ReadField0 

func (p *CreateTableResult) ReadField0(iprot thrift.TProtocol) error

func (*CreateTableResult) ReadField1 

func (p *CreateTableResult) ReadField1(iprot thrift.TProtocol) error

func (*CreateTableResult) String 

func (p *CreateTableResult) String() string

func (*CreateTableResult) Write 

func (p *CreateTableResult) Write(oprot thrift.TProtocol) error

type DeleteSnapshotArgs 

type DeleteSnapshotArgs struct {
	TableName    string `thrift:"tableName,1" json:"tableName"`
	SnapshotName string `thrift:"snapshotName,2" json:"snapshotName"`
}

func NewDeleteSnapshotArgs 

func NewDeleteSnapshotArgs() *DeleteSnapshotArgs

func (*DeleteSnapshotArgs) GetSnapshotName 

func (p *DeleteSnapshotArgs) GetSnapshotName() string

func (*DeleteSnapshotArgs) GetTableName 

func (p *DeleteSnapshotArgs) GetTableName() string

func (*DeleteSnapshotArgs) Read 

func (p *DeleteSnapshotArgs) Read(iprot thrift.TProtocol) error

func (*DeleteSnapshotArgs) ReadField1 

func (p *DeleteSnapshotArgs) ReadField1(iprot thrift.TProtocol) error

func (*DeleteSnapshotArgs) ReadField2 

func (p *DeleteSnapshotArgs) ReadField2(iprot thrift.TProtocol) error

func (*DeleteSnapshotArgs) String 

func (p *DeleteSnapshotArgs) String() string

func (*DeleteSnapshotArgs) Write 

func (p *DeleteSnapshotArgs) Write(oprot thrift.TProtocol) error

type DeleteSnapshotResult 

type DeleteSnapshotResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewDeleteSnapshotResult 

func NewDeleteSnapshotResult() *DeleteSnapshotResult

func (*DeleteSnapshotResult) GetSe 

func (p *DeleteSnapshotResult) GetSe() *errors.ServiceException

func (*DeleteSnapshotResult) IsSetSe 

func (p *DeleteSnapshotResult) IsSetSe() bool

func (*DeleteSnapshotResult) Read 

func (p *DeleteSnapshotResult) Read(iprot thrift.TProtocol) error

func (*DeleteSnapshotResult) ReadField1 

func (p *DeleteSnapshotResult) ReadField1(iprot thrift.TProtocol) error

func (*DeleteSnapshotResult) String 

func (p *DeleteSnapshotResult) String() string

func (*DeleteSnapshotResult) Write 

func (p *DeleteSnapshotResult) Write(oprot thrift.TProtocol) error

type DescribeTableArgs 

type DescribeTableArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
}

func NewDescribeTableArgs 

func NewDescribeTableArgs() *DescribeTableArgs

func (*DescribeTableArgs) GetTableName 

func (p *DescribeTableArgs) GetTableName() string

func (*DescribeTableArgs) Read 

func (p *DescribeTableArgs) Read(iprot thrift.TProtocol) error

func (*DescribeTableArgs) ReadField1 

func (p *DescribeTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*DescribeTableArgs) String 

func (p *DescribeTableArgs) String() string

func (*DescribeTableArgs) Write 

func (p *DescribeTableArgs) Write(oprot thrift.TProtocol) error

type DescribeTableResult 

type DescribeTableResult struct {
	Success *table.TableSpec         `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewDescribeTableResult 

func NewDescribeTableResult() *DescribeTableResult

func (*DescribeTableResult) GetSe 

func (p *DescribeTableResult) GetSe() *errors.ServiceException

func (*DescribeTableResult) GetSuccess 

func (p *DescribeTableResult) GetSuccess() *table.TableSpec

func (*DescribeTableResult) IsSetSe 

func (p *DescribeTableResult) IsSetSe() bool

func (*DescribeTableResult) IsSetSuccess 

func (p *DescribeTableResult) IsSetSuccess() bool

func (*DescribeTableResult) Read 

func (p *DescribeTableResult) Read(iprot thrift.TProtocol) error

func (*DescribeTableResult) ReadField0 

func (p *DescribeTableResult) ReadField0(iprot thrift.TProtocol) error

func (*DescribeTableResult) ReadField1 

func (p *DescribeTableResult) ReadField1(iprot thrift.TProtocol) error

func (*DescribeTableResult) String 

func (p *DescribeTableResult) String() string

func (*DescribeTableResult) Write 

func (p *DescribeTableResult) Write(oprot thrift.TProtocol) error

type DisableTableArgs 

type DisableTableArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
}

func NewDisableTableArgs 

func NewDisableTableArgs() *DisableTableArgs

func (*DisableTableArgs) GetTableName 

func (p *DisableTableArgs) GetTableName() string

func (*DisableTableArgs) Read 

func (p *DisableTableArgs) Read(iprot thrift.TProtocol) error

func (*DisableTableArgs) ReadField1 

func (p *DisableTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*DisableTableArgs) String 

func (p *DisableTableArgs) String() string

func (*DisableTableArgs) Write 

func (p *DisableTableArgs) Write(oprot thrift.TProtocol) error

type DisableTableResult 

type DisableTableResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewDisableTableResult 

func NewDisableTableResult() *DisableTableResult

func (*DisableTableResult) GetSe 

func (p *DisableTableResult) GetSe() *errors.ServiceException

func (*DisableTableResult) IsSetSe 

func (p *DisableTableResult) IsSetSe() bool

func (*DisableTableResult) Read 

func (p *DisableTableResult) Read(iprot thrift.TProtocol) error

func (*DisableTableResult) ReadField1 

func (p *DisableTableResult) ReadField1(iprot thrift.TProtocol) error

func (*DisableTableResult) String 

func (p *DisableTableResult) String() string

func (*DisableTableResult) Write 

func (p *DisableTableResult) Write(oprot thrift.TProtocol) error

type DropTableArgs 

type DropTableArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
}

func NewDropTableArgs 

func NewDropTableArgs() *DropTableArgs

func (*DropTableArgs) GetTableName 

func (p *DropTableArgs) GetTableName() string

func (*DropTableArgs) Read 

func (p *DropTableArgs) Read(iprot thrift.TProtocol) error

func (*DropTableArgs) ReadField1 

func (p *DropTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*DropTableArgs) String 

func (p *DropTableArgs) String() string

func (*DropTableArgs) Write 

func (p *DropTableArgs) Write(oprot thrift.TProtocol) error

type DropTableResult 

type DropTableResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewDropTableResult 

func NewDropTableResult() *DropTableResult

func (*DropTableResult) GetSe 

func (p *DropTableResult) GetSe() *errors.ServiceException

func (*DropTableResult) IsSetSe 

func (p *DropTableResult) IsSetSe() bool

func (*DropTableResult) Read 

func (p *DropTableResult) Read(iprot thrift.TProtocol) error

func (*DropTableResult) ReadField1 

func (p *DropTableResult) ReadField1(iprot thrift.TProtocol) error

func (*DropTableResult) String 

func (p *DropTableResult) String() string

func (*DropTableResult) Write 

func (p *DropTableResult) Write(oprot thrift.TProtocol) error

type EnableTableArgs 

type EnableTableArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
}

func NewEnableTableArgs 

func NewEnableTableArgs() *EnableTableArgs

func (*EnableTableArgs) GetTableName 

func (p *EnableTableArgs) GetTableName() string

func (*EnableTableArgs) Read 

func (p *EnableTableArgs) Read(iprot thrift.TProtocol) error

func (*EnableTableArgs) ReadField1 

func (p *EnableTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*EnableTableArgs) String 

func (p *EnableTableArgs) String() string

func (*EnableTableArgs) Write 

func (p *EnableTableArgs) Write(oprot thrift.TProtocol) error

type EnableTableResult 

type EnableTableResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewEnableTableResult 

func NewEnableTableResult() *EnableTableResult

func (*EnableTableResult) GetSe 

func (p *EnableTableResult) GetSe() *errors.ServiceException

func (*EnableTableResult) IsSetSe 

func (p *EnableTableResult) IsSetSe() bool

func (*EnableTableResult) Read 

func (p *EnableTableResult) Read(iprot thrift.TProtocol) error

func (*EnableTableResult) ReadField1 

func (p *EnableTableResult) ReadField1(iprot thrift.TProtocol) error

func (*EnableTableResult) String 

func (p *EnableTableResult) String() string

func (*EnableTableResult) Write 

func (p *EnableTableResult) Write(oprot thrift.TProtocol) error

type FindAllAppInfoArgs 

type FindAllAppInfoArgs struct {
}

func NewFindAllAppInfoArgs 

func NewFindAllAppInfoArgs() *FindAllAppInfoArgs

func (*FindAllAppInfoArgs) Read 

func (p *FindAllAppInfoArgs) Read(iprot thrift.TProtocol) error

func (*FindAllAppInfoArgs) String 

func (p *FindAllAppInfoArgs) String() string

func (*FindAllAppInfoArgs) Write 

func (p *FindAllAppInfoArgs) Write(oprot thrift.TProtocol) error

type FindAllAppInfoResult 

type FindAllAppInfoResult struct {
	Success []*AppInfo               `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewFindAllAppInfoResult 

func NewFindAllAppInfoResult() *FindAllAppInfoResult

func (*FindAllAppInfoResult) GetSe 

func (p *FindAllAppInfoResult) GetSe() *errors.ServiceException

func (*FindAllAppInfoResult) GetSuccess 

func (p *FindAllAppInfoResult) GetSuccess() []*AppInfo

func (*FindAllAppInfoResult) IsSetSe 

func (p *FindAllAppInfoResult) IsSetSe() bool

func (*FindAllAppInfoResult) IsSetSuccess 

func (p *FindAllAppInfoResult) IsSetSuccess() bool

func (*FindAllAppInfoResult) Read 

func (p *FindAllAppInfoResult) Read(iprot thrift.TProtocol) error

func (*FindAllAppInfoResult) ReadField0 

func (p *FindAllAppInfoResult) ReadField0(iprot thrift.TProtocol) error

func (*FindAllAppInfoResult) ReadField1 

func (p *FindAllAppInfoResult) ReadField1(iprot thrift.TProtocol) error

func (*FindAllAppInfoResult) String 

func (p *FindAllAppInfoResult) String() string

func (*FindAllAppInfoResult) Write 

func (p *FindAllAppInfoResult) Write(oprot thrift.TProtocol) error

type FindAllAppsArgs 

type FindAllAppsArgs struct {
}

func NewFindAllAppsArgs 

func NewFindAllAppsArgs() *FindAllAppsArgs

func (*FindAllAppsArgs) Read 

func (p *FindAllAppsArgs) Read(iprot thrift.TProtocol) error

func (*FindAllAppsArgs) String 

func (p *FindAllAppsArgs) String() string

func (*FindAllAppsArgs) Write 

func (p *FindAllAppsArgs) Write(oprot thrift.TProtocol) error

type FindAllAppsResult 

type FindAllAppsResult struct {
	Success []*AppInfo               `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewFindAllAppsResult 

func NewFindAllAppsResult() *FindAllAppsResult

func (*FindAllAppsResult) GetSe 

func (p *FindAllAppsResult) GetSe() *errors.ServiceException

func (*FindAllAppsResult) GetSuccess 

func (p *FindAllAppsResult) GetSuccess() []*AppInfo

func (*FindAllAppsResult) IsSetSe 

func (p *FindAllAppsResult) IsSetSe() bool

func (*FindAllAppsResult) IsSetSuccess 

func (p *FindAllAppsResult) IsSetSuccess() bool

func (*FindAllAppsResult) Read 

func (p *FindAllAppsResult) Read(iprot thrift.TProtocol) error

func (*FindAllAppsResult) ReadField0 

func (p *FindAllAppsResult) ReadField0(iprot thrift.TProtocol) error

func (*FindAllAppsResult) ReadField1 

func (p *FindAllAppsResult) ReadField1(iprot thrift.TProtocol) error

func (*FindAllAppsResult) String 

func (p *FindAllAppsResult) String() string

func (*FindAllAppsResult) Write 

func (p *FindAllAppsResult) Write(oprot thrift.TProtocol) error

type FindAllTablesArgs 

type FindAllTablesArgs struct {
}

func NewFindAllTablesArgs 

func NewFindAllTablesArgs() *FindAllTablesArgs

func (*FindAllTablesArgs) Read 

func (p *FindAllTablesArgs) Read(iprot thrift.TProtocol) error

func (*FindAllTablesArgs) String 

func (p *FindAllTablesArgs) String() string

func (*FindAllTablesArgs) Write 

func (p *FindAllTablesArgs) Write(oprot thrift.TProtocol) error

type FindAllTablesResult 

type FindAllTablesResult struct {
	Success []*table.TableInfo       `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewFindAllTablesResult 

func NewFindAllTablesResult() *FindAllTablesResult

func (*FindAllTablesResult) GetSe 

func (p *FindAllTablesResult) GetSe() *errors.ServiceException

func (*FindAllTablesResult) GetSuccess 

func (p *FindAllTablesResult) GetSuccess() []*table.TableInfo

func (*FindAllTablesResult) IsSetSe 

func (p *FindAllTablesResult) IsSetSe() bool

func (*FindAllTablesResult) IsSetSuccess 

func (p *FindAllTablesResult) IsSetSuccess() bool

func (*FindAllTablesResult) Read 

func (p *FindAllTablesResult) Read(iprot thrift.TProtocol) error

func (*FindAllTablesResult) ReadField0 

func (p *FindAllTablesResult) ReadField0(iprot thrift.TProtocol) error

func (*FindAllTablesResult) ReadField1 

func (p *FindAllTablesResult) ReadField1(iprot thrift.TProtocol) error

func (*FindAllTablesResult) String 

func (p *FindAllTablesResult) String() string

func (*FindAllTablesResult) Write 

func (p *FindAllTablesResult) Write(oprot thrift.TProtocol) error

type GetAppInfoArgs 

type GetAppInfoArgs struct {
	AppId string `thrift:"appId,1" json:"appId"`
}

func NewGetAppInfoArgs 

func NewGetAppInfoArgs() *GetAppInfoArgs

func (*GetAppInfoArgs) GetAppId 

func (p *GetAppInfoArgs) GetAppId() string

func (*GetAppInfoArgs) Read 

func (p *GetAppInfoArgs) Read(iprot thrift.TProtocol) error

func (*GetAppInfoArgs) ReadField1 

func (p *GetAppInfoArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetAppInfoArgs) String 

func (p *GetAppInfoArgs) String() string

func (*GetAppInfoArgs) Write 

func (p *GetAppInfoArgs) Write(oprot thrift.TProtocol) error

type GetAppInfoResult 

type GetAppInfoResult struct {
	Success *AppInfo                 `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetAppInfoResult 

func NewGetAppInfoResult() *GetAppInfoResult

func (*GetAppInfoResult) GetSe 

func (p *GetAppInfoResult) GetSe() *errors.ServiceException

func (*GetAppInfoResult) GetSuccess 

func (p *GetAppInfoResult) GetSuccess() *AppInfo

func (*GetAppInfoResult) IsSetSe 

func (p *GetAppInfoResult) IsSetSe() bool

func (*GetAppInfoResult) IsSetSuccess 

func (p *GetAppInfoResult) IsSetSuccess() bool

func (*GetAppInfoResult) Read 

func (p *GetAppInfoResult) Read(iprot thrift.TProtocol) error

func (*GetAppInfoResult) ReadField0 

func (p *GetAppInfoResult) ReadField0(iprot thrift.TProtocol) error

func (*GetAppInfoResult) ReadField1 

func (p *GetAppInfoResult) ReadField1(iprot thrift.TProtocol) error

func (*GetAppInfoResult) String 

func (p *GetAppInfoResult) String() string

func (*GetAppInfoResult) Write 

func (p *GetAppInfoResult) Write(oprot thrift.TProtocol) error

type GetCeilStreamCheckpointArgs 

type GetCeilStreamCheckpointArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
	TopicName string `thrift:"topicName,2" json:"topicName"`
	Timestamp int64  `thrift:"timestamp,3" json:"timestamp"`
}

func NewGetCeilStreamCheckpointArgs 

func NewGetCeilStreamCheckpointArgs() *GetCeilStreamCheckpointArgs

func (*GetCeilStreamCheckpointArgs) GetTableName 

func (p *GetCeilStreamCheckpointArgs) GetTableName() string

func (*GetCeilStreamCheckpointArgs) GetTimestamp 

func (p *GetCeilStreamCheckpointArgs) GetTimestamp() int64

func (*GetCeilStreamCheckpointArgs) GetTopicName 

func (p *GetCeilStreamCheckpointArgs) GetTopicName() string

func (*GetCeilStreamCheckpointArgs) Read 

func (p *GetCeilStreamCheckpointArgs) Read(iprot thrift.TProtocol) error

func (*GetCeilStreamCheckpointArgs) ReadField1 

func (p *GetCeilStreamCheckpointArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetCeilStreamCheckpointArgs) ReadField2 

func (p *GetCeilStreamCheckpointArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetCeilStreamCheckpointArgs) ReadField3 

func (p *GetCeilStreamCheckpointArgs) ReadField3(iprot thrift.TProtocol) error

func (*GetCeilStreamCheckpointArgs) String 

func (p *GetCeilStreamCheckpointArgs) String() string

func (*GetCeilStreamCheckpointArgs) Write 

func (p *GetCeilStreamCheckpointArgs) Write(oprot thrift.TProtocol) error

type GetCeilStreamCheckpointResult 

type GetCeilStreamCheckpointResult struct {
	Success *StreamCheckpoint        `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetCeilStreamCheckpointResult 

func NewGetCeilStreamCheckpointResult() *GetCeilStreamCheckpointResult

func (*GetCeilStreamCheckpointResult) GetSe 

func (p *GetCeilStreamCheckpointResult) GetSe() *errors.ServiceException

func (*GetCeilStreamCheckpointResult) GetSuccess 

func (p *GetCeilStreamCheckpointResult) GetSuccess() *StreamCheckpoint

func (*GetCeilStreamCheckpointResult) IsSetSe 

func (p *GetCeilStreamCheckpointResult) IsSetSe() bool

func (*GetCeilStreamCheckpointResult) IsSetSuccess 

func (p *GetCeilStreamCheckpointResult) IsSetSuccess() bool

func (*GetCeilStreamCheckpointResult) Read 

func (p *GetCeilStreamCheckpointResult) Read(iprot thrift.TProtocol) error

func (*GetCeilStreamCheckpointResult) ReadField0 

func (p *GetCeilStreamCheckpointResult) ReadField0(iprot thrift.TProtocol) error

func (*GetCeilStreamCheckpointResult) ReadField1 

func (p *GetCeilStreamCheckpointResult) ReadField1(iprot thrift.TProtocol) error

func (*GetCeilStreamCheckpointResult) String 

func (p *GetCeilStreamCheckpointResult) String() string

func (*GetCeilStreamCheckpointResult) Write 

func (p *GetCeilStreamCheckpointResult) Write(oprot thrift.TProtocol) error

type GetDefaultColdStandByArgs 

type GetDefaultColdStandByArgs struct {
}

func NewGetDefaultColdStandByArgs 

func NewGetDefaultColdStandByArgs() *GetDefaultColdStandByArgs

func (*GetDefaultColdStandByArgs) Read 

func (p *GetDefaultColdStandByArgs) Read(iprot thrift.TProtocol) error

func (*GetDefaultColdStandByArgs) String 

func (p *GetDefaultColdStandByArgs) String() string

func (*GetDefaultColdStandByArgs) Write 

func (p *GetDefaultColdStandByArgs) Write(oprot thrift.TProtocol) error

type GetDefaultColdStandByResult 

type GetDefaultColdStandByResult struct {
	Success *table.ColdStandBy       `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetDefaultColdStandByResult 

func NewGetDefaultColdStandByResult() *GetDefaultColdStandByResult

func (*GetDefaultColdStandByResult) GetSe 

func (p *GetDefaultColdStandByResult) GetSe() *errors.ServiceException

func (*GetDefaultColdStandByResult) GetSuccess 

func (p *GetDefaultColdStandByResult) GetSuccess() *table.ColdStandBy

func (*GetDefaultColdStandByResult) IsSetSe 

func (p *GetDefaultColdStandByResult) IsSetSe() bool

func (*GetDefaultColdStandByResult) IsSetSuccess 

func (p *GetDefaultColdStandByResult) IsSetSuccess() bool

func (*GetDefaultColdStandByResult) Read 

func (p *GetDefaultColdStandByResult) Read(iprot thrift.TProtocol) error

func (*GetDefaultColdStandByResult) ReadField0 

func (p *GetDefaultColdStandByResult) ReadField0(iprot thrift.TProtocol) error

func (*GetDefaultColdStandByResult) ReadField1 

func (p *GetDefaultColdStandByResult) ReadField1(iprot thrift.TProtocol) error

func (*GetDefaultColdStandByResult) String 

func (p *GetDefaultColdStandByResult) String() string

func (*GetDefaultColdStandByResult) Write 

func (p *GetDefaultColdStandByResult) Write(oprot thrift.TProtocol) error

type GetDevelopIdArgs 

type GetDevelopIdArgs struct {
}

func NewGetDevelopIdArgs 

func NewGetDevelopIdArgs() *GetDevelopIdArgs

func (*GetDevelopIdArgs) Read 

func (p *GetDevelopIdArgs) Read(iprot thrift.TProtocol) error

func (*GetDevelopIdArgs) String 

func (p *GetDevelopIdArgs) String() string

func (*GetDevelopIdArgs) Write 

func (p *GetDevelopIdArgs) Write(oprot thrift.TProtocol) error

type GetDevelopIdResult 

type GetDevelopIdResult struct {
	Success *string                  `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetDevelopIdResult 

func NewGetDevelopIdResult() *GetDevelopIdResult

func (*GetDevelopIdResult) GetSe 

func (p *GetDevelopIdResult) GetSe() *errors.ServiceException

func (*GetDevelopIdResult) GetSuccess 

func (p *GetDevelopIdResult) GetSuccess() string

func (*GetDevelopIdResult) IsSetSe 

func (p *GetDevelopIdResult) IsSetSe() bool

func (*GetDevelopIdResult) IsSetSuccess 

func (p *GetDevelopIdResult) IsSetSuccess() bool

func (*GetDevelopIdResult) Read 

func (p *GetDevelopIdResult) Read(iprot thrift.TProtocol) error

func (*GetDevelopIdResult) ReadField0 

func (p *GetDevelopIdResult) ReadField0(iprot thrift.TProtocol) error

func (*GetDevelopIdResult) ReadField1 

func (p *GetDevelopIdResult) ReadField1(iprot thrift.TProtocol) error

func (*GetDevelopIdResult) String 

func (p *GetDevelopIdResult) String() string

func (*GetDevelopIdResult) Write 

func (p *GetDevelopIdResult) Write(oprot thrift.TProtocol) error

type GetFloorStreamCheckpointArgs 

type GetFloorStreamCheckpointArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
	TopicName string `thrift:"topicName,2" json:"topicName"`
	Timestamp int64  `thrift:"timestamp,3" json:"timestamp"`
}

func NewGetFloorStreamCheckpointArgs 

func NewGetFloorStreamCheckpointArgs() *GetFloorStreamCheckpointArgs

func (*GetFloorStreamCheckpointArgs) GetTableName 

func (p *GetFloorStreamCheckpointArgs) GetTableName() string

func (*GetFloorStreamCheckpointArgs) GetTimestamp 

func (p *GetFloorStreamCheckpointArgs) GetTimestamp() int64

func (*GetFloorStreamCheckpointArgs) GetTopicName 

func (p *GetFloorStreamCheckpointArgs) GetTopicName() string

func (*GetFloorStreamCheckpointArgs) Read 

func (p *GetFloorStreamCheckpointArgs) Read(iprot thrift.TProtocol) error

func (*GetFloorStreamCheckpointArgs) ReadField1 

func (p *GetFloorStreamCheckpointArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetFloorStreamCheckpointArgs) ReadField2 

func (p *GetFloorStreamCheckpointArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetFloorStreamCheckpointArgs) ReadField3 

func (p *GetFloorStreamCheckpointArgs) ReadField3(iprot thrift.TProtocol) error

func (*GetFloorStreamCheckpointArgs) String 

func (p *GetFloorStreamCheckpointArgs) String() string

func (*GetFloorStreamCheckpointArgs) Write 

func (p *GetFloorStreamCheckpointArgs) Write(oprot thrift.TProtocol) error

type GetFloorStreamCheckpointResult 

type GetFloorStreamCheckpointResult struct {
	Success *StreamCheckpoint        `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetFloorStreamCheckpointResult 

func NewGetFloorStreamCheckpointResult() *GetFloorStreamCheckpointResult

func (*GetFloorStreamCheckpointResult) GetSe 

func (p *GetFloorStreamCheckpointResult) GetSe() *errors.ServiceException

func (*GetFloorStreamCheckpointResult) GetSuccess 

func (p *GetFloorStreamCheckpointResult) GetSuccess() *StreamCheckpoint

func (*GetFloorStreamCheckpointResult) IsSetSe 

func (p *GetFloorStreamCheckpointResult) IsSetSe() bool

func (*GetFloorStreamCheckpointResult) IsSetSuccess 

func (p *GetFloorStreamCheckpointResult) IsSetSuccess() bool

func (*GetFloorStreamCheckpointResult) Read 

func (p *GetFloorStreamCheckpointResult) Read(iprot thrift.TProtocol) error

func (*GetFloorStreamCheckpointResult) ReadField0 

func (p *GetFloorStreamCheckpointResult) ReadField0(iprot thrift.TProtocol) error

func (*GetFloorStreamCheckpointResult) ReadField1 

func (p *GetFloorStreamCheckpointResult) ReadField1(iprot thrift.TProtocol) error

func (*GetFloorStreamCheckpointResult) String 

func (p *GetFloorStreamCheckpointResult) String() string

func (*GetFloorStreamCheckpointResult) Write 

func (p *GetFloorStreamCheckpointResult) Write(oprot thrift.TProtocol) error

type GetGrantRuleArgs 

type GetGrantRuleArgs struct {
	SpaceId string `thrift:"spaceId,1" json:"spaceId"`
}

func NewGetGrantRuleArgs 

func NewGetGrantRuleArgs() *GetGrantRuleArgs

func (*GetGrantRuleArgs) GetSpaceId 

func (p *GetGrantRuleArgs) GetSpaceId() string

func (*GetGrantRuleArgs) Read 

func (p *GetGrantRuleArgs) Read(iprot thrift.TProtocol) error

func (*GetGrantRuleArgs) ReadField1 

func (p *GetGrantRuleArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetGrantRuleArgs) String 

func (p *GetGrantRuleArgs) String() string

func (*GetGrantRuleArgs) Write 

func (p *GetGrantRuleArgs) Write(oprot thrift.TProtocol) error

type GetGrantRuleResult 

type GetGrantRuleResult struct {
	Success *GrantRule               `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetGrantRuleResult 

func NewGetGrantRuleResult() *GetGrantRuleResult

func (*GetGrantRuleResult) GetSe 

func (p *GetGrantRuleResult) GetSe() *errors.ServiceException

func (*GetGrantRuleResult) GetSuccess 

func (p *GetGrantRuleResult) GetSuccess() *GrantRule

func (*GetGrantRuleResult) IsSetSe 

func (p *GetGrantRuleResult) IsSetSe() bool

func (*GetGrantRuleResult) IsSetSuccess 

func (p *GetGrantRuleResult) IsSetSuccess() bool

func (*GetGrantRuleResult) Read 

func (p *GetGrantRuleResult) Read(iprot thrift.TProtocol) error

func (*GetGrantRuleResult) ReadField0 

func (p *GetGrantRuleResult) ReadField0(iprot thrift.TProtocol) error

func (*GetGrantRuleResult) ReadField1 

func (p *GetGrantRuleResult) ReadField1(iprot thrift.TProtocol) error

func (*GetGrantRuleResult) String 

func (p *GetGrantRuleResult) String() string

func (*GetGrantRuleResult) Write 

func (p *GetGrantRuleResult) Write(oprot thrift.TProtocol) error

type GetIndexTableSplitsArgs 

type GetIndexTableSplitsArgs struct {
	TableName string           `thrift:"tableName,1" json:"tableName"`
	IndexName string           `thrift:"indexName,2" json:"indexName"`
	StartKey  table.Dictionary `thrift:"startKey,3" json:"startKey"`
	StopKey   table.Dictionary `thrift:"stopKey,4" json:"stopKey"`
}

func NewGetIndexTableSplitsArgs 

func NewGetIndexTableSplitsArgs() *GetIndexTableSplitsArgs

func (*GetIndexTableSplitsArgs) GetIndexName 

func (p *GetIndexTableSplitsArgs) GetIndexName() string

func (*GetIndexTableSplitsArgs) GetStartKey 

func (p *GetIndexTableSplitsArgs) GetStartKey() table.Dictionary

func (*GetIndexTableSplitsArgs) GetStopKey 

func (p *GetIndexTableSplitsArgs) GetStopKey() table.Dictionary

func (*GetIndexTableSplitsArgs) GetTableName 

func (p *GetIndexTableSplitsArgs) GetTableName() string

func (*GetIndexTableSplitsArgs) Read 

func (p *GetIndexTableSplitsArgs) Read(iprot thrift.TProtocol) error

func (*GetIndexTableSplitsArgs) ReadField1 

func (p *GetIndexTableSplitsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetIndexTableSplitsArgs) ReadField2 

func (p *GetIndexTableSplitsArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetIndexTableSplitsArgs) ReadField3 

func (p *GetIndexTableSplitsArgs) ReadField3(iprot thrift.TProtocol) error

func (*GetIndexTableSplitsArgs) ReadField4 

func (p *GetIndexTableSplitsArgs) ReadField4(iprot thrift.TProtocol) error

func (*GetIndexTableSplitsArgs) String 

func (p *GetIndexTableSplitsArgs) String() string

func (*GetIndexTableSplitsArgs) Write 

func (p *GetIndexTableSplitsArgs) Write(oprot thrift.TProtocol) error

type GetIndexTableSplitsResult 

type GetIndexTableSplitsResult struct {
	Success []*table.TableSplit      `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetIndexTableSplitsResult 

func NewGetIndexTableSplitsResult() *GetIndexTableSplitsResult

func (*GetIndexTableSplitsResult) GetSe 

func (p *GetIndexTableSplitsResult) GetSe() *errors.ServiceException

func (*GetIndexTableSplitsResult) GetSuccess 

func (p *GetIndexTableSplitsResult) GetSuccess() []*table.TableSplit

func (*GetIndexTableSplitsResult) IsSetSe 

func (p *GetIndexTableSplitsResult) IsSetSe() bool

func (*GetIndexTableSplitsResult) IsSetSuccess 

func (p *GetIndexTableSplitsResult) IsSetSuccess() bool

func (*GetIndexTableSplitsResult) Read 

func (p *GetIndexTableSplitsResult) Read(iprot thrift.TProtocol) error

func (*GetIndexTableSplitsResult) ReadField0 

func (p *GetIndexTableSplitsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetIndexTableSplitsResult) ReadField1 

func (p *GetIndexTableSplitsResult) ReadField1(iprot thrift.TProtocol) error

func (*GetIndexTableSplitsResult) String 

func (p *GetIndexTableSplitsResult) String() string

func (*GetIndexTableSplitsResult) Write 

func (p *GetIndexTableSplitsResult) Write(oprot thrift.TProtocol) error

type GetLatestStreamCheckpointArgs 

type GetLatestStreamCheckpointArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
	TopicName string `thrift:"topicName,2" json:"topicName"`
}

func NewGetLatestStreamCheckpointArgs 

func NewGetLatestStreamCheckpointArgs() *GetLatestStreamCheckpointArgs

func (*GetLatestStreamCheckpointArgs) GetTableName 

func (p *GetLatestStreamCheckpointArgs) GetTableName() string

func (*GetLatestStreamCheckpointArgs) GetTopicName 

func (p *GetLatestStreamCheckpointArgs) GetTopicName() string

func (*GetLatestStreamCheckpointArgs) Read 

func (p *GetLatestStreamCheckpointArgs) Read(iprot thrift.TProtocol) error

func (*GetLatestStreamCheckpointArgs) ReadField1 

func (p *GetLatestStreamCheckpointArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetLatestStreamCheckpointArgs) ReadField2 

func (p *GetLatestStreamCheckpointArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetLatestStreamCheckpointArgs) String 

func (p *GetLatestStreamCheckpointArgs) String() string

func (*GetLatestStreamCheckpointArgs) Write 

func (p *GetLatestStreamCheckpointArgs) Write(oprot thrift.TProtocol) error

type GetLatestStreamCheckpointResult 

type GetLatestStreamCheckpointResult struct {
	Success *StreamCheckpoint        `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetLatestStreamCheckpointResult 

func NewGetLatestStreamCheckpointResult() *GetLatestStreamCheckpointResult

func (*GetLatestStreamCheckpointResult) GetSe 

func (p *GetLatestStreamCheckpointResult) GetSe() *errors.ServiceException

func (*GetLatestStreamCheckpointResult) GetSuccess 

func (p *GetLatestStreamCheckpointResult) GetSuccess() *StreamCheckpoint

func (*GetLatestStreamCheckpointResult) IsSetSe 

func (p *GetLatestStreamCheckpointResult) IsSetSe() bool

func (*GetLatestStreamCheckpointResult) IsSetSuccess 

func (p *GetLatestStreamCheckpointResult) IsSetSuccess() bool

func (*GetLatestStreamCheckpointResult) Read 

func (p *GetLatestStreamCheckpointResult) Read(iprot thrift.TProtocol) error

func (*GetLatestStreamCheckpointResult) ReadField0 

func (p *GetLatestStreamCheckpointResult) ReadField0(iprot thrift.TProtocol) error

func (*GetLatestStreamCheckpointResult) ReadField1 

func (p *GetLatestStreamCheckpointResult) ReadField1(iprot thrift.TProtocol) error

func (*GetLatestStreamCheckpointResult) String 

func (p *GetLatestStreamCheckpointResult) String() string

func (*GetLatestStreamCheckpointResult) Write 

func (p *GetLatestStreamCheckpointResult) Write(oprot thrift.TProtocol) error

type GetQuotaInfoArgs 

type GetQuotaInfoArgs struct {
	SpaceId string `thrift:"spaceId,1" json:"spaceId"`
}

func NewGetQuotaInfoArgs 

func NewGetQuotaInfoArgs() *GetQuotaInfoArgs

func (*GetQuotaInfoArgs) GetSpaceId 

func (p *GetQuotaInfoArgs) GetSpaceId() string

func (*GetQuotaInfoArgs) Read 

func (p *GetQuotaInfoArgs) Read(iprot thrift.TProtocol) error

func (*GetQuotaInfoArgs) ReadField1 

func (p *GetQuotaInfoArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetQuotaInfoArgs) String 

func (p *GetQuotaInfoArgs) String() string

func (*GetQuotaInfoArgs) Write 

func (p *GetQuotaInfoArgs) Write(oprot thrift.TProtocol) error

type GetQuotaInfoResult 

type GetQuotaInfoResult struct {
	Success *QuotaInfo               `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetQuotaInfoResult 

func NewGetQuotaInfoResult() *GetQuotaInfoResult

func (*GetQuotaInfoResult) GetSe 

func (p *GetQuotaInfoResult) GetSe() *errors.ServiceException

func (*GetQuotaInfoResult) GetSuccess 

func (p *GetQuotaInfoResult) GetSuccess() *QuotaInfo

func (*GetQuotaInfoResult) IsSetSe 

func (p *GetQuotaInfoResult) IsSetSe() bool

func (*GetQuotaInfoResult) IsSetSuccess 

func (p *GetQuotaInfoResult) IsSetSuccess() bool

func (*GetQuotaInfoResult) Read 

func (p *GetQuotaInfoResult) Read(iprot thrift.TProtocol) error

func (*GetQuotaInfoResult) ReadField0 

func (p *GetQuotaInfoResult) ReadField0(iprot thrift.TProtocol) error

func (*GetQuotaInfoResult) ReadField1 

func (p *GetQuotaInfoResult) ReadField1(iprot thrift.TProtocol) error

func (*GetQuotaInfoResult) String 

func (p *GetQuotaInfoResult) String() string

func (*GetQuotaInfoResult) Write 

func (p *GetQuotaInfoResult) Write(oprot thrift.TProtocol) error

type GetSnapshotStateArgs 

type GetSnapshotStateArgs struct {
	TableName    string `thrift:"tableName,1" json:"tableName"`
	SnapshotName string `thrift:"snapshotName,2" json:"snapshotName"`
}

func NewGetSnapshotStateArgs 

func NewGetSnapshotStateArgs() *GetSnapshotStateArgs

func (*GetSnapshotStateArgs) GetSnapshotName 

func (p *GetSnapshotStateArgs) GetSnapshotName() string

func (*GetSnapshotStateArgs) GetTableName 

func (p *GetSnapshotStateArgs) GetTableName() string

func (*GetSnapshotStateArgs) Read 

func (p *GetSnapshotStateArgs) Read(iprot thrift.TProtocol) error

func (*GetSnapshotStateArgs) ReadField1 

func (p *GetSnapshotStateArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetSnapshotStateArgs) ReadField2 

func (p *GetSnapshotStateArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetSnapshotStateArgs) String 

func (p *GetSnapshotStateArgs) String() string

func (*GetSnapshotStateArgs) Write 

func (p *GetSnapshotStateArgs) Write(oprot thrift.TProtocol) error

type GetSnapshotStateResult 

type GetSnapshotStateResult struct {
	Success *table.SnapshotState     `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetSnapshotStateResult 

func NewGetSnapshotStateResult() *GetSnapshotStateResult

func (*GetSnapshotStateResult) GetSe 

func (p *GetSnapshotStateResult) GetSe() *errors.ServiceException

func (*GetSnapshotStateResult) GetSuccess 

func (p *GetSnapshotStateResult) GetSuccess() table.SnapshotState

func (*GetSnapshotStateResult) IsSetSe 

func (p *GetSnapshotStateResult) IsSetSe() bool

func (*GetSnapshotStateResult) IsSetSuccess 

func (p *GetSnapshotStateResult) IsSetSuccess() bool

func (*GetSnapshotStateResult) Read 

func (p *GetSnapshotStateResult) Read(iprot thrift.TProtocol) error

func (*GetSnapshotStateResult) ReadField0 

func (p *GetSnapshotStateResult) ReadField0(iprot thrift.TProtocol) error

func (*GetSnapshotStateResult) ReadField1 

func (p *GetSnapshotStateResult) ReadField1(iprot thrift.TProtocol) error

func (*GetSnapshotStateResult) String 

func (p *GetSnapshotStateResult) String() string

func (*GetSnapshotStateResult) Write 

func (p *GetSnapshotStateResult) Write(oprot thrift.TProtocol) error

type GetTableHistorySizeArgs 

type GetTableHistorySizeArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
	StartDate int64  `thrift:"startDate,2" json:"startDate"`
	StopDate  int64  `thrift:"stopDate,3" json:"stopDate"`
}

func NewGetTableHistorySizeArgs 

func NewGetTableHistorySizeArgs() *GetTableHistorySizeArgs

func (*GetTableHistorySizeArgs) GetStartDate 

func (p *GetTableHistorySizeArgs) GetStartDate() int64

func (*GetTableHistorySizeArgs) GetStopDate 

func (p *GetTableHistorySizeArgs) GetStopDate() int64

func (*GetTableHistorySizeArgs) GetTableName 

func (p *GetTableHistorySizeArgs) GetTableName() string

func (*GetTableHistorySizeArgs) Read 

func (p *GetTableHistorySizeArgs) Read(iprot thrift.TProtocol) error

func (*GetTableHistorySizeArgs) ReadField1 

func (p *GetTableHistorySizeArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTableHistorySizeArgs) ReadField2 

func (p *GetTableHistorySizeArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetTableHistorySizeArgs) ReadField3 

func (p *GetTableHistorySizeArgs) ReadField3(iprot thrift.TProtocol) error

func (*GetTableHistorySizeArgs) String 

func (p *GetTableHistorySizeArgs) String() string

func (*GetTableHistorySizeArgs) Write 

func (p *GetTableHistorySizeArgs) Write(oprot thrift.TProtocol) error

type GetTableHistorySizeResult 

type GetTableHistorySizeResult struct {
	Success map[int64]int64          `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetTableHistorySizeResult 

func NewGetTableHistorySizeResult() *GetTableHistorySizeResult

func (*GetTableHistorySizeResult) GetSe 

func (p *GetTableHistorySizeResult) GetSe() *errors.ServiceException

func (*GetTableHistorySizeResult) GetSuccess 

func (p *GetTableHistorySizeResult) GetSuccess() map[int64]int64

func (*GetTableHistorySizeResult) IsSetSe 

func (p *GetTableHistorySizeResult) IsSetSe() bool

func (*GetTableHistorySizeResult) IsSetSuccess 

func (p *GetTableHistorySizeResult) IsSetSuccess() bool

func (*GetTableHistorySizeResult) Read 

func (p *GetTableHistorySizeResult) Read(iprot thrift.TProtocol) error

func (*GetTableHistorySizeResult) ReadField0 

func (p *GetTableHistorySizeResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTableHistorySizeResult) ReadField1 

func (p *GetTableHistorySizeResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTableHistorySizeResult) String 

func (p *GetTableHistorySizeResult) String() string

func (*GetTableHistorySizeResult) Write 

func (p *GetTableHistorySizeResult) Write(oprot thrift.TProtocol) error

type GetTableSizeArgs 

type GetTableSizeArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
}

func NewGetTableSizeArgs 

func NewGetTableSizeArgs() *GetTableSizeArgs

func (*GetTableSizeArgs) GetTableName 

func (p *GetTableSizeArgs) GetTableName() string

func (*GetTableSizeArgs) Read 

func (p *GetTableSizeArgs) Read(iprot thrift.TProtocol) error

func (*GetTableSizeArgs) ReadField1 

func (p *GetTableSizeArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTableSizeArgs) String 

func (p *GetTableSizeArgs) String() string

func (*GetTableSizeArgs) Write 

func (p *GetTableSizeArgs) Write(oprot thrift.TProtocol) error

type GetTableSizeResult 

type GetTableSizeResult struct {
	Success *int64                   `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetTableSizeResult 

func NewGetTableSizeResult() *GetTableSizeResult

func (*GetTableSizeResult) GetSe 

func (p *GetTableSizeResult) GetSe() *errors.ServiceException

func (*GetTableSizeResult) GetSuccess 

func (p *GetTableSizeResult) GetSuccess() int64

func (*GetTableSizeResult) IsSetSe 

func (p *GetTableSizeResult) IsSetSe() bool

func (*GetTableSizeResult) IsSetSuccess 

func (p *GetTableSizeResult) IsSetSuccess() bool

func (*GetTableSizeResult) Read 

func (p *GetTableSizeResult) Read(iprot thrift.TProtocol) error

func (*GetTableSizeResult) ReadField0 

func (p *GetTableSizeResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTableSizeResult) ReadField1 

func (p *GetTableSizeResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTableSizeResult) String 

func (p *GetTableSizeResult) String() string

func (*GetTableSizeResult) Write 

func (p *GetTableSizeResult) Write(oprot thrift.TProtocol) error

type GetTableSplitsArgs 

type GetTableSplitsArgs struct {
	TableName string           `thrift:"tableName,1" json:"tableName"`
	StartKey  table.Dictionary `thrift:"startKey,2" json:"startKey"`
	StopKey   table.Dictionary `thrift:"stopKey,3" json:"stopKey"`
}

func NewGetTableSplitsArgs 

func NewGetTableSplitsArgs() *GetTableSplitsArgs

func (*GetTableSplitsArgs) GetStartKey 

func (p *GetTableSplitsArgs) GetStartKey() table.Dictionary

func (*GetTableSplitsArgs) GetStopKey 

func (p *GetTableSplitsArgs) GetStopKey() table.Dictionary

func (*GetTableSplitsArgs) GetTableName 

func (p *GetTableSplitsArgs) GetTableName() string

func (*GetTableSplitsArgs) Read 

func (p *GetTableSplitsArgs) Read(iprot thrift.TProtocol) error

func (*GetTableSplitsArgs) ReadField1 

func (p *GetTableSplitsArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTableSplitsArgs) ReadField2 

func (p *GetTableSplitsArgs) ReadField2(iprot thrift.TProtocol) error

func (*GetTableSplitsArgs) ReadField3 

func (p *GetTableSplitsArgs) ReadField3(iprot thrift.TProtocol) error

func (*GetTableSplitsArgs) String 

func (p *GetTableSplitsArgs) String() string

func (*GetTableSplitsArgs) Write 

func (p *GetTableSplitsArgs) Write(oprot thrift.TProtocol) error

type GetTableSplitsResult 

type GetTableSplitsResult struct {
	Success []*table.TableSplit      `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetTableSplitsResult 

func NewGetTableSplitsResult() *GetTableSplitsResult

func (*GetTableSplitsResult) GetSe 

func (p *GetTableSplitsResult) GetSe() *errors.ServiceException

func (*GetTableSplitsResult) GetSuccess 

func (p *GetTableSplitsResult) GetSuccess() []*table.TableSplit

func (*GetTableSplitsResult) IsSetSe 

func (p *GetTableSplitsResult) IsSetSe() bool

func (*GetTableSplitsResult) IsSetSuccess 

func (p *GetTableSplitsResult) IsSetSuccess() bool

func (*GetTableSplitsResult) Read 

func (p *GetTableSplitsResult) Read(iprot thrift.TProtocol) error

func (*GetTableSplitsResult) ReadField0 

func (p *GetTableSplitsResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTableSplitsResult) ReadField1 

func (p *GetTableSplitsResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTableSplitsResult) String 

func (p *GetTableSplitsResult) String() string

func (*GetTableSplitsResult) Write 

func (p *GetTableSplitsResult) Write(oprot thrift.TProtocol) error

type GetTableStateArgs 

type GetTableStateArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
}

func NewGetTableStateArgs 

func NewGetTableStateArgs() *GetTableStateArgs

func (*GetTableStateArgs) GetTableName 

func (p *GetTableStateArgs) GetTableName() string

func (*GetTableStateArgs) Read 

func (p *GetTableStateArgs) Read(iprot thrift.TProtocol) error

func (*GetTableStateArgs) ReadField1 

func (p *GetTableStateArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTableStateArgs) String 

func (p *GetTableStateArgs) String() string

func (*GetTableStateArgs) Write 

func (p *GetTableStateArgs) Write(oprot thrift.TProtocol) error

type GetTableStateResult 

type GetTableStateResult struct {
	Success *table.TableState        `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetTableStateResult 

func NewGetTableStateResult() *GetTableStateResult

func (*GetTableStateResult) GetSe 

func (p *GetTableStateResult) GetSe() *errors.ServiceException

func (*GetTableStateResult) GetSuccess 

func (p *GetTableStateResult) GetSuccess() table.TableState

func (*GetTableStateResult) IsSetSe 

func (p *GetTableStateResult) IsSetSe() bool

func (*GetTableStateResult) IsSetSuccess 

func (p *GetTableStateResult) IsSetSuccess() bool

func (*GetTableStateResult) Read 

func (p *GetTableStateResult) Read(iprot thrift.TProtocol) error

func (*GetTableStateResult) ReadField0 

func (p *GetTableStateResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTableStateResult) ReadField1 

func (p *GetTableStateResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTableStateResult) String 

func (p *GetTableStateResult) String() string

func (*GetTableStateResult) Write 

func (p *GetTableStateResult) Write(oprot thrift.TProtocol) error

type GetTableStatusArgs 

type GetTableStatusArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
}

func NewGetTableStatusArgs 

func NewGetTableStatusArgs() *GetTableStatusArgs

func (*GetTableStatusArgs) GetTableName 

func (p *GetTableStatusArgs) GetTableName() string

func (*GetTableStatusArgs) Read 

func (p *GetTableStatusArgs) Read(iprot thrift.TProtocol) error

func (*GetTableStatusArgs) ReadField1 

func (p *GetTableStatusArgs) ReadField1(iprot thrift.TProtocol) error

func (*GetTableStatusArgs) String 

func (p *GetTableStatusArgs) String() string

func (*GetTableStatusArgs) Write 

func (p *GetTableStatusArgs) Write(oprot thrift.TProtocol) error

type GetTableStatusResult 

type GetTableStatusResult struct {
	Success *table.TableStatus       `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewGetTableStatusResult 

func NewGetTableStatusResult() *GetTableStatusResult

func (*GetTableStatusResult) GetSe 

func (p *GetTableStatusResult) GetSe() *errors.ServiceException

func (*GetTableStatusResult) GetSuccess 

func (p *GetTableStatusResult) GetSuccess() *table.TableStatus

func (*GetTableStatusResult) IsSetSe 

func (p *GetTableStatusResult) IsSetSe() bool

func (*GetTableStatusResult) IsSetSuccess 

func (p *GetTableStatusResult) IsSetSuccess() bool

func (*GetTableStatusResult) Read 

func (p *GetTableStatusResult) Read(iprot thrift.TProtocol) error

func (*GetTableStatusResult) ReadField0 

func (p *GetTableStatusResult) ReadField0(iprot thrift.TProtocol) error

func (*GetTableStatusResult) ReadField1 

func (p *GetTableStatusResult) ReadField1(iprot thrift.TProtocol) error

func (*GetTableStatusResult) String 

func (p *GetTableStatusResult) String() string

func (*GetTableStatusResult) Write 

func (p *GetTableStatusResult) Write(oprot thrift.TProtocol) error

type GrantRule 

type GrantRule struct {
	GrantRule map[string]map[string][]table.Permission `thrift:"grantRule,1" json:"grantRule"`
}
var GetGrantRuleResult_Success_DEFAULT *GrantRule
var SetGrantRuleArgs_GrantRule_DEFAULT *GrantRule

func NewGrantRule 

func NewGrantRule() *GrantRule

func (*GrantRule) GetGrantRule 

func (p *GrantRule) GetGrantRule() map[string]map[string][]table.Permission

func (*GrantRule) Read 

func (p *GrantRule) Read(iprot thrift.TProtocol) error

func (*GrantRule) ReadField1 

func (p *GrantRule) ReadField1(iprot thrift.TProtocol) error

func (*GrantRule) String 

func (p *GrantRule) String() string

func (*GrantRule) Write 

func (p *GrantRule) Write(oprot thrift.TProtocol) error

type LatencyMetricType 

type LatencyMetricType int64

客户端metrics请求延迟的类型 

const (
	LatencyMetricType_ExecutionTime LatencyMetricType = 1
)

func LatencyMetricTypeFromString 

func LatencyMetricTypeFromString(s string) (LatencyMetricType, error)

func LatencyMetricTypePtr 

func LatencyMetricTypePtr(v LatencyMetricType) *LatencyMetricType

func (LatencyMetricType) String 

func (p LatencyMetricType) String() string

type ListAllDeletedTablesArgs 

type ListAllDeletedTablesArgs struct {
	SpaceId string `thrift:"spaceId,1" json:"spaceId"`
}

func NewListAllDeletedTablesArgs 

func NewListAllDeletedTablesArgs() *ListAllDeletedTablesArgs

func (*ListAllDeletedTablesArgs) GetSpaceId 

func (p *ListAllDeletedTablesArgs) GetSpaceId() string

func (*ListAllDeletedTablesArgs) Read 

func (p *ListAllDeletedTablesArgs) Read(iprot thrift.TProtocol) error

func (*ListAllDeletedTablesArgs) ReadField1 

func (p *ListAllDeletedTablesArgs) ReadField1(iprot thrift.TProtocol) error

func (*ListAllDeletedTablesArgs) String 

func (p *ListAllDeletedTablesArgs) String() string

func (*ListAllDeletedTablesArgs) Write 

func (p *ListAllDeletedTablesArgs) Write(oprot thrift.TProtocol) error

type ListAllDeletedTablesResult 

type ListAllDeletedTablesResult struct {
	Success []*table.TableInfo       `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewListAllDeletedTablesResult 

func NewListAllDeletedTablesResult() *ListAllDeletedTablesResult

func (*ListAllDeletedTablesResult) GetSe 

func (p *ListAllDeletedTablesResult) GetSe() *errors.ServiceException

func (*ListAllDeletedTablesResult) GetSuccess 

func (p *ListAllDeletedTablesResult) GetSuccess() []*table.TableInfo

func (*ListAllDeletedTablesResult) IsSetSe 

func (p *ListAllDeletedTablesResult) IsSetSe() bool

func (*ListAllDeletedTablesResult) IsSetSuccess 

func (p *ListAllDeletedTablesResult) IsSetSuccess() bool

func (*ListAllDeletedTablesResult) Read 

func (p *ListAllDeletedTablesResult) Read(iprot thrift.TProtocol) error

func (*ListAllDeletedTablesResult) ReadField0 

func (p *ListAllDeletedTablesResult) ReadField0(iprot thrift.TProtocol) error

func (*ListAllDeletedTablesResult) ReadField1 

func (p *ListAllDeletedTablesResult) ReadField1(iprot thrift.TProtocol) error

func (*ListAllDeletedTablesResult) String 

func (p *ListAllDeletedTablesResult) String() string

func (*ListAllDeletedTablesResult) Write 

func (p *ListAllDeletedTablesResult) Write(oprot thrift.TProtocol) error

type ListAllSnapshotsArgs 

type ListAllSnapshotsArgs struct {
	SpaceId string `thrift:"spaceId,1" json:"spaceId"`
}

func NewListAllSnapshotsArgs 

func NewListAllSnapshotsArgs() *ListAllSnapshotsArgs

func (*ListAllSnapshotsArgs) GetSpaceId 

func (p *ListAllSnapshotsArgs) GetSpaceId() string

func (*ListAllSnapshotsArgs) Read 

func (p *ListAllSnapshotsArgs) Read(iprot thrift.TProtocol) error

func (*ListAllSnapshotsArgs) ReadField1 

func (p *ListAllSnapshotsArgs) ReadField1(iprot thrift.TProtocol) error

func (*ListAllSnapshotsArgs) String 

func (p *ListAllSnapshotsArgs) String() string

func (*ListAllSnapshotsArgs) Write 

func (p *ListAllSnapshotsArgs) Write(oprot thrift.TProtocol) error

type ListAllSnapshotsResult 

type ListAllSnapshotsResult struct {
	Success []*SnapshotTableView     `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewListAllSnapshotsResult 

func NewListAllSnapshotsResult() *ListAllSnapshotsResult

func (*ListAllSnapshotsResult) GetSe 

func (p *ListAllSnapshotsResult) GetSe() *errors.ServiceException

func (*ListAllSnapshotsResult) GetSuccess 

func (p *ListAllSnapshotsResult) GetSuccess() []*SnapshotTableView

func (*ListAllSnapshotsResult) IsSetSe 

func (p *ListAllSnapshotsResult) IsSetSe() bool

func (*ListAllSnapshotsResult) IsSetSuccess 

func (p *ListAllSnapshotsResult) IsSetSuccess() bool

func (*ListAllSnapshotsResult) Read 

func (p *ListAllSnapshotsResult) Read(iprot thrift.TProtocol) error

func (*ListAllSnapshotsResult) ReadField0 

func (p *ListAllSnapshotsResult) ReadField0(iprot thrift.TProtocol) error

func (*ListAllSnapshotsResult) ReadField1 

func (p *ListAllSnapshotsResult) ReadField1(iprot thrift.TProtocol) error

func (*ListAllSnapshotsResult) String 

func (p *ListAllSnapshotsResult) String() string

func (*ListAllSnapshotsResult) Write 

func (p *ListAllSnapshotsResult) Write(oprot thrift.TProtocol) error

type ListSnapshotsArgs 

type ListSnapshotsArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
}

func NewListSnapshotsArgs 

func NewListSnapshotsArgs() *ListSnapshotsArgs

func (*ListSnapshotsArgs) GetTableName 

func (p *ListSnapshotsArgs) GetTableName() string

func (*ListSnapshotsArgs) Read 

func (p *ListSnapshotsArgs) Read(iprot thrift.TProtocol) error

func (*ListSnapshotsArgs) ReadField1 

func (p *ListSnapshotsArgs) ReadField1(iprot thrift.TProtocol) error

func (*ListSnapshotsArgs) String 

func (p *ListSnapshotsArgs) String() string

func (*ListSnapshotsArgs) Write 

func (p *ListSnapshotsArgs) Write(oprot thrift.TProtocol) error

type ListSnapshotsResult 

type ListSnapshotsResult struct {
	Success *TableSnapshots          `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewListSnapshotsResult 

func NewListSnapshotsResult() *ListSnapshotsResult

func (*ListSnapshotsResult) GetSe 

func (p *ListSnapshotsResult) GetSe() *errors.ServiceException

func (*ListSnapshotsResult) GetSuccess 

func (p *ListSnapshotsResult) GetSuccess() *TableSnapshots

func (*ListSnapshotsResult) IsSetSe 

func (p *ListSnapshotsResult) IsSetSe() bool

func (*ListSnapshotsResult) IsSetSuccess 

func (p *ListSnapshotsResult) IsSetSuccess() bool

func (*ListSnapshotsResult) Read 

func (p *ListSnapshotsResult) Read(iprot thrift.TProtocol) error

func (*ListSnapshotsResult) ReadField0 

func (p *ListSnapshotsResult) ReadField0(iprot thrift.TProtocol) error

func (*ListSnapshotsResult) ReadField1 

func (p *ListSnapshotsResult) ReadField1(iprot thrift.TProtocol) error

func (*ListSnapshotsResult) String 

func (p *ListSnapshotsResult) String() string

func (*ListSnapshotsResult) Write 

func (p *ListSnapshotsResult) Write(oprot thrift.TProtocol) error

type ListSubscribedEmailArgs 

type ListSubscribedEmailArgs struct {
	SpaceId string `thrift:"spaceId,1" json:"spaceId"`
}

func NewListSubscribedEmailArgs 

func NewListSubscribedEmailArgs() *ListSubscribedEmailArgs

func (*ListSubscribedEmailArgs) GetSpaceId 

func (p *ListSubscribedEmailArgs) GetSpaceId() string

func (*ListSubscribedEmailArgs) Read 

func (p *ListSubscribedEmailArgs) Read(iprot thrift.TProtocol) error

func (*ListSubscribedEmailArgs) ReadField1 

func (p *ListSubscribedEmailArgs) ReadField1(iprot thrift.TProtocol) error

func (*ListSubscribedEmailArgs) String 

func (p *ListSubscribedEmailArgs) String() string

func (*ListSubscribedEmailArgs) Write 

func (p *ListSubscribedEmailArgs) Write(oprot thrift.TProtocol) error

type ListSubscribedEmailResult 

type ListSubscribedEmailResult struct {
	Success []string                 `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewListSubscribedEmailResult 

func NewListSubscribedEmailResult() *ListSubscribedEmailResult

func (*ListSubscribedEmailResult) GetSe 

func (p *ListSubscribedEmailResult) GetSe() *errors.ServiceException

func (*ListSubscribedEmailResult) GetSuccess 

func (p *ListSubscribedEmailResult) GetSuccess() []string

func (*ListSubscribedEmailResult) IsSetSe 

func (p *ListSubscribedEmailResult) IsSetSe() bool

func (*ListSubscribedEmailResult) IsSetSuccess 

func (p *ListSubscribedEmailResult) IsSetSuccess() bool

func (*ListSubscribedEmailResult) Read 

func (p *ListSubscribedEmailResult) Read(iprot thrift.TProtocol) error

func (*ListSubscribedEmailResult) ReadField0 

func (p *ListSubscribedEmailResult) ReadField0(iprot thrift.TProtocol) error

func (*ListSubscribedEmailResult) ReadField1 

func (p *ListSubscribedEmailResult) ReadField1(iprot thrift.TProtocol) error

func (*ListSubscribedEmailResult) String 

func (p *ListSubscribedEmailResult) String() string

func (*ListSubscribedEmailResult) Write 

func (p *ListSubscribedEmailResult) Write(oprot thrift.TProtocol) error

type ListSubscribedPhoneArgs 

type ListSubscribedPhoneArgs struct {
	SpaceId string `thrift:"spaceId,1" json:"spaceId"`
}

func NewListSubscribedPhoneArgs 

func NewListSubscribedPhoneArgs() *ListSubscribedPhoneArgs

func (*ListSubscribedPhoneArgs) GetSpaceId 

func (p *ListSubscribedPhoneArgs) GetSpaceId() string

func (*ListSubscribedPhoneArgs) Read 

func (p *ListSubscribedPhoneArgs) Read(iprot thrift.TProtocol) error

func (*ListSubscribedPhoneArgs) ReadField1 

func (p *ListSubscribedPhoneArgs) ReadField1(iprot thrift.TProtocol) error

func (*ListSubscribedPhoneArgs) String 

func (p *ListSubscribedPhoneArgs) String() string

func (*ListSubscribedPhoneArgs) Write 

func (p *ListSubscribedPhoneArgs) Write(oprot thrift.TProtocol) error

type ListSubscribedPhoneResult 

type ListSubscribedPhoneResult struct {
	Success []string                 `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewListSubscribedPhoneResult 

func NewListSubscribedPhoneResult() *ListSubscribedPhoneResult

func (*ListSubscribedPhoneResult) GetSe 

func (p *ListSubscribedPhoneResult) GetSe() *errors.ServiceException

func (*ListSubscribedPhoneResult) GetSuccess 

func (p *ListSubscribedPhoneResult) GetSuccess() []string

func (*ListSubscribedPhoneResult) IsSetSe 

func (p *ListSubscribedPhoneResult) IsSetSe() bool

func (*ListSubscribedPhoneResult) IsSetSuccess 

func (p *ListSubscribedPhoneResult) IsSetSuccess() bool

func (*ListSubscribedPhoneResult) Read 

func (p *ListSubscribedPhoneResult) Read(iprot thrift.TProtocol) error

func (*ListSubscribedPhoneResult) ReadField0 

func (p *ListSubscribedPhoneResult) ReadField0(iprot thrift.TProtocol) error

func (*ListSubscribedPhoneResult) ReadField1 

func (p *ListSubscribedPhoneResult) ReadField1(iprot thrift.TProtocol) error

func (*ListSubscribedPhoneResult) String 

func (p *ListSubscribedPhoneResult) String() string

func (*ListSubscribedPhoneResult) Write 

func (p *ListSubscribedPhoneResult) Write(oprot thrift.TProtocol) error

type MetricData 

type MetricData struct {
	ClientMetricType *ClientMetricType `thrift:"clientMetricType,1" json:"clientMetricType"`
	MetricName       *string           `thrift:"metricName,2" json:"metricName"`
	Value            *int64            `thrift:"value,3" json:"value"`
	TimeStamp        *int64            `thrift:"timeStamp,4" json:"timeStamp"`
}

func NewMetricData 

func NewMetricData() *MetricData

func (*MetricData) GetClientMetricType 

func (p *MetricData) GetClientMetricType() ClientMetricType

func (*MetricData) GetMetricName 

func (p *MetricData) GetMetricName() string

func (*MetricData) GetTimeStamp 

func (p *MetricData) GetTimeStamp() int64

func (*MetricData) GetValue 

func (p *MetricData) GetValue() int64

func (*MetricData) IsSetClientMetricType 

func (p *MetricData) IsSetClientMetricType() bool

func (*MetricData) IsSetMetricName 

func (p *MetricData) IsSetMetricName() bool

func (*MetricData) IsSetTimeStamp 

func (p *MetricData) IsSetTimeStamp() bool

func (*MetricData) IsSetValue 

func (p *MetricData) IsSetValue() bool

func (*MetricData) Read 

func (p *MetricData) Read(iprot thrift.TProtocol) error

func (*MetricData) ReadField1 

func (p *MetricData) ReadField1(iprot thrift.TProtocol) error

func (*MetricData) ReadField2 

func (p *MetricData) ReadField2(iprot thrift.TProtocol) error

func (*MetricData) ReadField3 

func (p *MetricData) ReadField3(iprot thrift.TProtocol) error

func (*MetricData) ReadField4 

func (p *MetricData) ReadField4(iprot thrift.TProtocol) error

func (*MetricData) String 

func (p *MetricData) String() string

func (*MetricData) Write 

func (p *MetricData) Write(oprot thrift.TProtocol) error

type MetricKey 

type MetricKey int64

系统统计指标类型 

const (
	MetricKey_METER_METRIC_MIN     MetricKey = 0
	MetricKey_READ_ALLOWED         MetricKey = 1
	MetricKey_READ_THROTTLED       MetricKey = 2
	MetricKey_WRITE_ALLOWED        MetricKey = 3
	MetricKey_WRITE_THROTTLED      MetricKey = 4
	MetricKey_ACTION_SUCCESS       MetricKey = 5
	MetricKey_ACTION_CLIENT_ERROR  MetricKey = 6
	MetricKey_ACTION_SYSTEM_ERROR  MetricKey = 7
	MetricKey_METER_METRIC_MAX     MetricKey = 49
	MetricKey_HISTOGRAM_METRIC_MIN MetricKey = 50
	MetricKey_CREATE_LATENCY       MetricKey = 51
	MetricKey_DROP_LATENCY         MetricKey = 52
	MetricKey_DESCRIBE_LATENCY     MetricKey = 53
	MetricKey_ALTER_LATENCY        MetricKey = 54
	MetricKey_ENABLE_LATENCY       MetricKey = 55
	MetricKey_DISABLE_LATENCY      MetricKey = 56
	MetricKey_METRICQUERY_LATENCY  MetricKey = 57
	MetricKey_GET_LATENCY          MetricKey = 58
	MetricKey_PUT_LATENCY          MetricKey = 59
	MetricKey_INCREMENT_LATENCY    MetricKey = 60
	MetricKey_DELETE_LATENCY       MetricKey = 61
	MetricKey_SCAN_LATENCY         MetricKey = 62
	MetricKey_BATCH_LATENCY        MetricKey = 63
	MetricKey_HISTOGRAM_METRIC_MAX MetricKey = 100
)
var MetricQueryRequest_MetricKey_DEFAULT MetricKey
var TimeSeriesData_MetricKey_DEFAULT MetricKey

func MetricKeyFromString 

func MetricKeyFromString(s string) (MetricKey, error)

func MetricKeyPtr 

func MetricKeyPtr(v MetricKey) *MetricKey

func (MetricKey) String 

func (p MetricKey) String() string

type MetricQueryRequest 

type MetricQueryRequest struct {
	TableName          *string       `thrift:"tableName,1" json:"tableName"`
	StartTime          *int64        `thrift:"startTime,2" json:"startTime"`
	StopTime           *int64        `thrift:"stopTime,3" json:"stopTime"`
	MetricKey          *MetricKey    `thrift:"metricKey,4" json:"metricKey"`
	MetricType         *MetricType   `thrift:"metricType,5" json:"metricType"`
	DownsampleInterval *int32        `thrift:"downsampleInterval,6" json:"downsampleInterval"`
	DownsampleTimeUnit *TimeSpanUnit `thrift:"downsampleTimeUnit,7" json:"downsampleTimeUnit"`
}
var QueryMetricArgs_Query_DEFAULT *MetricQueryRequest

func NewMetricQueryRequest 

func NewMetricQueryRequest() *MetricQueryRequest

func (*MetricQueryRequest) GetDownsampleInterval 

func (p *MetricQueryRequest) GetDownsampleInterval() int32

func (*MetricQueryRequest) GetDownsampleTimeUnit 

func (p *MetricQueryRequest) GetDownsampleTimeUnit() TimeSpanUnit

func (*MetricQueryRequest) GetMetricKey 

func (p *MetricQueryRequest) GetMetricKey() MetricKey

func (*MetricQueryRequest) GetMetricType 

func (p *MetricQueryRequest) GetMetricType() MetricType

func (*MetricQueryRequest) GetStartTime 

func (p *MetricQueryRequest) GetStartTime() int64

func (*MetricQueryRequest) GetStopTime 

func (p *MetricQueryRequest) GetStopTime() int64

func (*MetricQueryRequest) GetTableName 

func (p *MetricQueryRequest) GetTableName() string

func (*MetricQueryRequest) IsSetDownsampleInterval 

func (p *MetricQueryRequest) IsSetDownsampleInterval() bool

func (*MetricQueryRequest) IsSetDownsampleTimeUnit 

func (p *MetricQueryRequest) IsSetDownsampleTimeUnit() bool

func (*MetricQueryRequest) IsSetMetricKey 

func (p *MetricQueryRequest) IsSetMetricKey() bool

func (*MetricQueryRequest) IsSetMetricType 

func (p *MetricQueryRequest) IsSetMetricType() bool

func (*MetricQueryRequest) IsSetStartTime 

func (p *MetricQueryRequest) IsSetStartTime() bool

func (*MetricQueryRequest) IsSetStopTime 

func (p *MetricQueryRequest) IsSetStopTime() bool

func (*MetricQueryRequest) IsSetTableName 

func (p *MetricQueryRequest) IsSetTableName() bool

func (*MetricQueryRequest) Read 

func (p *MetricQueryRequest) Read(iprot thrift.TProtocol) error

func (*MetricQueryRequest) ReadField1 

func (p *MetricQueryRequest) ReadField1(iprot thrift.TProtocol) error

func (*MetricQueryRequest) ReadField2 

func (p *MetricQueryRequest) ReadField2(iprot thrift.TProtocol) error

func (*MetricQueryRequest) ReadField3 

func (p *MetricQueryRequest) ReadField3(iprot thrift.TProtocol) error

func (*MetricQueryRequest) ReadField4 

func (p *MetricQueryRequest) ReadField4(iprot thrift.TProtocol) error

func (*MetricQueryRequest) ReadField5 

func (p *MetricQueryRequest) ReadField5(iprot thrift.TProtocol) error

func (*MetricQueryRequest) ReadField6 

func (p *MetricQueryRequest) ReadField6(iprot thrift.TProtocol) error

func (*MetricQueryRequest) ReadField7 

func (p *MetricQueryRequest) ReadField7(iprot thrift.TProtocol) error

func (*MetricQueryRequest) String 

func (p *MetricQueryRequest) String() string

func (*MetricQueryRequest) Write 

func (p *MetricQueryRequest) Write(oprot thrift.TProtocol) error

type MetricType 

type MetricType int64

统计指标的子类型 (MetricKey, MetricType) 元组唯一确定一个统计指标 

const (
	MetricType_COUNT    MetricType = 1
	MetricType_M1_RATE  MetricType = 2
	MetricType_M5_RATE  MetricType = 3
	MetricType_M15_RATE MetricType = 4
	MetricType_MEAN     MetricType = 5
	MetricType_STDDEV   MetricType = 6
	MetricType_P50      MetricType = 7
	MetricType_P75      MetricType = 8
	MetricType_P95      MetricType = 9
	MetricType_P98      MetricType = 10
	MetricType_P99      MetricType = 11
)
var MetricQueryRequest_MetricType_DEFAULT MetricType
var TimeSeriesData_MetricType_DEFAULT MetricType

func MetricTypeFromString 

func MetricTypeFromString(s string) (MetricType, error)

func MetricTypePtr 

func MetricTypePtr(v MetricType) *MetricType

func (MetricType) String 

func (p MetricType) String() string

type PutClientMetricsArgs 

type PutClientMetricsArgs struct {
	ClientMetrics *ClientMetrics `thrift:"clientMetrics,1" json:"clientMetrics"`
}

func NewPutClientMetricsArgs 

func NewPutClientMetricsArgs() *PutClientMetricsArgs

func (*PutClientMetricsArgs) GetClientMetrics 

func (p *PutClientMetricsArgs) GetClientMetrics() *ClientMetrics

func (*PutClientMetricsArgs) IsSetClientMetrics 

func (p *PutClientMetricsArgs) IsSetClientMetrics() bool

func (*PutClientMetricsArgs) Read 

func (p *PutClientMetricsArgs) Read(iprot thrift.TProtocol) error

func (*PutClientMetricsArgs) ReadField1 

func (p *PutClientMetricsArgs) ReadField1(iprot thrift.TProtocol) error

func (*PutClientMetricsArgs) String 

func (p *PutClientMetricsArgs) String() string

func (*PutClientMetricsArgs) Write 

func (p *PutClientMetricsArgs) Write(oprot thrift.TProtocol) error

type PutClientMetricsResult 

type PutClientMetricsResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewPutClientMetricsResult 

func NewPutClientMetricsResult() *PutClientMetricsResult

func (*PutClientMetricsResult) GetSe 

func (p *PutClientMetricsResult) GetSe() *errors.ServiceException

func (*PutClientMetricsResult) IsSetSe 

func (p *PutClientMetricsResult) IsSetSe() bool

func (*PutClientMetricsResult) Read 

func (p *PutClientMetricsResult) Read(iprot thrift.TProtocol) error

func (*PutClientMetricsResult) ReadField1 

func (p *PutClientMetricsResult) ReadField1(iprot thrift.TProtocol) error

func (*PutClientMetricsResult) String 

func (p *PutClientMetricsResult) String() string

func (*PutClientMetricsResult) Write 

func (p *PutClientMetricsResult) Write(oprot thrift.TProtocol) error

type QueryMetricArgs 

type QueryMetricArgs struct {
	Query *MetricQueryRequest `thrift:"query,1" json:"query"`
}

func NewQueryMetricArgs 

func NewQueryMetricArgs() *QueryMetricArgs

func (*QueryMetricArgs) GetQuery 

func (p *QueryMetricArgs) GetQuery() *MetricQueryRequest

func (*QueryMetricArgs) IsSetQuery 

func (p *QueryMetricArgs) IsSetQuery() bool

func (*QueryMetricArgs) Read 

func (p *QueryMetricArgs) Read(iprot thrift.TProtocol) error

func (*QueryMetricArgs) ReadField1 

func (p *QueryMetricArgs) ReadField1(iprot thrift.TProtocol) error

func (*QueryMetricArgs) String 

func (p *QueryMetricArgs) String() string

func (*QueryMetricArgs) Write 

func (p *QueryMetricArgs) Write(oprot thrift.TProtocol) error

type QueryMetricResult 

type QueryMetricResult struct {
	Success *TimeSeriesData          `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewQueryMetricResult 

func NewQueryMetricResult() *QueryMetricResult

func (*QueryMetricResult) GetSe 

func (p *QueryMetricResult) GetSe() *errors.ServiceException

func (*QueryMetricResult) GetSuccess 

func (p *QueryMetricResult) GetSuccess() *TimeSeriesData

func (*QueryMetricResult) IsSetSe 

func (p *QueryMetricResult) IsSetSe() bool

func (*QueryMetricResult) IsSetSuccess 

func (p *QueryMetricResult) IsSetSuccess() bool

func (*QueryMetricResult) Read 

func (p *QueryMetricResult) Read(iprot thrift.TProtocol) error

func (*QueryMetricResult) ReadField0 

func (p *QueryMetricResult) ReadField0(iprot thrift.TProtocol) error

func (*QueryMetricResult) ReadField1 

func (p *QueryMetricResult) ReadField1(iprot thrift.TProtocol) error

func (*QueryMetricResult) String 

func (p *QueryMetricResult) String() string

func (*QueryMetricResult) Write 

func (p *QueryMetricResult) Write(oprot thrift.TProtocol) error

type QueryMetricsArgs 

type QueryMetricsArgs struct {
	Queries []*MetricQueryRequest `thrift:"queries,1" json:"queries"`
}

func NewQueryMetricsArgs 

func NewQueryMetricsArgs() *QueryMetricsArgs

func (*QueryMetricsArgs) GetQueries 

func (p *QueryMetricsArgs) GetQueries() []*MetricQueryRequest

func (*QueryMetricsArgs) Read 

func (p *QueryMetricsArgs) Read(iprot thrift.TProtocol) error

func (*QueryMetricsArgs) ReadField1 

func (p *QueryMetricsArgs) ReadField1(iprot thrift.TProtocol) error

func (*QueryMetricsArgs) String 

func (p *QueryMetricsArgs) String() string

func (*QueryMetricsArgs) Write 

func (p *QueryMetricsArgs) Write(oprot thrift.TProtocol) error

type QueryMetricsResult 

type QueryMetricsResult struct {
	Success []*TimeSeriesData        `thrift:"success,0" json:"success"`
	Se      *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewQueryMetricsResult 

func NewQueryMetricsResult() *QueryMetricsResult

func (*QueryMetricsResult) GetSe 

func (p *QueryMetricsResult) GetSe() *errors.ServiceException

func (*QueryMetricsResult) GetSuccess 

func (p *QueryMetricsResult) GetSuccess() []*TimeSeriesData

func (*QueryMetricsResult) IsSetSe 

func (p *QueryMetricsResult) IsSetSe() bool

func (*QueryMetricsResult) IsSetSuccess 

func (p *QueryMetricsResult) IsSetSuccess() bool

func (*QueryMetricsResult) Read 

func (p *QueryMetricsResult) Read(iprot thrift.TProtocol) error

func (*QueryMetricsResult) ReadField0 

func (p *QueryMetricsResult) ReadField0(iprot thrift.TProtocol) error

func (*QueryMetricsResult) ReadField1 

func (p *QueryMetricsResult) ReadField1(iprot thrift.TProtocol) error

func (*QueryMetricsResult) String 

func (p *QueryMetricsResult) String() string

func (*QueryMetricsResult) Write 

func (p *QueryMetricsResult) Write(oprot thrift.TProtocol) error

type QuotaInfo 

type QuotaInfo struct {
	AccountId              *string `thrift:"accountId,1" json:"accountId"`
	TableNum               *int32  `thrift:"tableNum,2" json:"tableNum"`
	TableNumUsed           *int32  `thrift:"tableNumUsed,3" json:"tableNumUsed"`
	Space                  *int64  `thrift:"space,4" json:"space"`
	SpaceUsed              *int64  `thrift:"spaceUsed,5" json:"spaceUsed"`
	ReadCapacity           *int64  `thrift:"readCapacity,6" json:"readCapacity"`
	ReadCapacityUsed       *int64  `thrift:"readCapacityUsed,7" json:"readCapacityUsed"`
	WriteCapacity          *int64  `thrift:"writeCapacity,8" json:"writeCapacity"`
	WriteCapacityUsed      *int64  `thrift:"writeCapacityUsed,9" json:"writeCapacityUsed"`
	SlaveReadCapacity      *int64  `thrift:"slaveReadCapacity,10" json:"slaveReadCapacity"`
	SlaveReadCapacityUsed  *int64  `thrift:"slaveReadCapacityUsed,11" json:"slaveReadCapacityUsed"`
	SlaveWriteCapacity     *int64  `thrift:"slaveWriteCapacity,12" json:"slaveWriteCapacity"`
	SlaveWriteCapacityUsed *int64  `thrift:"slaveWriteCapacityUsed,13" json:"slaveWriteCapacityUsed"`
}
var GetQuotaInfoResult_Success_DEFAULT *QuotaInfo

func NewQuotaInfo 

func NewQuotaInfo() *QuotaInfo

func (*QuotaInfo) GetAccountId 

func (p *QuotaInfo) GetAccountId() string

func (*QuotaInfo) GetReadCapacity 

func (p *QuotaInfo) GetReadCapacity() int64

func (*QuotaInfo) GetReadCapacityUsed 

func (p *QuotaInfo) GetReadCapacityUsed() int64

func (*QuotaInfo) GetSlaveReadCapacity 

func (p *QuotaInfo) GetSlaveReadCapacity() int64

func (*QuotaInfo) GetSlaveReadCapacityUsed 

func (p *QuotaInfo) GetSlaveReadCapacityUsed() int64

func (*QuotaInfo) GetSlaveWriteCapacity 

func (p *QuotaInfo) GetSlaveWriteCapacity() int64

func (*QuotaInfo) GetSlaveWriteCapacityUsed 

func (p *QuotaInfo) GetSlaveWriteCapacityUsed() int64

func (*QuotaInfo) GetSpace 

func (p *QuotaInfo) GetSpace() int64

func (*QuotaInfo) GetSpaceUsed 

func (p *QuotaInfo) GetSpaceUsed() int64

func (*QuotaInfo) GetTableNum 

func (p *QuotaInfo) GetTableNum() int32

func (*QuotaInfo) GetTableNumUsed 

func (p *QuotaInfo) GetTableNumUsed() int32

func (*QuotaInfo) GetWriteCapacity 

func (p *QuotaInfo) GetWriteCapacity() int64

func (*QuotaInfo) GetWriteCapacityUsed 

func (p *QuotaInfo) GetWriteCapacityUsed() int64

func (*QuotaInfo) IsSetAccountId 

func (p *QuotaInfo) IsSetAccountId() bool

func (*QuotaInfo) IsSetReadCapacity 

func (p *QuotaInfo) IsSetReadCapacity() bool

func (*QuotaInfo) IsSetReadCapacityUsed 

func (p *QuotaInfo) IsSetReadCapacityUsed() bool

func (*QuotaInfo) IsSetSlaveReadCapacity 

func (p *QuotaInfo) IsSetSlaveReadCapacity() bool

func (*QuotaInfo) IsSetSlaveReadCapacityUsed 

func (p *QuotaInfo) IsSetSlaveReadCapacityUsed() bool

func (*QuotaInfo) IsSetSlaveWriteCapacity 

func (p *QuotaInfo) IsSetSlaveWriteCapacity() bool

func (*QuotaInfo) IsSetSlaveWriteCapacityUsed 

func (p *QuotaInfo) IsSetSlaveWriteCapacityUsed() bool

func (*QuotaInfo) IsSetSpace 

func (p *QuotaInfo) IsSetSpace() bool

func (*QuotaInfo) IsSetSpaceUsed 

func (p *QuotaInfo) IsSetSpaceUsed() bool

func (*QuotaInfo) IsSetTableNum 

func (p *QuotaInfo) IsSetTableNum() bool

func (*QuotaInfo) IsSetTableNumUsed 

func (p *QuotaInfo) IsSetTableNumUsed() bool

func (*QuotaInfo) IsSetWriteCapacity 

func (p *QuotaInfo) IsSetWriteCapacity() bool

func (*QuotaInfo) IsSetWriteCapacityUsed 

func (p *QuotaInfo) IsSetWriteCapacityUsed() bool

func (*QuotaInfo) Read 

func (p *QuotaInfo) Read(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField1 

func (p *QuotaInfo) ReadField1(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField10 

func (p *QuotaInfo) ReadField10(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField11 

func (p *QuotaInfo) ReadField11(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField12 

func (p *QuotaInfo) ReadField12(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField13 

func (p *QuotaInfo) ReadField13(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField2 

func (p *QuotaInfo) ReadField2(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField3 

func (p *QuotaInfo) ReadField3(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField4 

func (p *QuotaInfo) ReadField4(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField5 

func (p *QuotaInfo) ReadField5(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField6 

func (p *QuotaInfo) ReadField6(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField7 

func (p *QuotaInfo) ReadField7(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField8 

func (p *QuotaInfo) ReadField8(iprot thrift.TProtocol) error

func (*QuotaInfo) ReadField9 

func (p *QuotaInfo) ReadField9(iprot thrift.TProtocol) error

func (*QuotaInfo) String 

func (p *QuotaInfo) String() string

func (*QuotaInfo) Write 

func (p *QuotaInfo) Write(oprot thrift.TProtocol) error

type RecoverTableArgs 

type RecoverTableArgs struct {
	SrcTableName  string `thrift:"srcTableName,1" json:"srcTableName"`
	DestTableName string `thrift:"destTableName,2" json:"destTableName"`
	TopicName     string `thrift:"topicName,3" json:"topicName"`
	Timestamp     int64  `thrift:"timestamp,4" json:"timestamp"`
}

func NewRecoverTableArgs 

func NewRecoverTableArgs() *RecoverTableArgs

func (*RecoverTableArgs) GetDestTableName 

func (p *RecoverTableArgs) GetDestTableName() string

func (*RecoverTableArgs) GetSrcTableName 

func (p *RecoverTableArgs) GetSrcTableName() string

func (*RecoverTableArgs) GetTimestamp 

func (p *RecoverTableArgs) GetTimestamp() int64

func (*RecoverTableArgs) GetTopicName 

func (p *RecoverTableArgs) GetTopicName() string

func (*RecoverTableArgs) Read 

func (p *RecoverTableArgs) Read(iprot thrift.TProtocol) error

func (*RecoverTableArgs) ReadField1 

func (p *RecoverTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*RecoverTableArgs) ReadField2 

func (p *RecoverTableArgs) ReadField2(iprot thrift.TProtocol) error

func (*RecoverTableArgs) ReadField3 

func (p *RecoverTableArgs) ReadField3(iprot thrift.TProtocol) error

func (*RecoverTableArgs) ReadField4 

func (p *RecoverTableArgs) ReadField4(iprot thrift.TProtocol) error

func (*RecoverTableArgs) String 

func (p *RecoverTableArgs) String() string

func (*RecoverTableArgs) Write 

func (p *RecoverTableArgs) Write(oprot thrift.TProtocol) error

type RecoverTableResult 

type RecoverTableResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewRecoverTableResult 

func NewRecoverTableResult() *RecoverTableResult

func (*RecoverTableResult) GetSe 

func (p *RecoverTableResult) GetSe() *errors.ServiceException

func (*RecoverTableResult) IsSetSe 

func (p *RecoverTableResult) IsSetSe() bool

func (*RecoverTableResult) Read 

func (p *RecoverTableResult) Read(iprot thrift.TProtocol) error

func (*RecoverTableResult) ReadField1 

func (p *RecoverTableResult) ReadField1(iprot thrift.TProtocol) error

func (*RecoverTableResult) String 

func (p *RecoverTableResult) String() string

func (*RecoverTableResult) Write 

func (p *RecoverTableResult) Write(oprot thrift.TProtocol) error

type RenameTableArgs 

type RenameTableArgs struct {
	SrcName  string `thrift:"srcName,1" json:"srcName"`
	DestName string `thrift:"destName,2" json:"destName"`
}

func NewRenameTableArgs 

func NewRenameTableArgs() *RenameTableArgs

func (*RenameTableArgs) GetDestName 

func (p *RenameTableArgs) GetDestName() string

func (*RenameTableArgs) GetSrcName 

func (p *RenameTableArgs) GetSrcName() string

func (*RenameTableArgs) Read 

func (p *RenameTableArgs) Read(iprot thrift.TProtocol) error

func (*RenameTableArgs) ReadField1 

func (p *RenameTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*RenameTableArgs) ReadField2 

func (p *RenameTableArgs) ReadField2(iprot thrift.TProtocol) error

func (*RenameTableArgs) String 

func (p *RenameTableArgs) String() string

func (*RenameTableArgs) Write 

func (p *RenameTableArgs) Write(oprot thrift.TProtocol) error

type RenameTableResult 

type RenameTableResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewRenameTableResult 

func NewRenameTableResult() *RenameTableResult

func (*RenameTableResult) GetSe 

func (p *RenameTableResult) GetSe() *errors.ServiceException

func (*RenameTableResult) IsSetSe 

func (p *RenameTableResult) IsSetSe() bool

func (*RenameTableResult) Read 

func (p *RenameTableResult) Read(iprot thrift.TProtocol) error

func (*RenameTableResult) ReadField1 

func (p *RenameTableResult) ReadField1(iprot thrift.TProtocol) error

func (*RenameTableResult) String 

func (p *RenameTableResult) String() string

func (*RenameTableResult) Write 

func (p *RenameTableResult) Write(oprot thrift.TProtocol) error

type RestoreSnapshotArgs 

type RestoreSnapshotArgs struct {
	TableName     string             `thrift:"tableName,1" json:"tableName"`
	SnapshotName  string             `thrift:"snapshotName,2" json:"snapshotName"`
	DestTableName string             `thrift:"destTableName,3" json:"destTableName"`
	SnapshotType  table.SnapshotType `thrift:"snapshotType,4" json:"snapshotType"`
}

func NewRestoreSnapshotArgs 

func NewRestoreSnapshotArgs() *RestoreSnapshotArgs

func (*RestoreSnapshotArgs) GetDestTableName 

func (p *RestoreSnapshotArgs) GetDestTableName() string

func (*RestoreSnapshotArgs) GetSnapshotName 

func (p *RestoreSnapshotArgs) GetSnapshotName() string

func (*RestoreSnapshotArgs) GetSnapshotType 

func (p *RestoreSnapshotArgs) GetSnapshotType() table.SnapshotType

func (*RestoreSnapshotArgs) GetTableName 

func (p *RestoreSnapshotArgs) GetTableName() string

func (*RestoreSnapshotArgs) Read 

func (p *RestoreSnapshotArgs) Read(iprot thrift.TProtocol) error

func (*RestoreSnapshotArgs) ReadField1 

func (p *RestoreSnapshotArgs) ReadField1(iprot thrift.TProtocol) error

func (*RestoreSnapshotArgs) ReadField2 

func (p *RestoreSnapshotArgs) ReadField2(iprot thrift.TProtocol) error

func (*RestoreSnapshotArgs) ReadField3 

func (p *RestoreSnapshotArgs) ReadField3(iprot thrift.TProtocol) error

func (*RestoreSnapshotArgs) ReadField4 

func (p *RestoreSnapshotArgs) ReadField4(iprot thrift.TProtocol) error

func (*RestoreSnapshotArgs) String 

func (p *RestoreSnapshotArgs) String() string

func (*RestoreSnapshotArgs) Write 

func (p *RestoreSnapshotArgs) Write(oprot thrift.TProtocol) error

type RestoreSnapshotResult 

type RestoreSnapshotResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewRestoreSnapshotResult 

func NewRestoreSnapshotResult() *RestoreSnapshotResult

func (*RestoreSnapshotResult) GetSe 

func (p *RestoreSnapshotResult) GetSe() *errors.ServiceException

func (*RestoreSnapshotResult) IsSetSe 

func (p *RestoreSnapshotResult) IsSetSe() bool

func (*RestoreSnapshotResult) Read 

func (p *RestoreSnapshotResult) Read(iprot thrift.TProtocol) error

func (*RestoreSnapshotResult) ReadField1 

func (p *RestoreSnapshotResult) ReadField1(iprot thrift.TProtocol) error

func (*RestoreSnapshotResult) String 

func (p *RestoreSnapshotResult) String() string

func (*RestoreSnapshotResult) Write 

func (p *RestoreSnapshotResult) Write(oprot thrift.TProtocol) error

type RestoreTableArgs 

type RestoreTableArgs struct {
	DeletedTableName string `thrift:"deletedTableName,1" json:"deletedTableName"`
	DestTableName    string `thrift:"destTableName,2" json:"destTableName"`
}

func NewRestoreTableArgs 

func NewRestoreTableArgs() *RestoreTableArgs

func (*RestoreTableArgs) GetDeletedTableName 

func (p *RestoreTableArgs) GetDeletedTableName() string

func (*RestoreTableArgs) GetDestTableName 

func (p *RestoreTableArgs) GetDestTableName() string

func (*RestoreTableArgs) Read 

func (p *RestoreTableArgs) Read(iprot thrift.TProtocol) error

func (*RestoreTableArgs) ReadField1 

func (p *RestoreTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*RestoreTableArgs) ReadField2 

func (p *RestoreTableArgs) ReadField2(iprot thrift.TProtocol) error

func (*RestoreTableArgs) String 

func (p *RestoreTableArgs) String() string

func (*RestoreTableArgs) Write 

func (p *RestoreTableArgs) Write(oprot thrift.TProtocol) error

type RestoreTableResult 

type RestoreTableResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewRestoreTableResult 

func NewRestoreTableResult() *RestoreTableResult

func (*RestoreTableResult) GetSe 

func (p *RestoreTableResult) GetSe() *errors.ServiceException

func (*RestoreTableResult) IsSetSe 

func (p *RestoreTableResult) IsSetSe() bool

func (*RestoreTableResult) Read 

func (p *RestoreTableResult) Read(iprot thrift.TProtocol) error

func (*RestoreTableResult) ReadField1 

func (p *RestoreTableResult) ReadField1(iprot thrift.TProtocol) error

func (*RestoreTableResult) String 

func (p *RestoreTableResult) String() string

func (*RestoreTableResult) Write 

func (p *RestoreTableResult) Write(oprot thrift.TProtocol) error

type SaveAppInfoArgs 

type SaveAppInfoArgs struct {
	AppInfo *AppInfo `thrift:"appInfo,1" json:"appInfo"`
}

func NewSaveAppInfoArgs 

func NewSaveAppInfoArgs() *SaveAppInfoArgs

func (*SaveAppInfoArgs) GetAppInfo 

func (p *SaveAppInfoArgs) GetAppInfo() *AppInfo

func (*SaveAppInfoArgs) IsSetAppInfo 

func (p *SaveAppInfoArgs) IsSetAppInfo() bool

func (*SaveAppInfoArgs) Read 

func (p *SaveAppInfoArgs) Read(iprot thrift.TProtocol) error

func (*SaveAppInfoArgs) ReadField1 

func (p *SaveAppInfoArgs) ReadField1(iprot thrift.TProtocol) error

func (*SaveAppInfoArgs) String 

func (p *SaveAppInfoArgs) String() string

func (*SaveAppInfoArgs) Write 

func (p *SaveAppInfoArgs) Write(oprot thrift.TProtocol) error

type SaveAppInfoResult 

type SaveAppInfoResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewSaveAppInfoResult 

func NewSaveAppInfoResult() *SaveAppInfoResult

func (*SaveAppInfoResult) GetSe 

func (p *SaveAppInfoResult) GetSe() *errors.ServiceException

func (*SaveAppInfoResult) IsSetSe 

func (p *SaveAppInfoResult) IsSetSe() bool

func (*SaveAppInfoResult) Read 

func (p *SaveAppInfoResult) Read(iprot thrift.TProtocol) error

func (*SaveAppInfoResult) ReadField1 

func (p *SaveAppInfoResult) ReadField1(iprot thrift.TProtocol) error

func (*SaveAppInfoResult) String 

func (p *SaveAppInfoResult) String() string

func (*SaveAppInfoResult) Write 

func (p *SaveAppInfoResult) Write(oprot thrift.TProtocol) error

type SetGrantRuleArgs 

type SetGrantRuleArgs struct {
	SpaceId   string     `thrift:"spaceId,1" json:"spaceId"`
	GrantRule *GrantRule `thrift:"grantRule,2" json:"grantRule"`
}

func NewSetGrantRuleArgs 

func NewSetGrantRuleArgs() *SetGrantRuleArgs

func (*SetGrantRuleArgs) GetGrantRule 

func (p *SetGrantRuleArgs) GetGrantRule() *GrantRule

func (*SetGrantRuleArgs) GetSpaceId 

func (p *SetGrantRuleArgs) GetSpaceId() string

func (*SetGrantRuleArgs) IsSetGrantRule 

func (p *SetGrantRuleArgs) IsSetGrantRule() bool

func (*SetGrantRuleArgs) Read 

func (p *SetGrantRuleArgs) Read(iprot thrift.TProtocol) error

func (*SetGrantRuleArgs) ReadField1 

func (p *SetGrantRuleArgs) ReadField1(iprot thrift.TProtocol) error

func (*SetGrantRuleArgs) ReadField2 

func (p *SetGrantRuleArgs) ReadField2(iprot thrift.TProtocol) error

func (*SetGrantRuleArgs) String 

func (p *SetGrantRuleArgs) String() string

func (*SetGrantRuleArgs) Write 

func (p *SetGrantRuleArgs) Write(oprot thrift.TProtocol) error

type SetGrantRuleResult 

type SetGrantRuleResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewSetGrantRuleResult 

func NewSetGrantRuleResult() *SetGrantRuleResult

func (*SetGrantRuleResult) GetSe 

func (p *SetGrantRuleResult) GetSe() *errors.ServiceException

func (*SetGrantRuleResult) IsSetSe 

func (p *SetGrantRuleResult) IsSetSe() bool

func (*SetGrantRuleResult) Read 

func (p *SetGrantRuleResult) Read(iprot thrift.TProtocol) error

func (*SetGrantRuleResult) ReadField1 

func (p *SetGrantRuleResult) ReadField1(iprot thrift.TProtocol) error

func (*SetGrantRuleResult) String 

func (p *SetGrantRuleResult) String() string

func (*SetGrantRuleResult) Write 

func (p *SetGrantRuleResult) Write(oprot thrift.TProtocol) error

type SetSpaceIdArgs 

type SetSpaceIdArgs struct {
	TableName string `thrift:"tableName,1" json:"tableName"`
	SpaceId   string `thrift:"spaceId,2" json:"spaceId"`
}

func NewSetSpaceIdArgs 

func NewSetSpaceIdArgs() *SetSpaceIdArgs

func (*SetSpaceIdArgs) GetSpaceId 

func (p *SetSpaceIdArgs) GetSpaceId() string

func (*SetSpaceIdArgs) GetTableName 

func (p *SetSpaceIdArgs) GetTableName() string

func (*SetSpaceIdArgs) Read 

func (p *SetSpaceIdArgs) Read(iprot thrift.TProtocol) error

func (*SetSpaceIdArgs) ReadField1 

func (p *SetSpaceIdArgs) ReadField1(iprot thrift.TProtocol) error

func (*SetSpaceIdArgs) ReadField2 

func (p *SetSpaceIdArgs) ReadField2(iprot thrift.TProtocol) error

func (*SetSpaceIdArgs) String 

func (p *SetSpaceIdArgs) String() string

func (*SetSpaceIdArgs) Write 

func (p *SetSpaceIdArgs) Write(oprot thrift.TProtocol) error

type SetSpaceIdResult 

type SetSpaceIdResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewSetSpaceIdResult 

func NewSetSpaceIdResult() *SetSpaceIdResult

func (*SetSpaceIdResult) GetSe 

func (p *SetSpaceIdResult) GetSe() *errors.ServiceException

func (*SetSpaceIdResult) IsSetSe 

func (p *SetSpaceIdResult) IsSetSe() bool

func (*SetSpaceIdResult) Read 

func (p *SetSpaceIdResult) Read(iprot thrift.TProtocol) error

func (*SetSpaceIdResult) ReadField1 

func (p *SetSpaceIdResult) ReadField1(iprot thrift.TProtocol) error

func (*SetSpaceIdResult) String 

func (p *SetSpaceIdResult) String() string

func (*SetSpaceIdResult) Write 

func (p *SetSpaceIdResult) Write(oprot thrift.TProtocol) error

type Snapshot 

type Snapshot struct {
	SnapshotName  *string              `thrift:"snapshotName,1" json:"snapshotName"`
	SnapshotState *table.SnapshotState `thrift:"snapshotState,2" json:"snapshotState"`
}

func NewSnapshot 

func NewSnapshot() *Snapshot

func (*Snapshot) GetSnapshotName 

func (p *Snapshot) GetSnapshotName() string

func (*Snapshot) GetSnapshotState 

func (p *Snapshot) GetSnapshotState() table.SnapshotState

func (*Snapshot) IsSetSnapshotName 

func (p *Snapshot) IsSetSnapshotName() bool

func (*Snapshot) IsSetSnapshotState 

func (p *Snapshot) IsSetSnapshotState() bool

func (*Snapshot) Read 

func (p *Snapshot) Read(iprot thrift.TProtocol) error

func (*Snapshot) ReadField1 

func (p *Snapshot) ReadField1(iprot thrift.TProtocol) error

func (*Snapshot) ReadField2 

func (p *Snapshot) ReadField2(iprot thrift.TProtocol) error

func (*Snapshot) String 

func (p *Snapshot) String() string

func (*Snapshot) Write 

func (p *Snapshot) Write(oprot thrift.TProtocol) error

type SnapshotTableArgs 

type SnapshotTableArgs struct {
	TableName    string `thrift:"tableName,1" json:"tableName"`
	SnapshotName string `thrift:"snapshotName,2" json:"snapshotName"`
}

func NewSnapshotTableArgs 

func NewSnapshotTableArgs() *SnapshotTableArgs

func (*SnapshotTableArgs) GetSnapshotName 

func (p *SnapshotTableArgs) GetSnapshotName() string

func (*SnapshotTableArgs) GetTableName 

func (p *SnapshotTableArgs) GetTableName() string

func (*SnapshotTableArgs) Read 

func (p *SnapshotTableArgs) Read(iprot thrift.TProtocol) error

func (*SnapshotTableArgs) ReadField1 

func (p *SnapshotTableArgs) ReadField1(iprot thrift.TProtocol) error

func (*SnapshotTableArgs) ReadField2 

func (p *SnapshotTableArgs) ReadField2(iprot thrift.TProtocol) error

func (*SnapshotTableArgs) String 

func (p *SnapshotTableArgs) String() string

func (*SnapshotTableArgs) Write 

func (p *SnapshotTableArgs) Write(oprot thrift.TProtocol) error

type SnapshotTableResult 

type SnapshotTableResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewSnapshotTableResult 

func NewSnapshotTableResult() *SnapshotTableResult

func (*SnapshotTableResult) GetSe 

func (p *SnapshotTableResult) GetSe() *errors.ServiceException

func (*SnapshotTableResult) IsSetSe 

func (p *SnapshotTableResult) IsSetSe() bool

func (*SnapshotTableResult) Read 

func (p *SnapshotTableResult) Read(iprot thrift.TProtocol) error

func (*SnapshotTableResult) ReadField1 

func (p *SnapshotTableResult) ReadField1(iprot thrift.TProtocol) error

func (*SnapshotTableResult) String 

func (p *SnapshotTableResult) String() string

func (*SnapshotTableResult) Write 

func (p *SnapshotTableResult) Write(oprot thrift.TProtocol) error

type SnapshotTableView 

type SnapshotTableView struct {
	TableName  *string `thrift:"tableName,1" json:"tableName"`
	TableExist *bool   `thrift:"tableExist,2" json:"tableExist"`
	DeleteTime int64   `thrift:"deleteTime,3" json:"deleteTime"`
}

func NewSnapshotTableView 

func NewSnapshotTableView() *SnapshotTableView

func (*SnapshotTableView) GetDeleteTime 

func (p *SnapshotTableView) GetDeleteTime() int64

func (*SnapshotTableView) GetTableExist 

func (p *SnapshotTableView) GetTableExist() bool

func (*SnapshotTableView) GetTableName 

func (p *SnapshotTableView) GetTableName() string

func (*SnapshotTableView) IsSetTableExist 

func (p *SnapshotTableView) IsSetTableExist() bool

func (*SnapshotTableView) IsSetTableName 

func (p *SnapshotTableView) IsSetTableName() bool

func (*SnapshotTableView) Read 

func (p *SnapshotTableView) Read(iprot thrift.TProtocol) error

func (*SnapshotTableView) ReadField1 

func (p *SnapshotTableView) ReadField1(iprot thrift.TProtocol) error

func (*SnapshotTableView) ReadField2 

func (p *SnapshotTableView) ReadField2(iprot thrift.TProtocol) error

func (*SnapshotTableView) ReadField3 

func (p *SnapshotTableView) ReadField3(iprot thrift.TProtocol) error

func (*SnapshotTableView) String 

func (p *SnapshotTableView) String() string

func (*SnapshotTableView) Write 

func (p *SnapshotTableView) Write(oprot thrift.TProtocol) error

type StreamCheckpoint 

type StreamCheckpoint struct {
	Timestamp       *int64                 `thrift:"timestamp,1" json:"timestamp"`
	TopicName       *string                `thrift:"topicName,2" json:"topicName"`
	PartitionStates []*TopicPartitionState `thrift:"partitionStates,3" json:"partitionStates"`
}
var GetCeilStreamCheckpointResult_Success_DEFAULT *StreamCheckpoint
var GetFloorStreamCheckpointResult_Success_DEFAULT *StreamCheckpoint
var GetLatestStreamCheckpointResult_Success_DEFAULT *StreamCheckpoint

func NewStreamCheckpoint 

func NewStreamCheckpoint() *StreamCheckpoint

func (*StreamCheckpoint) GetPartitionStates 

func (p *StreamCheckpoint) GetPartitionStates() []*TopicPartitionState

func (*StreamCheckpoint) GetTimestamp 

func (p *StreamCheckpoint) GetTimestamp() int64

func (*StreamCheckpoint) GetTopicName 

func (p *StreamCheckpoint) GetTopicName() string

func (*StreamCheckpoint) IsSetPartitionStates 

func (p *StreamCheckpoint) IsSetPartitionStates() bool

func (*StreamCheckpoint) IsSetTimestamp 

func (p *StreamCheckpoint) IsSetTimestamp() bool

func (*StreamCheckpoint) IsSetTopicName 

func (p *StreamCheckpoint) IsSetTopicName() bool

func (*StreamCheckpoint) Read 

func (p *StreamCheckpoint) Read(iprot thrift.TProtocol) error

func (*StreamCheckpoint) ReadField1 

func (p *StreamCheckpoint) ReadField1(iprot thrift.TProtocol) error

func (*StreamCheckpoint) ReadField2 

func (p *StreamCheckpoint) ReadField2(iprot thrift.TProtocol) error

func (*StreamCheckpoint) ReadField3 

func (p *StreamCheckpoint) ReadField3(iprot thrift.TProtocol) error

func (*StreamCheckpoint) String 

func (p *StreamCheckpoint) String() string

func (*StreamCheckpoint) Write 

func (p *StreamCheckpoint) Write(oprot thrift.TProtocol) error

type SubscribeEmailAlertArgs 

type SubscribeEmailAlertArgs struct {
	Email   string `thrift:"email,1" json:"email"`
	SpaceId string `thrift:"spaceId,2" json:"spaceId"`
}

func NewSubscribeEmailAlertArgs 

func NewSubscribeEmailAlertArgs() *SubscribeEmailAlertArgs

func (*SubscribeEmailAlertArgs) GetEmail 

func (p *SubscribeEmailAlertArgs) GetEmail() string

func (*SubscribeEmailAlertArgs) GetSpaceId 

func (p *SubscribeEmailAlertArgs) GetSpaceId() string

func (*SubscribeEmailAlertArgs) Read 

func (p *SubscribeEmailAlertArgs) Read(iprot thrift.TProtocol) error

func (*SubscribeEmailAlertArgs) ReadField1 

func (p *SubscribeEmailAlertArgs) ReadField1(iprot thrift.TProtocol) error

func (*SubscribeEmailAlertArgs) ReadField2 

func (p *SubscribeEmailAlertArgs) ReadField2(iprot thrift.TProtocol) error

func (*SubscribeEmailAlertArgs) String 

func (p *SubscribeEmailAlertArgs) String() string

func (*SubscribeEmailAlertArgs) Write 

func (p *SubscribeEmailAlertArgs) Write(oprot thrift.TProtocol) error

type SubscribeEmailAlertResult 

type SubscribeEmailAlertResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewSubscribeEmailAlertResult 

func NewSubscribeEmailAlertResult() *SubscribeEmailAlertResult

func (*SubscribeEmailAlertResult) GetSe 

func (p *SubscribeEmailAlertResult) GetSe() *errors.ServiceException

func (*SubscribeEmailAlertResult) IsSetSe 

func (p *SubscribeEmailAlertResult) IsSetSe() bool

func (*SubscribeEmailAlertResult) Read 

func (p *SubscribeEmailAlertResult) Read(iprot thrift.TProtocol) error

func (*SubscribeEmailAlertResult) ReadField1 

func (p *SubscribeEmailAlertResult) ReadField1(iprot thrift.TProtocol) error

func (*SubscribeEmailAlertResult) String 

func (p *SubscribeEmailAlertResult) String() string

func (*SubscribeEmailAlertResult) Write 

func (p *SubscribeEmailAlertResult) Write(oprot thrift.TProtocol) error

type SubscribePhoneAlertArgs 

type SubscribePhoneAlertArgs struct {
	PhoneNumber string `thrift:"phoneNumber,1" json:"phoneNumber"`
	SpaceId     string `thrift:"spaceId,2" json:"spaceId"`
}

func NewSubscribePhoneAlertArgs 

func NewSubscribePhoneAlertArgs() *SubscribePhoneAlertArgs

func (*SubscribePhoneAlertArgs) GetPhoneNumber 

func (p *SubscribePhoneAlertArgs) GetPhoneNumber() string

func (*SubscribePhoneAlertArgs) GetSpaceId 

func (p *SubscribePhoneAlertArgs) GetSpaceId() string

func (*SubscribePhoneAlertArgs) Read 

func (p *SubscribePhoneAlertArgs) Read(iprot thrift.TProtocol) error

func (*SubscribePhoneAlertArgs) ReadField1 

func (p *SubscribePhoneAlertArgs) ReadField1(iprot thrift.TProtocol) error

func (*SubscribePhoneAlertArgs) ReadField2 

func (p *SubscribePhoneAlertArgs) ReadField2(iprot thrift.TProtocol) error

func (*SubscribePhoneAlertArgs) String 

func (p *SubscribePhoneAlertArgs) String() string

func (*SubscribePhoneAlertArgs) Write 

func (p *SubscribePhoneAlertArgs) Write(oprot thrift.TProtocol) error

type SubscribePhoneAlertResult 

type SubscribePhoneAlertResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewSubscribePhoneAlertResult 

func NewSubscribePhoneAlertResult() *SubscribePhoneAlertResult

func (*SubscribePhoneAlertResult) GetSe 

func (p *SubscribePhoneAlertResult) GetSe() *errors.ServiceException

func (*SubscribePhoneAlertResult) IsSetSe 

func (p *SubscribePhoneAlertResult) IsSetSe() bool

func (*SubscribePhoneAlertResult) Read 

func (p *SubscribePhoneAlertResult) Read(iprot thrift.TProtocol) error

func (*SubscribePhoneAlertResult) ReadField1 

func (p *SubscribePhoneAlertResult) ReadField1(iprot thrift.TProtocol) error

func (*SubscribePhoneAlertResult) String 

func (p *SubscribePhoneAlertResult) String() string

func (*SubscribePhoneAlertResult) Write 

func (p *SubscribePhoneAlertResult) Write(oprot thrift.TProtocol) error

type TableSnapshots 

type TableSnapshots struct {
	TableName            *string     `thrift:"tableName,1" json:"tableName"`
	SysSnapshots         []*Snapshot `thrift:"sysSnapshots,2" json:"sysSnapshots"`
	UserSnapshots        []*Snapshot `thrift:"userSnapshots,3" json:"userSnapshots"`
	PitrSnapshots        []*Snapshot `thrift:"pitrSnapshots,4" json:"pitrSnapshots"`
	ColdStandBySnapshots []*Snapshot `thrift:"coldStandBySnapshots,5" json:"coldStandBySnapshots"`
}
var ListSnapshotsResult_Success_DEFAULT *TableSnapshots

func NewTableSnapshots 

func NewTableSnapshots() *TableSnapshots

func (*TableSnapshots) GetColdStandBySnapshots 

func (p *TableSnapshots) GetColdStandBySnapshots() []*Snapshot

func (*TableSnapshots) GetPitrSnapshots 

func (p *TableSnapshots) GetPitrSnapshots() []*Snapshot

func (*TableSnapshots) GetSysSnapshots 

func (p *TableSnapshots) GetSysSnapshots() []*Snapshot

func (*TableSnapshots) GetTableName 

func (p *TableSnapshots) GetTableName() string

func (*TableSnapshots) GetUserSnapshots 

func (p *TableSnapshots) GetUserSnapshots() []*Snapshot

func (*TableSnapshots) IsSetColdStandBySnapshots 

func (p *TableSnapshots) IsSetColdStandBySnapshots() bool

func (*TableSnapshots) IsSetPitrSnapshots 

func (p *TableSnapshots) IsSetPitrSnapshots() bool

func (*TableSnapshots) IsSetSysSnapshots 

func (p *TableSnapshots) IsSetSysSnapshots() bool

func (*TableSnapshots) IsSetTableName 

func (p *TableSnapshots) IsSetTableName() bool

func (*TableSnapshots) IsSetUserSnapshots 

func (p *TableSnapshots) IsSetUserSnapshots() bool

func (*TableSnapshots) Read 

func (p *TableSnapshots) Read(iprot thrift.TProtocol) error

func (*TableSnapshots) ReadField1 

func (p *TableSnapshots) ReadField1(iprot thrift.TProtocol) error

func (*TableSnapshots) ReadField2 

func (p *TableSnapshots) ReadField2(iprot thrift.TProtocol) error

func (*TableSnapshots) ReadField3 

func (p *TableSnapshots) ReadField3(iprot thrift.TProtocol) error

func (*TableSnapshots) ReadField4 

func (p *TableSnapshots) ReadField4(iprot thrift.TProtocol) error

func (*TableSnapshots) ReadField5 

func (p *TableSnapshots) ReadField5(iprot thrift.TProtocol) error

func (*TableSnapshots) String 

func (p *TableSnapshots) String() string

func (*TableSnapshots) Write 

func (p *TableSnapshots) Write(oprot thrift.TProtocol) error

type TimeSeriesData 

type TimeSeriesData struct {
	TableName  *string           `thrift:"tableName,1" json:"tableName"`
	MetricKey  *MetricKey        `thrift:"metricKey,2" json:"metricKey"`
	MetricType *MetricType       `thrift:"metricType,3" json:"metricType"`
	Data       map[int64]float64 `thrift:"data,4" json:"data"`
}
var QueryMetricResult_Success_DEFAULT *TimeSeriesData

func NewTimeSeriesData 

func NewTimeSeriesData() *TimeSeriesData

func (*TimeSeriesData) GetData 

func (p *TimeSeriesData) GetData() map[int64]float64

func (*TimeSeriesData) GetMetricKey 

func (p *TimeSeriesData) GetMetricKey() MetricKey

func (*TimeSeriesData) GetMetricType 

func (p *TimeSeriesData) GetMetricType() MetricType

func (*TimeSeriesData) GetTableName 

func (p *TimeSeriesData) GetTableName() string

func (*TimeSeriesData) IsSetData 

func (p *TimeSeriesData) IsSetData() bool

func (*TimeSeriesData) IsSetMetricKey 

func (p *TimeSeriesData) IsSetMetricKey() bool

func (*TimeSeriesData) IsSetMetricType 

func (p *TimeSeriesData) IsSetMetricType() bool

func (*TimeSeriesData) IsSetTableName 

func (p *TimeSeriesData) IsSetTableName() bool

func (*TimeSeriesData) Read 

func (p *TimeSeriesData) Read(iprot thrift.TProtocol) error

func (*TimeSeriesData) ReadField1 

func (p *TimeSeriesData) ReadField1(iprot thrift.TProtocol) error

func (*TimeSeriesData) ReadField2 

func (p *TimeSeriesData) ReadField2(iprot thrift.TProtocol) error

func (*TimeSeriesData) ReadField3 

func (p *TimeSeriesData) ReadField3(iprot thrift.TProtocol) error

func (*TimeSeriesData) ReadField4 

func (p *TimeSeriesData) ReadField4(iprot thrift.TProtocol) error

func (*TimeSeriesData) String 

func (p *TimeSeriesData) String() string

func (*TimeSeriesData) Write 

func (p *TimeSeriesData) Write(oprot thrift.TProtocol) error

type TimeSpanUnit 

type TimeSpanUnit int64

时间间隔单位，用于查询统计指标时的下采样 

const (
	TimeSpanUnit_SECONDS TimeSpanUnit = 1
	TimeSpanUnit_MINUTES TimeSpanUnit = 2
	TimeSpanUnit_HOURS   TimeSpanUnit = 3
)
var MetricQueryRequest_DownsampleTimeUnit_DEFAULT TimeSpanUnit

func TimeSpanUnitFromString 

func TimeSpanUnitFromString(s string) (TimeSpanUnit, error)

func TimeSpanUnitPtr 

func TimeSpanUnitPtr(v TimeSpanUnit) *TimeSpanUnit

func (TimeSpanUnit) String 

func (p TimeSpanUnit) String() string

type TopicPartitionState 

type TopicPartitionState struct {
	PartitionId *int32 `thrift:"partitionId,1" json:"partitionId"`
	Offset      *int64 `thrift:"offset,2" json:"offset"`
}

func NewTopicPartitionState 

func NewTopicPartitionState() *TopicPartitionState

func (*TopicPartitionState) GetOffset 

func (p *TopicPartitionState) GetOffset() int64

func (*TopicPartitionState) GetPartitionId 

func (p *TopicPartitionState) GetPartitionId() int32

func (*TopicPartitionState) IsSetOffset 

func (p *TopicPartitionState) IsSetOffset() bool

func (*TopicPartitionState) IsSetPartitionId 

func (p *TopicPartitionState) IsSetPartitionId() bool

func (*TopicPartitionState) Read 

func (p *TopicPartitionState) Read(iprot thrift.TProtocol) error

func (*TopicPartitionState) ReadField1 

func (p *TopicPartitionState) ReadField1(iprot thrift.TProtocol) error

func (*TopicPartitionState) ReadField2 

func (p *TopicPartitionState) ReadField2(iprot thrift.TProtocol) error

func (*TopicPartitionState) String 

func (p *TopicPartitionState) String() string

func (*TopicPartitionState) Write 

func (p *TopicPartitionState) Write(oprot thrift.TProtocol) error

type UnsubscribeEmailAlertArgs 

type UnsubscribeEmailAlertArgs struct {
	Email   string `thrift:"email,1" json:"email"`
	SpaceId string `thrift:"spaceId,2" json:"spaceId"`
}

func NewUnsubscribeEmailAlertArgs 

func NewUnsubscribeEmailAlertArgs() *UnsubscribeEmailAlertArgs

func (*UnsubscribeEmailAlertArgs) GetEmail 

func (p *UnsubscribeEmailAlertArgs) GetEmail() string

func (*UnsubscribeEmailAlertArgs) GetSpaceId 

func (p *UnsubscribeEmailAlertArgs) GetSpaceId() string

func (*UnsubscribeEmailAlertArgs) Read 

func (p *UnsubscribeEmailAlertArgs) Read(iprot thrift.TProtocol) error

func (*UnsubscribeEmailAlertArgs) ReadField1 

func (p *UnsubscribeEmailAlertArgs) ReadField1(iprot thrift.TProtocol) error

func (*UnsubscribeEmailAlertArgs) ReadField2 

func (p *UnsubscribeEmailAlertArgs) ReadField2(iprot thrift.TProtocol) error

func (*UnsubscribeEmailAlertArgs) String 

func (p *UnsubscribeEmailAlertArgs) String() string

func (*UnsubscribeEmailAlertArgs) Write 

func (p *UnsubscribeEmailAlertArgs) Write(oprot thrift.TProtocol) error

type UnsubscribeEmailAlertResult 

type UnsubscribeEmailAlertResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewUnsubscribeEmailAlertResult 

func NewUnsubscribeEmailAlertResult() *UnsubscribeEmailAlertResult

func (*UnsubscribeEmailAlertResult) GetSe 

func (p *UnsubscribeEmailAlertResult) GetSe() *errors.ServiceException

func (*UnsubscribeEmailAlertResult) IsSetSe 

func (p *UnsubscribeEmailAlertResult) IsSetSe() bool

func (*UnsubscribeEmailAlertResult) Read 

func (p *UnsubscribeEmailAlertResult) Read(iprot thrift.TProtocol) error

func (*UnsubscribeEmailAlertResult) ReadField1 

func (p *UnsubscribeEmailAlertResult) ReadField1(iprot thrift.TProtocol) error

func (*UnsubscribeEmailAlertResult) String 

func (p *UnsubscribeEmailAlertResult) String() string

func (*UnsubscribeEmailAlertResult) Write 

func (p *UnsubscribeEmailAlertResult) Write(oprot thrift.TProtocol) error

type UnsubscribePhoneAlertArgs 

type UnsubscribePhoneAlertArgs struct {
	PhoneNumber string `thrift:"phoneNumber,1" json:"phoneNumber"`
	SpaceId     string `thrift:"spaceId,2" json:"spaceId"`
}

func NewUnsubscribePhoneAlertArgs 

func NewUnsubscribePhoneAlertArgs() *UnsubscribePhoneAlertArgs

func (*UnsubscribePhoneAlertArgs) GetPhoneNumber 

func (p *UnsubscribePhoneAlertArgs) GetPhoneNumber() string

func (*UnsubscribePhoneAlertArgs) GetSpaceId 

func (p *UnsubscribePhoneAlertArgs) GetSpaceId() string

func (*UnsubscribePhoneAlertArgs) Read 

func (p *UnsubscribePhoneAlertArgs) Read(iprot thrift.TProtocol) error

func (*UnsubscribePhoneAlertArgs) ReadField1 

func (p *UnsubscribePhoneAlertArgs) ReadField1(iprot thrift.TProtocol) error

func (*UnsubscribePhoneAlertArgs) ReadField2 

func (p *UnsubscribePhoneAlertArgs) ReadField2(iprot thrift.TProtocol) error

func (*UnsubscribePhoneAlertArgs) String 

func (p *UnsubscribePhoneAlertArgs) String() string

func (*UnsubscribePhoneAlertArgs) Write 

func (p *UnsubscribePhoneAlertArgs) Write(oprot thrift.TProtocol) error

type UnsubscribePhoneAlertResult 

type UnsubscribePhoneAlertResult struct {
	Se *errors.ServiceException `thrift:"se,1" json:"se"`
}

func NewUnsubscribePhoneAlertResult 

func NewUnsubscribePhoneAlertResult() *UnsubscribePhoneAlertResult

func (*UnsubscribePhoneAlertResult) GetSe 

func (p *UnsubscribePhoneAlertResult) GetSe() *errors.ServiceException

func (*UnsubscribePhoneAlertResult) IsSetSe 

func (p *UnsubscribePhoneAlertResult) IsSetSe() bool

func (*UnsubscribePhoneAlertResult) Read 

func (p *UnsubscribePhoneAlertResult) Read(iprot thrift.TProtocol) error

func (*UnsubscribePhoneAlertResult) ReadField1 

func (p *UnsubscribePhoneAlertResult) ReadField1(iprot thrift.TProtocol) error

func (*UnsubscribePhoneAlertResult) String 

func (p *UnsubscribePhoneAlertResult) String() string

func (*UnsubscribePhoneAlertResult) Write 

func (p *UnsubscribePhoneAlertResult) Write(oprot thrift.TProtocol) error

Source Files

View all Source files

Directories

Path Synopsis

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.