qmgmt

package
v0.0.0-...-f382dc8 Latest Latest
Warning

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

 Go to latest Published: Nov 12, 2022 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Overview

Package qmgmt is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrCode_name = map[int32]string{
		0: "ERR_CODE_OK",
		1: "ERR_CODE_UNKNOWN",
		2: "ERR_CODE_ARGS_INVALID",
		3: "ERR_CODE_BAD_REQUEST",
		4: "ERR_CODE_UNAUTHORIZED",
		5: "ERR_CODE_INTERNAL",
		6: "ERR_CODE_BUSINESS",
	}
	ErrCode_value = map[string]int32{
		"ERR_CODE_OK":           0,
		"ERR_CODE_UNKNOWN":      1,
		"ERR_CODE_ARGS_INVALID": 2,
		"ERR_CODE_BAD_REQUEST":  3,
		"ERR_CODE_UNAUTHORIZED": 4,
		"ERR_CODE_INTERNAL":     5,
		"ERR_CODE_BUSINESS":     6,
	}
)

Enum value maps for ErrCode.

View Source 
var (
	IsDeleted_name = map[int32]string{
		0: "IsDeletedUnknown",
		1: "IsDeletedTrue",
		2: "IsDeletedFalse",
	}
	IsDeleted_value = map[string]int32{
		"IsDeletedUnknown": 0,
		"IsDeletedTrue":    1,
		"IsDeletedFalse":   2,
	}
)

Enum value maps for IsDeleted.

View Source 
var (
	ExchangeType_name = map[int32]string{
		0: "ExchangeTypeUnknown",
		1: "ExchangeTypeFanout",
		2: "ExchangeTypeTopic",
		3: "ExchangeTypeDirect",
		4: "ExchangeTypeHeaders",
	}
	ExchangeType_value = map[string]int32{
		"ExchangeTypeUnknown": 0,
		"ExchangeTypeFanout":  1,
		"ExchangeTypeTopic":   2,
		"ExchangeTypeDirect":  3,
		"ExchangeTypeHeaders": 4,
	}
)

Enum value maps for ExchangeType.

View Source 
var (
	Status_name = map[int32]string{
		0:  "StatusUnknown",
		10: "StatusStayOnline",
		20: "StatusOnline",
		30: "StatusActive",
		40: "StatusInActive",
		50: "StatusOffline",
		60: "StatusDownline",
	}
	Status_value = map[string]int32{
		"StatusUnknown":    0,
		"StatusStayOnline": 10,
		"StatusOnline":     20,
		"StatusActive":     30,
		"StatusInActive":   40,
		"StatusOffline":    50,
		"StatusDownline":   60,
	}
)

Enum value maps for Status.

View Source 
var (
	Priority_name = map[int32]string{
		0:  "PriorityUnknown",
		10: "PriorityGeneral",
		20: "PriorityImportant",
		30: "PriorityVeryImportant",
	}
	Priority_value = map[string]int32{
		"PriorityUnknown":       0,
		"PriorityGeneral":       10,
		"PriorityImportant":     20,
		"PriorityVeryImportant": 30,
	}
)

Enum value maps for Priority.

View Source 
var (
	BindingStatus_name = map[int32]string{
		0:  "BindingStatusUnknown",
		10: "BindingStatusStayBinding",
		20: "BindingStatusBinding",
		30: "BindingStatusToUnBind",
		40: "BindingStatusUnBinded",
	}
	BindingStatus_value = map[string]int32{
		"BindingStatusUnknown":     0,
		"BindingStatusStayBinding": 10,
		"BindingStatusBinding":     20,
		"BindingStatusToUnBind":    30,
		"BindingStatusUnBinded":    40,
	}
)

Enum value maps for BindingStatus.

View Source 
var (
	IsBoolean_name = map[int32]string{
		0: "IsBooleanUnknown",
		1: "IsBooleanTrue",
		2: "IsBooleanFalse",
	}
	IsBoolean_value = map[string]int32{
		"IsBooleanUnknown": 0,
		"IsBooleanTrue":    1,
		"IsBooleanFalse":   2,
	}
)

Enum value maps for IsBoolean.

View Source 
var (
	DLockType_name = map[int32]string{
		0:  "DLockTypeUnknown",
		10: "DLockTypeExchangeSync",
		20: "DLockTypeQueueSync",
		30: "DLockTypeBindingSync",
		40: "DLockTypeMetaDataSync",
		50: "DLockTypeAppMetaDataSync",
	}
	DLockType_value = map[string]int32{
		"DLockTypeUnknown":         0,
		"DLockTypeExchangeSync":    10,
		"DLockTypeQueueSync":       20,
		"DLockTypeBindingSync":     30,
		"DLockTypeMetaDataSync":    40,
		"DLockTypeAppMetaDataSync": 50,
	}
)

Enum value maps for DLockType.

View Source 
var (
	CollectionType_name = map[int32]string{
		0: "CollectionTypeUnknown",
		1: "CollectionTypeApp",
		2: "CollectionTypeQueue",
		3: "CollectionTypeExchange",
	}
	CollectionType_value = map[string]int32{
		"CollectionTypeUnknown":  0,
		"CollectionTypeApp":      1,
		"CollectionTypeQueue":    2,
		"CollectionTypeExchange": 3,
	}
)

Enum value maps for CollectionType.

View Source 
var (
	MessageBodySize_name = map[int32]string{
		0: "MessageBodySizeUnknown",
		1: "MessageBodySizeLess512B",
		2: "MessageBodySizeLess2KB",
		3: "MessageBodySizeLess16KB",
		4: "MessageBodySizeLess32KB",
	}
	MessageBodySize_value = map[string]int32{
		"MessageBodySizeUnknown":  0,
		"MessageBodySizeLess512B": 1,
		"MessageBodySizeLess2KB":  2,
		"MessageBodySizeLess16KB": 3,
		"MessageBodySizeLess32KB": 4,
	}
)

Enum value maps for MessageBodySize.

View Source 
var File_qmgmt_qmgmt_proto protoreflect.FileDescriptor
View Source 
var QMgmt_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "qmgmt.QMgmt",
	HandlerType: (*QMgmtServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SayHello",
			Handler:    _QMgmt_SayHello_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _QMgmt_Ping_Handler,
		},
		{
			MethodName: "NginxStatus",
			Handler:    _QMgmt_NginxStatus_Handler,
		},
		{
			MethodName: "HandlerSendBucSSOTokenDo",
			Handler:    _QMgmt_HandlerSendBucSSOTokenDo_Handler,
		},
		{
			MethodName: "LogOut",
			Handler:    _QMgmt_LogOut_Handler,
		},
		{
			MethodName: "LoginStatus",
			Handler:    _QMgmt_LoginStatus_Handler,
		},
		{
			MethodName: "UpdateDiamondExtConfig",
			Handler:    _QMgmt_UpdateDiamondExtConfig_Handler,
		},
		{
			MethodName: "DeleteDistributedLock",
			Handler:    _QMgmt_DeleteDistributedLock_Handler,
		},
		{
			MethodName: "SyncClusterMetaData",
			Handler:    _QMgmt_SyncClusterMetaData_Handler,
		},
		{
			MethodName: "DeleteAllData",
			Handler:    _QMgmt_DeleteAllData_Handler,
		},
		{
			MethodName: "ListMetaDataByAppName",
			Handler:    _QMgmt_ListMetaDataByAppName_Handler,
		},
		{
			MethodName: "ListExchangesByName",
			Handler:    _QMgmt_ListExchangesByName_Handler,
		},
		{
			MethodName: "GetExchangeByID",
			Handler:    _QMgmt_GetExchangeByID_Handler,
		},
		{
			MethodName: "ModifyExchangeAtribute",
			Handler:    _QMgmt_ModifyExchangeAtribute_Handler,
		},
		{
			MethodName: "ListQueuesByName",
			Handler:    _QMgmt_ListQueuesByName_Handler,
		},
		{
			MethodName: "GetQueueByID",
			Handler:    _QMgmt_GetQueueByID_Handler,
		},
		{
			MethodName: "ModifyQueueAtribute",
			Handler:    _QMgmt_ModifyQueueAtribute_Handler,
		},
		{
			MethodName: "MoveQueuesToNode",
			Handler:    _QMgmt_MoveQueuesToNode_Handler,
		},
		{
			MethodName: "MoveAmountQueuesToNode",
			Handler:    _QMgmt_MoveAmountQueuesToNode_Handler,
		},
		{
			MethodName: "SyncApps",
			Handler:    _QMgmt_SyncApps_Handler,
		},
		{
			MethodName: "ListApps",
			Handler:    _QMgmt_ListApps_Handler,
		},
		{
			MethodName: "GetAppDetailByID",
			Handler:    _QMgmt_GetAppDetailByID_Handler,
		},
		{
			MethodName: "ListMyselfApps",
			Handler:    _QMgmt_ListMyselfApps_Handler,
		},
		{
			MethodName: "ListCoreLevelApps",
			Handler:    _QMgmt_ListCoreLevelApps_Handler,
		},
		{
			MethodName: "ListMainLinkApps",
			Handler:    _QMgmt_ListMainLinkApps_Handler,
		},
		{
			MethodName: "SyncClusters",
			Handler:    _QMgmt_SyncClusters_Handler,
		},
		{
			MethodName: "ListClusterNames",
			Handler:    _QMgmt_ListClusterNames_Handler,
		},
		{
			MethodName: "ListClusters",
			Handler:    _QMgmt_ListClusters_Handler,
		},
		{
			MethodName: "GetVhostsByClusterName",
			Handler:    _QMgmt_GetVhostsByClusterName_Handler,
		},
		{
			MethodName: "CollectionResource",
			Handler:    _QMgmt_CollectionResource_Handler,
		},
		{
			MethodName: "CancelCollection",
			Handler:    _QMgmt_CancelCollection_Handler,
		},
		{
			MethodName: "ListCollection",
			Handler:    _QMgmt_ListCollection_Handler,
		},
		{
			MethodName: "ListAuditLog",
			Handler:    _QMgmt_ListAuditLog_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "qmgmt/qmgmt.proto",
}

QMgmt_ServiceDesc is the grpc.ServiceDesc for QMgmt service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterQMgmtHandler 

func RegisterQMgmtHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQMgmtHandler registers the http handlers for service QMgmt to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQMgmtHandlerClient 

func RegisterQMgmtHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QMgmtClient) error

RegisterQMgmtHandlerClient registers the http handlers for service QMgmt to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QMgmtClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QMgmtClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QMgmtClient" to call the correct interceptors.

func RegisterQMgmtHandlerFromEndpoint 

func RegisterQMgmtHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQMgmtHandlerFromEndpoint is same as RegisterQMgmtHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQMgmtHandlerServer 

func RegisterQMgmtHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QMgmtServer) error

RegisterQMgmtHandlerServer registers the http handlers for service QMgmt to "mux". UnaryRPC :call QMgmtServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQMgmtHandlerFromEndpoint instead.

func RegisterQMgmtServer 

func RegisterQMgmtServer(s grpc.ServiceRegistrar, srv QMgmtServer)

Types

type App 

type App struct {

	// 数据库 id
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 创建时间戳
	CreatedAt int64 `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// 更新时间
	UpdatedAt int64 `protobuf:"varint,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// 是否删除
	IsDelete bool `protobuf:"varint,4,opt,name=is_delete,json=isDelete,proto3" json:"is_delete,omitempty"`
	// 是否删除 文案
	IsDeleteDesc string `protobuf:"bytes,5,opt,name=is_delete_desc,json=isDeleteDesc,proto3" json:"is_delete_desc,omitempty"`
	// 应用 Aone 名称
	AppName string `protobuf:"bytes,10,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	// 应用 Aone ID
	AoneId string `protobuf:"bytes,11,opt,name=aone_id,json=aoneId,proto3" json:"aone_id,omitempty"`
	// 饿了么应用 ID
	AppId string `protobuf:"bytes,12,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// 应用 OwnerID
	OwnerId string `protobuf:"bytes,13,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"`
	// 应用资损等级
	CapitalLossLevel string `protobuf:"bytes,14,opt,name=capital_loss_level,json=capitalLossLevel,proto3" json:"capital_loss_level,omitempty"`
	// 应用高可用等级
	HighAvailabilityLevel string `` /* 127-byte string literal not displayed */
	// 应用状态
	Status string `protobuf:"bytes,16,opt,name=status,proto3" json:"status,omitempty"`
	// 应用分类
	Category string `protobuf:"bytes,17,opt,name=category,proto3" json:"category,omitempty"`
	// 是否是核心应用
	IsCritical bool `protobuf:"varint,18,opt,name=is_critical,json=isCritical,proto3" json:"is_critical,omitempty"`
	// 是否是虚拟应用
	IsVirtual bool `protobuf:"varint,19,opt,name=is_virtual,json=isVirtual,proto3" json:"is_virtual,omitempty"`
	// 当前用户是否收藏该应用
	IsCollection bool `protobuf:"varint,50,opt,name=is_collection,json=isCollection,proto3" json:"is_collection,omitempty"`
	// contains filtered or unexported fields
}

App 应用元数据信息

func (*App) Descriptor deprecated 

func (*App) Descriptor() ([]byte, []int)

Deprecated: Use App.ProtoReflect.Descriptor instead.

func (*App) GetAoneId 

func (x *App) GetAoneId() string

func (*App) GetAppId 

func (x *App) GetAppId() string

func (*App) GetAppName 

func (x *App) GetAppName() string

func (*App) GetCapitalLossLevel 

func (x *App) GetCapitalLossLevel() string

func (*App) GetCategory 

func (x *App) GetCategory() string

func (*App) GetCreatedAt 

func (x *App) GetCreatedAt() int64

func (*App) GetHighAvailabilityLevel 

func (x *App) GetHighAvailabilityLevel() string

func (*App) GetId 

func (x *App) GetId() uint64

func (*App) GetIsCollection 

func (x *App) GetIsCollection() bool

func (*App) GetIsCritical 

func (x *App) GetIsCritical() bool

func (*App) GetIsDelete 

func (x *App) GetIsDelete() bool

func (*App) GetIsDeleteDesc 

func (x *App) GetIsDeleteDesc() string

func (*App) GetIsVirtual 

func (x *App) GetIsVirtual() bool

func (*App) GetOwnerId 

func (x *App) GetOwnerId() string

func (*App) GetStatus 

func (x *App) GetStatus() string

func (*App) GetUpdatedAt 

func (x *App) GetUpdatedAt() int64

func (*App) ProtoMessage 

func (*App) ProtoMessage()

func (*App) ProtoReflect 

func (x *App) ProtoReflect() protoreflect.Message

func (*App) Reset 

func (x *App) Reset()

func (*App) String 

func (x *App) String() string

type AppInfo 

type AppInfo struct {

	// 应用基本信息
	App *App `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"` ////////  应用补充信息字段
	// Emonitor 监控链接
	EmonitorLink string `protobuf:"bytes,2,opt,name=emonitor_link,json=emonitorLink,proto3" json:"emonitor_link,omitempty"`
	// 应用 Aone 链接
	AoneLink string `protobuf:"bytes,3,opt,name=aone_link,json=aoneLink,proto3" json:"aone_link,omitempty"`
	// 应用 normandy 系统软链
	NormandyLink string `protobuf:"bytes,4,opt,name=normandy_link,json=normandyLink,proto3" json:"normandy_link,omitempty"`
	// 应用磐石系统软链
	KialiLink string `protobuf:"bytes,5,opt,name=kiali_link,json=kialiLink,proto3" json:"kiali_link,omitempty"`
	// 应用神算子系统软链
	SszLink string `protobuf:"bytes,6,opt,name=ssz_link,json=sszLink,proto3" json:"ssz_link,omitempty"`
	// contains filtered or unexported fields
}

AppInfo 应用详情 带补充信息字段

func (*AppInfo) Descriptor deprecated 

func (*AppInfo) Descriptor() ([]byte, []int)

Deprecated: Use AppInfo.ProtoReflect.Descriptor instead. 

func (x *AppInfo) GetAoneLink() string

func (*AppInfo) GetApp 

func (x *AppInfo) GetApp() *App
func (x *AppInfo) GetEmonitorLink() string
func (x *AppInfo) GetKialiLink() string
func (x *AppInfo) GetNormandyLink() string
func (x *AppInfo) GetSszLink() string

func (*AppInfo) ProtoMessage 

func (*AppInfo) ProtoMessage()

func (*AppInfo) ProtoReflect 

func (x *AppInfo) ProtoReflect() protoreflect.Message

func (*AppInfo) Reset 

func (x *AppInfo) Reset()

func (*AppInfo) String 

func (x *AppInfo) String() string

type AuditLog 

type AuditLog struct {

	// 数据库 id
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 创建时间戳
	CreatedAt int64 `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// 更新时间
	UpdatedAt int64 `protobuf:"varint,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// 是否删除
	IsDelete bool `protobuf:"varint,4,opt,name=is_delete,json=isDelete,proto3" json:"is_delete,omitempty"`
	// 是否删除 文案
	IsDeleteDesc string `protobuf:"bytes,5,opt,name=is_delete_desc,json=isDeleteDesc,proto3" json:"is_delete_desc,omitempty"`
	// 用户 EmpID
	EmpId string `protobuf:"bytes,6,opt,name=emp_id,json=empId,proto3" json:"emp_id,omitempty"`
	// 用户名称
	Account string `protobuf:"bytes,7,opt,name=account,proto3" json:"account,omitempty"`
	// API 操作名称
	OperatorName string `protobuf:"bytes,8,opt,name=operator_name,json=operatorName,proto3" json:"operator_name,omitempty"`
	// API 请求方式 [GET | PUT | POST | DELETE ...]
	RequestMethod string `protobuf:"bytes,9,opt,name=request_method,json=requestMethod,proto3" json:"request_method,omitempty"`
	// API 请求 URI 地址
	RequestUri string `protobuf:"bytes,10,opt,name=request_uri,json=requestUri,proto3" json:"request_uri,omitempty"`
	// 请求时间
	RequestAt int64 `protobuf:"varint,11,opt,name=request_at,json=requestAt,proto3" json:"request_at,omitempty"`
	// 请求耗时  单位: Microsecond
	Duration int64 `protobuf:"varint,12,opt,name=duration,proto3" json:"duration,omitempty"`
	// 请求报文
	RequestBody string `protobuf:"bytes,13,opt,name=request_body,json=requestBody,proto3" json:"request_body,omitempty"`
	// 响应报文
	ResponseBody string `protobuf:"bytes,14,opt,name=response_body,json=responseBody,proto3" json:"response_body,omitempty"`
	// contains filtered or unexported fields
}

AuditLog 操作升级日志

func (*AuditLog) Descriptor deprecated 

func (*AuditLog) Descriptor() ([]byte, []int)

Deprecated: Use AuditLog.ProtoReflect.Descriptor instead.

func (*AuditLog) GetAccount 

func (x *AuditLog) GetAccount() string

func (*AuditLog) GetCreatedAt 

func (x *AuditLog) GetCreatedAt() int64

func (*AuditLog) GetDuration 

func (x *AuditLog) GetDuration() int64

func (*AuditLog) GetEmpId 

func (x *AuditLog) GetEmpId() string

func (*AuditLog) GetId 

func (x *AuditLog) GetId() uint64

func (*AuditLog) GetIsDelete 

func (x *AuditLog) GetIsDelete() bool

func (*AuditLog) GetIsDeleteDesc 

func (x *AuditLog) GetIsDeleteDesc() string

func (*AuditLog) GetOperatorName 

func (x *AuditLog) GetOperatorName() string

func (*AuditLog) GetRequestAt 

func (x *AuditLog) GetRequestAt() int64

func (*AuditLog) GetRequestBody 

func (x *AuditLog) GetRequestBody() string

func (*AuditLog) GetRequestMethod 

func (x *AuditLog) GetRequestMethod() string

func (*AuditLog) GetRequestUri 

func (x *AuditLog) GetRequestUri() string

func (*AuditLog) GetResponseBody 

func (x *AuditLog) GetResponseBody() string

func (*AuditLog) GetUpdatedAt 

func (x *AuditLog) GetUpdatedAt() int64

func (*AuditLog) ProtoMessage 

func (*AuditLog) ProtoMessage()

func (*AuditLog) ProtoReflect 

func (x *AuditLog) ProtoReflect() protoreflect.Message

func (*AuditLog) Reset 

func (x *AuditLog) Reset()

func (*AuditLog) String 

func (x *AuditLog) String() string

type Binding 

type Binding struct {

	// 数据库 id
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 创建时间戳
	CreatedAt int64 `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// 更新时间
	UpdatedAt int64 `protobuf:"varint,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// 是否删除
	IsDelete bool `protobuf:"varint,4,opt,name=is_delete,json=isDelete,proto3" json:"is_delete,omitempty"`
	// 是否删除 文案
	IsDeleteDesc string `protobuf:"bytes,5,opt,name=is_delete_desc,json=isDeleteDesc,proto3" json:"is_delete_desc,omitempty"`
	// idc 机房 [zb1 | nt1 | ppe]
	Idc string `protobuf:"bytes,6,opt,name=idc,proto3" json:"idc,omitempty"`
	// MaxQ 集群名称
	Cluster string `protobuf:"bytes,7,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// MaxQ Vhost 名称
	Vhost string `protobuf:"bytes,8,opt,name=vhost,proto3" json:"vhost,omitempty"`
	// binding 源 Exchange ID
	// NOTE: 对应 MaxQ Binding source 字段, 所对应的 Exchange id
	ExchangeId uint64 `protobuf:"varint,9,opt,name=exchange_id,json=exchangeId,proto3" json:"exchange_id,omitempty"`
	// binding routing_key
	RoutingKey string `protobuf:"bytes,10,opt,name=routing_key,json=routingKey,proto3" json:"routing_key,omitempty"`
	// PropertiesKey is the md5 value of sorted arguments.
	// 是由 propertiesKey + '~' +  routingKey 组成
	PropertiesKey string `protobuf:"bytes,11,opt,name=properties_key,json=propertiesKey,proto3" json:"properties_key,omitempty"`
	// 参数 是由 amqp.Table 经过 json marshal 后的字符串
	Arguments string `protobuf:"bytes,12,opt,name=arguments,proto3" json:"arguments,omitempty"`
	// binding 目标 Exchange 或 Queue ID
	// NOTE: 对应 MaxQ Binding destination 字段, 所对应的 Exchange 或 Queue id
	DestinationId uint64 `protobuf:"varint,13,opt,name=destination_id,json=destinationId,proto3" json:"destination_id,omitempty"`
	// binding 目标类型 [exchange | queue]
	DestinationType string `protobuf:"bytes,14,opt,name=destination_type,json=destinationType,proto3" json:"destination_type,omitempty"`
	// binding 记录唯一索引 用于快速查询 Binding 记录
	// NOTE: 由 GenBindingIndex 生成  该字段不会主动更新
	BindingIndex string `protobuf:"bytes,15,opt,name=binding_index,json=bindingIndex,proto3" json:"binding_index,omitempty"`
	// 绑定状态
	Status BindingStatus `protobuf:"varint,16,opt,name=status,proto3,enum=qmgmt.BindingStatus" json:"status,omitempty"`
	// 绑定状态 文案
	StatusDesc string `protobuf:"bytes,17,opt,name=status_desc,json=statusDesc,proto3" json:"status_desc,omitempty"`
	// Binding 关系用途描述
	Description string `protobuf:"bytes,18,opt,name=description,proto3" json:"description,omitempty"`
	// 创建人工号
	CreateEmpId string `protobuf:"bytes,19,opt,name=create_emp_id,json=createEmpId,proto3" json:"create_emp_id,omitempty"`
	// 编辑修改人工号
	ModifyEmpId string `protobuf:"bytes,20,opt,name=modify_emp_id,json=modifyEmpId,proto3" json:"modify_emp_id,omitempty"`
	// contains filtered or unexported fields
}

Binding 绑定对象类型定义

func (*Binding) Descriptor deprecated 

func (*Binding) Descriptor() ([]byte, []int)

Deprecated: Use Binding.ProtoReflect.Descriptor instead.

func (*Binding) GetArguments 

func (x *Binding) GetArguments() string

func (*Binding) GetBindingIndex 

func (x *Binding) GetBindingIndex() string

func (*Binding) GetCluster 

func (x *Binding) GetCluster() string

func (*Binding) GetCreateEmpId 

func (x *Binding) GetCreateEmpId() string

func (*Binding) GetCreatedAt 

func (x *Binding) GetCreatedAt() int64

func (*Binding) GetDescription 

func (x *Binding) GetDescription() string

func (*Binding) GetDestinationId 

func (x *Binding) GetDestinationId() uint64

func (*Binding) GetDestinationType 

func (x *Binding) GetDestinationType() string

func (*Binding) GetExchangeId 

func (x *Binding) GetExchangeId() uint64

func (*Binding) GetId 

func (x *Binding) GetId() uint64

func (*Binding) GetIdc 

func (x *Binding) GetIdc() string

func (*Binding) GetIsDelete 

func (x *Binding) GetIsDelete() bool

func (*Binding) GetIsDeleteDesc 

func (x *Binding) GetIsDeleteDesc() string

func (*Binding) GetModifyEmpId 

func (x *Binding) GetModifyEmpId() string

func (*Binding) GetPropertiesKey 

func (x *Binding) GetPropertiesKey() string

func (*Binding) GetRoutingKey 

func (x *Binding) GetRoutingKey() string

func (*Binding) GetStatus 

func (x *Binding) GetStatus() BindingStatus

func (*Binding) GetStatusDesc 

func (x *Binding) GetStatusDesc() string

func (*Binding) GetUpdatedAt 

func (x *Binding) GetUpdatedAt() int64

func (*Binding) GetVhost 

func (x *Binding) GetVhost() string

func (*Binding) ProtoMessage 

func (*Binding) ProtoMessage()

func (*Binding) ProtoReflect 

func (x *Binding) ProtoReflect() protoreflect.Message

func (*Binding) Reset 

func (x *Binding) Reset()

func (*Binding) String 

func (x *Binding) String() string

type BindingInfo 

type BindingInfo struct {

	// Binding 基本信息
	B *Binding `protobuf:"bytes,1,opt,name=b,proto3" json:"b,omitempty"`
	// source exchange 信息(source 只能为 Exchange)
	SrcE *ExchangeInfo `protobuf:"bytes,2,opt,name=src_e,json=srcE,proto3" json:"src_e,omitempty"`
	// destination exchange 信息 // NOTE: 根据 DestinationType 是 queue 还是 exchange 来填充
	DestE *ExchangeInfo `protobuf:"bytes,3,opt,name=dest_e,json=destE,proto3" json:"dest_e,omitempty"`
	// destination queue 信息 // NOTE: 根据 DestinationType 是 queue 还是 exchange 来填充
	DestQ *QueueInfo `protobuf:"bytes,4,opt,name=dest_q,json=destQ,proto3" json:"dest_q,omitempty"`
	// contains filtered or unexported fields
}

BindingInfo 带额外附属信息的 Binding 模型定义

func (*BindingInfo) Descriptor deprecated 

func (*BindingInfo) Descriptor() ([]byte, []int)

Deprecated: Use BindingInfo.ProtoReflect.Descriptor instead.

func (*BindingInfo) GetB 

func (x *BindingInfo) GetB() *Binding

func (*BindingInfo) GetDestE 

func (x *BindingInfo) GetDestE() *ExchangeInfo

func (*BindingInfo) GetDestQ 

func (x *BindingInfo) GetDestQ() *QueueInfo

func (*BindingInfo) GetSrcE 

func (x *BindingInfo) GetSrcE() *ExchangeInfo

func (*BindingInfo) ProtoMessage 

func (*BindingInfo) ProtoMessage()

func (*BindingInfo) ProtoReflect 

func (x *BindingInfo) ProtoReflect() protoreflect.Message

func (*BindingInfo) Reset 

func (x *BindingInfo) Reset()

func (*BindingInfo) String 

func (x *BindingInfo) String() string

type BindingStatus 

type BindingStatus int32

BindingStatus 绑定状态枚举 

const (
	// 未知
	BindingStatus_BindingStatusUnknown BindingStatus = 0
	// 待绑定
	BindingStatus_BindingStatusStayBinding BindingStatus = 10
	// 已绑定
	BindingStatus_BindingStatusBinding BindingStatus = 20
	// 待解绑
	BindingStatus_BindingStatusToUnBind BindingStatus = 30
	// 已解绑
	BindingStatus_BindingStatusUnBinded BindingStatus = 40
)

func (BindingStatus) Descriptor 

func (BindingStatus) Descriptor() protoreflect.EnumDescriptor

func (BindingStatus) Enum 

func (x BindingStatus) Enum() *BindingStatus

func (BindingStatus) EnumDescriptor deprecated 

func (BindingStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use BindingStatus.Descriptor instead.

func (BindingStatus) Number 

func (x BindingStatus) Number() protoreflect.EnumNumber

func (BindingStatus) String 

func (x BindingStatus) String() string

func (BindingStatus) Type 

func (BindingStatus) Type() protoreflect.EnumType

type CancelCollectionReply 

type CancelCollectionReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message CancelCollection

func (*CancelCollectionReply) Descriptor deprecated 

func (*CancelCollectionReply) Descriptor() ([]byte, []int)

Deprecated: Use CancelCollectionReply.ProtoReflect.Descriptor instead.

func (*CancelCollectionReply) GetStatus 

func (x *CancelCollectionReply) GetStatus() *Error

func (*CancelCollectionReply) ProtoMessage 

func (*CancelCollectionReply) ProtoMessage()

func (*CancelCollectionReply) ProtoReflect 

func (x *CancelCollectionReply) ProtoReflect() protoreflect.Message

func (*CancelCollectionReply) Reset 

func (x *CancelCollectionReply) Reset()

func (*CancelCollectionReply) String 

func (x *CancelCollectionReply) String() string

type CancelCollectionRequest 

type CancelCollectionRequest struct {

	// 要取消收藏的资源类型
	Type CollectionType `protobuf:"varint,1,opt,name=type,proto3,enum=qmgmt.CollectionType" json:"type,omitempty"`
	// 要取消收藏的 资源 数据库 ID 列表
	Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

The response message CancelCollection

func (*CancelCollectionRequest) Descriptor deprecated 

func (*CancelCollectionRequest) Descriptor() ([]byte, []int)

Deprecated: Use CancelCollectionRequest.ProtoReflect.Descriptor instead.

func (*CancelCollectionRequest) GetIds 

func (x *CancelCollectionRequest) GetIds() []string

func (*CancelCollectionRequest) GetType 

func (x *CancelCollectionRequest) GetType() CollectionType

func (*CancelCollectionRequest) ProtoMessage 

func (*CancelCollectionRequest) ProtoMessage()

func (*CancelCollectionRequest) ProtoReflect 

func (x *CancelCollectionRequest) ProtoReflect() protoreflect.Message

func (*CancelCollectionRequest) Reset 

func (x *CancelCollectionRequest) Reset()

func (*CancelCollectionRequest) String 

func (x *CancelCollectionRequest) String() string

type Cluster 

type Cluster struct {

	// 数据库 id
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 创建时间戳
	CreatedAt int64 `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// 更新时间
	UpdatedAt int64 `protobuf:"varint,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// 是否删除
	IsDelete bool `protobuf:"varint,4,opt,name=is_delete,json=isDelete,proto3" json:"is_delete,omitempty"`
	// 是否删除 文案
	IsDeleteDesc string `protobuf:"bytes,5,opt,name=is_delete_desc,json=isDeleteDesc,proto3" json:"is_delete_desc,omitempty"`
	// Qboard 系统的 集群 ID
	QboardId uint64 `protobuf:"varint,6,opt,name=qboard_id,json=qboardId,proto3" json:"qboard_id,omitempty"`
	// 集群名称
	Name string `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	// 集群所属  IDC [zb1 | nt1 | ppe]
	Idc string `protobuf:"bytes,8,opt,name=idc,proto3" json:"idc,omitempty"`
	// 集群现有的节点数量
	NodeCount uint32 `protobuf:"varint,9,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
	// 集群 健康正常的 节点数量
	AliveCount uint32 `protobuf:"varint,10,opt,name=alive_count,json=aliveCount,proto3" json:"alive_count,omitempty"`
	// 集群 所有 User 总数
	UserCount uint32 `protobuf:"varint,11,opt,name=user_count,json=userCount,proto3" json:"user_count,omitempty"`
	// 集群 所有 User 名称   // NOTE: DB 采用 Text 类型
	Users string `protobuf:"bytes,12,opt,name=users,proto3" json:"users,omitempty"`
	// 集群 Vhost 总数
	VhostCount uint32 `protobuf:"varint,13,opt,name=vhost_count,json=vhostCount,proto3" json:"vhost_count,omitempty"`
	// 集群 所有 Vhost 名称   // NOTE: DB 采用 Text 类型
	Vhosts string `protobuf:"bytes,14,opt,name=vhosts,proto3" json:"vhosts,omitempty"`
	// MaxQ 集群后台管理页面页面链接
	DomainLink string `protobuf:"bytes,15,opt,name=domain_link,json=domainLink,proto3" json:"domain_link,omitempty"`
	// 当前集群是否是 BackUp 备份集群
	IsBackup bool `protobuf:"varint,16,opt,name=is_backup,json=isBackup,proto3" json:"is_backup,omitempty"`
	// 是否使用
	IsUsed bool `protobuf:"varint,17,opt,name=is_used,json=isUsed,proto3" json:"is_used,omitempty"`
	// 是否已经 Reset
	IsReset bool `protobuf:"varint,18,opt,name=is_reset,json=isReset,proto3" json:"is_reset,omitempty"`
	// 是否私有集群
	IsPrivate bool `protobuf:"varint,19,opt,name=is_private,json=isPrivate,proto3" json:"is_private,omitempty"`
	// MaxQ Server 版本
	Version string `protobuf:"bytes,20,opt,name=version,proto3" json:"version,omitempty"`
	// MaxQ Server 节点列表字符串 以逗号分隔  // NOTE: DB 采用 Text 类型
	Nodes string `protobuf:"bytes,21,opt,name=nodes,proto3" json:"nodes,omitempty"`
	// add sam port search in cluster page
	Ports string `protobuf:"bytes,22,opt,name=ports,proto3" json:"ports,omitempty"`
	// contains filtered or unexported fields
}

Cluster MaxQ Cluster 模型定义

func (*Cluster) Descriptor deprecated 

func (*Cluster) Descriptor() ([]byte, []int)

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetAliveCount 

func (x *Cluster) GetAliveCount() uint32

func (*Cluster) GetCreatedAt 

func (x *Cluster) GetCreatedAt() int64
func (x *Cluster) GetDomainLink() string

func (*Cluster) GetId 

func (x *Cluster) GetId() uint64

func (*Cluster) GetIdc 

func (x *Cluster) GetIdc() string

func (*Cluster) GetIsBackup 

func (x *Cluster) GetIsBackup() bool

func (*Cluster) GetIsDelete 

func (x *Cluster) GetIsDelete() bool

func (*Cluster) GetIsDeleteDesc 

func (x *Cluster) GetIsDeleteDesc() string

func (*Cluster) GetIsPrivate 

func (x *Cluster) GetIsPrivate() bool

func (*Cluster) GetIsReset 

func (x *Cluster) GetIsReset() bool

func (*Cluster) GetIsUsed 

func (x *Cluster) GetIsUsed() bool

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetNodeCount 

func (x *Cluster) GetNodeCount() uint32

func (*Cluster) GetNodes 

func (x *Cluster) GetNodes() string

func (*Cluster) GetPorts 

func (x *Cluster) GetPorts() string

func (*Cluster) GetQboardId 

func (x *Cluster) GetQboardId() uint64

func (*Cluster) GetUpdatedAt 

func (x *Cluster) GetUpdatedAt() int64

func (*Cluster) GetUserCount 

func (x *Cluster) GetUserCount() uint32

func (*Cluster) GetUsers 

func (x *Cluster) GetUsers() string

func (*Cluster) GetVersion 

func (x *Cluster) GetVersion() string

func (*Cluster) GetVhostCount 

func (x *Cluster) GetVhostCount() uint32

func (*Cluster) GetVhosts 

func (x *Cluster) GetVhosts() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

func (x *Cluster) ProtoReflect() protoreflect.Message

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

type Collection 

type Collection struct {

	// 数据库 id
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 创建时间戳
	CreatedAt int64 `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// 更新时间
	UpdatedAt int64 `protobuf:"varint,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// 是否删除
	IsDelete bool `protobuf:"varint,4,opt,name=is_delete,json=isDelete,proto3" json:"is_delete,omitempty"`
	// 是否删除 文案
	IsDeleteDesc string `protobuf:"bytes,5,opt,name=is_delete_desc,json=isDeleteDesc,proto3" json:"is_delete_desc,omitempty"`
	// 创建人工号
	CreateEmpId string `protobuf:"bytes,6,opt,name=create_emp_id,json=createEmpId,proto3" json:"create_emp_id,omitempty"`
	// 编辑修改人工号
	ModifyEmpId string `protobuf:"bytes,7,opt,name=modify_emp_id,json=modifyEmpId,proto3" json:"modify_emp_id,omitempty"`
	// 用户 EmpID
	EmpId string `protobuf:"bytes,8,opt,name=emp_id,json=empId,proto3" json:"emp_id,omitempty"`
	// 用户收藏的应用列表 ID  (ID 以逗号分隔)
	Apps string `protobuf:"bytes,9,opt,name=apps,proto3" json:"apps,omitempty"`
	// 用户收藏的 Queue 队列列表 ID (ID 以逗号分隔)
	Queues string `protobuf:"bytes,10,opt,name=queues,proto3" json:"queues,omitempty"`
	// 用户收藏的 Exchange 列表 ID  (ID 以逗号分隔)
	Exchanges string `protobuf:"bytes,11,opt,name=exchanges,proto3" json:"exchanges,omitempty"`
	// contains filtered or unexported fields
}

Collection 用户收藏的各种资源结构模型

func (*Collection) Descriptor deprecated 

func (*Collection) Descriptor() ([]byte, []int)

Deprecated: Use Collection.ProtoReflect.Descriptor instead.

func (*Collection) GetApps 

func (x *Collection) GetApps() string

func (*Collection) GetCreateEmpId 

func (x *Collection) GetCreateEmpId() string

func (*Collection) GetCreatedAt 

func (x *Collection) GetCreatedAt() int64

func (*Collection) GetEmpId 

func (x *Collection) GetEmpId() string

func (*Collection) GetExchanges 

func (x *Collection) GetExchanges() string

func (*Collection) GetId 

func (x *Collection) GetId() uint64

func (*Collection) GetIsDelete 

func (x *Collection) GetIsDelete() bool

func (*Collection) GetIsDeleteDesc 

func (x *Collection) GetIsDeleteDesc() string

func (*Collection) GetModifyEmpId 

func (x *Collection) GetModifyEmpId() string

func (*Collection) GetQueues 

func (x *Collection) GetQueues() string

func (*Collection) GetUpdatedAt 

func (x *Collection) GetUpdatedAt() int64

func (*Collection) ProtoMessage 

func (*Collection) ProtoMessage()

func (*Collection) ProtoReflect 

func (x *Collection) ProtoReflect() protoreflect.Message

func (*Collection) Reset 

func (x *Collection) Reset()

func (*Collection) String 

func (x *Collection) String() string

type CollectionInfo 

type CollectionInfo struct {

	// Collection 用户收藏基本信息
	C *Collection `protobuf:"bytes,1,opt,name=c,proto3" json:"c,omitempty"`
	// 应用详情列表
	Apps []*App `protobuf:"bytes,2,rep,name=apps,proto3" json:"apps,omitempty"`
	// 队列详情列表
	Queues []*Queue `protobuf:"bytes,3,rep,name=queues,proto3" json:"queues,omitempty"`
	// Exchange 详情列表
	Exchanges []*Exchange `protobuf:"bytes,4,rep,name=exchanges,proto3" json:"exchanges,omitempty"`
	// contains filtered or unexported fields
}

CollectionInfo 用户收藏信息详情

func (*CollectionInfo) Descriptor deprecated 

func (*CollectionInfo) Descriptor() ([]byte, []int)

Deprecated: Use CollectionInfo.ProtoReflect.Descriptor instead.

func (*CollectionInfo) GetApps 

func (x *CollectionInfo) GetApps() []*App

func (*CollectionInfo) GetC 

func (x *CollectionInfo) GetC() *Collection

func (*CollectionInfo) GetExchanges 

func (x *CollectionInfo) GetExchanges() []*Exchange

func (*CollectionInfo) GetQueues 

func (x *CollectionInfo) GetQueues() []*Queue

func (*CollectionInfo) ProtoMessage 

func (*CollectionInfo) ProtoMessage()

func (*CollectionInfo) ProtoReflect 

func (x *CollectionInfo) ProtoReflect() protoreflect.Message

func (*CollectionInfo) Reset 

func (x *CollectionInfo) Reset()

func (*CollectionInfo) String 

func (x *CollectionInfo) String() string

type CollectionResourceReply 

type CollectionResourceReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message CollectionResource

func (*CollectionResourceReply) Descriptor deprecated 

func (*CollectionResourceReply) Descriptor() ([]byte, []int)

Deprecated: Use CollectionResourceReply.ProtoReflect.Descriptor instead.

func (*CollectionResourceReply) GetStatus 

func (x *CollectionResourceReply) GetStatus() *Error

func (*CollectionResourceReply) ProtoMessage 

func (*CollectionResourceReply) ProtoMessage()

func (*CollectionResourceReply) ProtoReflect 

func (x *CollectionResourceReply) ProtoReflect() protoreflect.Message

func (*CollectionResourceReply) Reset 

func (x *CollectionResourceReply) Reset()

func (*CollectionResourceReply) String 

func (x *CollectionResourceReply) String() string

type CollectionResourceRequest 

type CollectionResourceRequest struct {

	// 要收藏的资源类型
	Type CollectionType `protobuf:"varint,1,opt,name=type,proto3,enum=qmgmt.CollectionType" json:"type,omitempty"`
	// 要收藏的 资源 数据库 ID 列表
	Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

The response message CollectionResource

func (*CollectionResourceRequest) Descriptor deprecated 

func (*CollectionResourceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CollectionResourceRequest.ProtoReflect.Descriptor instead.

func (*CollectionResourceRequest) GetIds 

func (x *CollectionResourceRequest) GetIds() []string

func (*CollectionResourceRequest) GetType 

func (x *CollectionResourceRequest) GetType() CollectionType

func (*CollectionResourceRequest) ProtoMessage 

func (*CollectionResourceRequest) ProtoMessage()

func (*CollectionResourceRequest) ProtoReflect 

func (x *CollectionResourceRequest) ProtoReflect() protoreflect.Message

func (*CollectionResourceRequest) Reset 

func (x *CollectionResourceRequest) Reset()

func (*CollectionResourceRequest) String 

func (x *CollectionResourceRequest) String() string

type CollectionType 

type CollectionType int32

CollectionType 用户收藏不同资源的类型 

const (
	// 未知
	CollectionType_CollectionTypeUnknown CollectionType = 0
	// 收藏应用
	CollectionType_CollectionTypeApp CollectionType = 1
	// 收藏 MaxQ 队列
	CollectionType_CollectionTypeQueue CollectionType = 2
	// 收藏 MaxQ Exchange
	CollectionType_CollectionTypeExchange CollectionType = 3
)

func (CollectionType) Descriptor 

func (CollectionType) Descriptor() protoreflect.EnumDescriptor

func (CollectionType) Enum 

func (x CollectionType) Enum() *CollectionType

func (CollectionType) EnumDescriptor deprecated 

func (CollectionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CollectionType.Descriptor instead.

func (CollectionType) Number 

func (x CollectionType) Number() protoreflect.EnumNumber

func (CollectionType) String 

func (x CollectionType) String() string

func (CollectionType) Type 

func (CollectionType) Type() protoreflect.EnumType

type DLockType 

type DLockType int32

DLockType 分布式锁类型 

const (
	// 未知
	DLockType_DLockTypeUnknown DLockType = 0
	// Exchange 同步锁
	DLockType_DLockTypeExchangeSync DLockType = 10
	// Queue 同步锁
	DLockType_DLockTypeQueueSync DLockType = 20
	// Binding 同步锁
	DLockType_DLockTypeBindingSync DLockType = 30
	// MetaData 元数据同步锁
	DLockType_DLockTypeMetaDataSync DLockType = 40
	// AppMetaData 应用元数据同步锁
	DLockType_DLockTypeAppMetaDataSync DLockType = 50
)

func (DLockType) Descriptor 

func (DLockType) Descriptor() protoreflect.EnumDescriptor

func (DLockType) Enum 

func (x DLockType) Enum() *DLockType

func (DLockType) EnumDescriptor deprecated 

func (DLockType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DLockType.Descriptor instead.

func (DLockType) Number 

func (x DLockType) Number() protoreflect.EnumNumber

func (DLockType) String 

func (x DLockType) String() string

func (DLockType) Type 

func (DLockType) Type() protoreflect.EnumType

type DeleteAllDataReply 

type DeleteAllDataReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 响应消息
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

The response message DeleteAllData

func (*DeleteAllDataReply) Descriptor deprecated 

func (*DeleteAllDataReply) Descriptor() ([]byte, []int)

Deprecated: Use DeleteAllDataReply.ProtoReflect.Descriptor instead.

func (*DeleteAllDataReply) GetMessage 

func (x *DeleteAllDataReply) GetMessage() string

func (*DeleteAllDataReply) GetStatus 

func (x *DeleteAllDataReply) GetStatus() *Error

func (*DeleteAllDataReply) ProtoMessage 

func (*DeleteAllDataReply) ProtoMessage()

func (*DeleteAllDataReply) ProtoReflect 

func (x *DeleteAllDataReply) ProtoReflect() protoreflect.Message

func (*DeleteAllDataReply) Reset 

func (x *DeleteAllDataReply) Reset()

func (*DeleteAllDataReply) String 

func (x *DeleteAllDataReply) String() string

type DeleteAllDataRequest 

type DeleteAllDataRequest struct {

	// 请求密码
	Password string `protobuf:"bytes,1,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

The request message DeleteAllData

func (*DeleteAllDataRequest) Descriptor deprecated 

func (*DeleteAllDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteAllDataRequest.ProtoReflect.Descriptor instead.

func (*DeleteAllDataRequest) GetPassword 

func (x *DeleteAllDataRequest) GetPassword() string

func (*DeleteAllDataRequest) ProtoMessage 

func (*DeleteAllDataRequest) ProtoMessage()

func (*DeleteAllDataRequest) ProtoReflect 

func (x *DeleteAllDataRequest) ProtoReflect() protoreflect.Message

func (*DeleteAllDataRequest) Reset 

func (x *DeleteAllDataRequest) Reset()

func (*DeleteAllDataRequest) String 

func (x *DeleteAllDataRequest) String() string

type DeleteDistributedLockReply 

type DeleteDistributedLockReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message DeleteDistributedLock

func (*DeleteDistributedLockReply) Descriptor deprecated 

func (*DeleteDistributedLockReply) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDistributedLockReply.ProtoReflect.Descriptor instead.

func (*DeleteDistributedLockReply) GetStatus 

func (x *DeleteDistributedLockReply) GetStatus() *Error

func (*DeleteDistributedLockReply) ProtoMessage 

func (*DeleteDistributedLockReply) ProtoMessage()

func (*DeleteDistributedLockReply) ProtoReflect 

func (x *DeleteDistributedLockReply) ProtoReflect() protoreflect.Message

func (*DeleteDistributedLockReply) Reset 

func (x *DeleteDistributedLockReply) Reset()

func (*DeleteDistributedLockReply) String 

func (x *DeleteDistributedLockReply) String() string

type DeleteDistributedLockRequest 

type DeleteDistributedLockRequest struct {

	// 分布式锁类型 code
	Code DLockType `protobuf:"varint,1,opt,name=code,proto3,enum=qmgmt.DLockType" json:"code,omitempty"`
	// contains filtered or unexported fields
}

The request message DeleteDistributedLock

func (*DeleteDistributedLockRequest) Descriptor deprecated 

func (*DeleteDistributedLockRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDistributedLockRequest.ProtoReflect.Descriptor instead.

func (*DeleteDistributedLockRequest) GetCode 

func (x *DeleteDistributedLockRequest) GetCode() DLockType

func (*DeleteDistributedLockRequest) ProtoMessage 

func (*DeleteDistributedLockRequest) ProtoMessage()

func (*DeleteDistributedLockRequest) ProtoReflect 

func (x *DeleteDistributedLockRequest) ProtoReflect() protoreflect.Message

func (*DeleteDistributedLockRequest) Reset 

func (x *DeleteDistributedLockRequest) Reset()

func (*DeleteDistributedLockRequest) String 

func (x *DeleteDistributedLockRequest) String() string

type ErrCode 

type ErrCode int32

ErrCode is the enums of error codes. 

const (
	// 成功
	ErrCode_ERR_CODE_OK ErrCode = 0
	// 未知错误
	ErrCode_ERR_CODE_UNKNOWN ErrCode = 1
	// 无效的请求参数
	ErrCode_ERR_CODE_ARGS_INVALID ErrCode = 2
	// 请求错误
	ErrCode_ERR_CODE_BAD_REQUEST ErrCode = 3
	// 未认证
	ErrCode_ERR_CODE_UNAUTHORIZED ErrCode = 4
	// 系统内部错误
	ErrCode_ERR_CODE_INTERNAL ErrCode = 5
	// 业务逻辑错误
	ErrCode_ERR_CODE_BUSINESS ErrCode = 6
)

func (ErrCode) Descriptor 

func (ErrCode) Descriptor() protoreflect.EnumDescriptor

func (ErrCode) Enum 

func (x ErrCode) Enum() *ErrCode

func (ErrCode) EnumDescriptor deprecated 

func (ErrCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ErrCode.Descriptor instead.

func (ErrCode) Number 

func (x ErrCode) Number() protoreflect.EnumNumber

func (ErrCode) String 

func (x ErrCode) String() string

func (ErrCode) Type 

func (ErrCode) Type() protoreflect.EnumType

type Error 

type Error struct {

	// Error code.
	Code ErrCode `protobuf:"varint,1,opt,name=code,proto3,enum=qmgmt.ErrCode" json:"code,omitempty"`
	// Error number
	Number uint32 `protobuf:"varint,2,opt,name=number,proto3" json:"number,omitempty"`
	// Error message (for human).
	Msg string `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// Hint msg (for developers).
	Hint string `protobuf:"bytes,4,opt,name=hint,proto3" json:"hint,omitempty"`
	// contains filtered or unexported fields
}

Error is the abstraction for error.

func (*Error) Descriptor deprecated 

func (*Error) Descriptor() ([]byte, []int)

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() ErrCode

func (*Error) GetHint 

func (x *Error) GetHint() string

func (*Error) GetMsg 

func (x *Error) GetMsg() string

func (*Error) GetNumber 

func (x *Error) GetNumber() uint32

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type Exchange 

type Exchange struct {

	// 数据库 id
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 创建时间戳
	CreatedAt int64 `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// 更新时间
	UpdatedAt int64 `protobuf:"varint,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// 是否删除
	IsDelete bool `protobuf:"varint,4,opt,name=is_delete,json=isDelete,proto3" json:"is_delete,omitempty"`
	// 是否删除 文案
	IsDeleteDesc string `protobuf:"bytes,5,opt,name=is_delete_desc,json=isDeleteDesc,proto3" json:"is_delete_desc,omitempty"`
	// idc 机房 [zb1 | nt1 | ppe]
	Idc string `protobuf:"bytes,6,opt,name=idc,proto3" json:"idc,omitempty"`
	// MaxQ 集群名称
	Cluster string `protobuf:"bytes,7,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// MaxQ Vhost 名称
	Vhost string `protobuf:"bytes,8,opt,name=vhost,proto3" json:"vhost,omitempty"`
	// Exchange 名称
	Name string `protobuf:"bytes,9,opt,name=Name,proto3" json:"Name,omitempty"`
	// Exchange 类型
	Type ExchangeType `protobuf:"varint,10,opt,name=type,proto3,enum=qmgmt.ExchangeType" json:"type,omitempty"`
	// Exchange 类型 文案
	TypeDesc string `protobuf:"bytes,11,opt,name=type_desc,json=typeDesc,proto3" json:"type_desc,omitempty"`
	// Exchange 状态
	Status Status `protobuf:"varint,12,opt,name=status,proto3,enum=qmgmt.Status" json:"status,omitempty"`
	// Exchange 状态 文案
	StatusDesc string `protobuf:"bytes,13,opt,name=status_desc,json=statusDesc,proto3" json:"status_desc,omitempty"`
	// 生产方应用名称
	// NOTE: 1.以逗号分隔   2.可以人工清理和修改, 默认自动同步
	PublisherApps string `protobuf:"bytes,14,opt,name=publisher_apps,json=publisherApps,proto3" json:"publisher_apps,omitempty"`
	// Exchange 重要等级    // NOTE: 人工设置
	Priority Priority `protobuf:"varint,15,opt,name=priority,proto3,enum=qmgmt.Priority" json:"priority,omitempty"`
	// Exchange 重要等级 文案
	PriorityDesc string `protobuf:"bytes,16,opt,name=priority_desc,json=priorityDesc,proto3" json:"priority_desc,omitempty"`
	// Exchange 用途描述备注 // NOTE: 人工设置
	Description string `protobuf:"bytes,17,opt,name=description,proto3" json:"description,omitempty"`
	// 发布消息速率 NOTE: 单位: tps/s  // NOTE: 人工设置
	PublisherRate uint32 `protobuf:"varint,18,opt,name=publisher_rate,json=publisherRate,proto3" json:"publisher_rate,omitempty"`
	// 发布者 hosts 数量 自动同步
	PublisherCount uint32 `protobuf:"varint,19,opt,name=publisher_count,json=publisherCount,proto3" json:"publisher_count,omitempty"`
	// 发布消息体大小  // NOTE: 人工设置
	MessageBodySize uint32 `protobuf:"varint,20,opt,name=message_body_size,json=messageBodySize,proto3" json:"message_body_size,omitempty"`
	// 发布消息体大小  文案
	MessageBodySizeDesc string `protobuf:"bytes,21,opt,name=message_body_size_desc,json=messageBodySizeDesc,proto3" json:"message_body_size_desc,omitempty"`
	// Exchange 属性
	Attribute *ExchangeAttribute `protobuf:"bytes,22,opt,name=attribute,proto3" json:"attribute,omitempty"`
	// 创建人工号
	CreateEmpId string `protobuf:"bytes,23,opt,name=create_emp_id,json=createEmpId,proto3" json:"create_emp_id,omitempty"`
	// 编辑修改人工号
	ModifyEmpId string `protobuf:"bytes,24,opt,name=modify_emp_id,json=modifyEmpId,proto3" json:"modify_emp_id,omitempty"`
	// 当前用户是否收藏该应用
	IsCollection bool `protobuf:"varint,50,opt,name=is_collection,json=isCollection,proto3" json:"is_collection,omitempty"`
	// contains filtered or unexported fields
}

Exchange Exchange 对象模型

func (*Exchange) Descriptor deprecated 

func (*Exchange) Descriptor() ([]byte, []int)

Deprecated: Use Exchange.ProtoReflect.Descriptor instead.

func (*Exchange) GetAttribute 

func (x *Exchange) GetAttribute() *ExchangeAttribute

func (*Exchange) GetCluster 

func (x *Exchange) GetCluster() string

func (*Exchange) GetCreateEmpId 

func (x *Exchange) GetCreateEmpId() string

func (*Exchange) GetCreatedAt 

func (x *Exchange) GetCreatedAt() int64

func (*Exchange) GetDescription 

func (x *Exchange) GetDescription() string

func (*Exchange) GetId 

func (x *Exchange) GetId() uint64

func (*Exchange) GetIdc 

func (x *Exchange) GetIdc() string

func (*Exchange) GetIsCollection 

func (x *Exchange) GetIsCollection() bool

func (*Exchange) GetIsDelete 

func (x *Exchange) GetIsDelete() bool

func (*Exchange) GetIsDeleteDesc 

func (x *Exchange) GetIsDeleteDesc() string

func (*Exchange) GetMessageBodySize 

func (x *Exchange) GetMessageBodySize() uint32

func (*Exchange) GetMessageBodySizeDesc 

func (x *Exchange) GetMessageBodySizeDesc() string

func (*Exchange) GetModifyEmpId 

func (x *Exchange) GetModifyEmpId() string

func (*Exchange) GetName 

func (x *Exchange) GetName() string

func (*Exchange) GetPriority 

func (x *Exchange) GetPriority() Priority

func (*Exchange) GetPriorityDesc 

func (x *Exchange) GetPriorityDesc() string

func (*Exchange) GetPublisherApps 

func (x *Exchange) GetPublisherApps() string

func (*Exchange) GetPublisherCount 

func (x *Exchange) GetPublisherCount() uint32

func (*Exchange) GetPublisherRate 

func (x *Exchange) GetPublisherRate() uint32

func (*Exchange) GetStatus 

func (x *Exchange) GetStatus() Status

func (*Exchange) GetStatusDesc 

func (x *Exchange) GetStatusDesc() string

func (*Exchange) GetType 

func (x *Exchange) GetType() ExchangeType

func (*Exchange) GetTypeDesc 

func (x *Exchange) GetTypeDesc() string

func (*Exchange) GetUpdatedAt 

func (x *Exchange) GetUpdatedAt() int64

func (*Exchange) GetVhost 

func (x *Exchange) GetVhost() string

func (*Exchange) ProtoMessage 

func (*Exchange) ProtoMessage()

func (*Exchange) ProtoReflect 

func (x *Exchange) ProtoReflect() protoreflect.Message

func (*Exchange) Reset 

func (x *Exchange) Reset()

func (*Exchange) String 

func (x *Exchange) String() string

type ExchangeAttribute 

type ExchangeAttribute struct {

	// 表示业务方是否填写了该 Exchange 描述属性
	// NOTE: 当该结构作为参数时，该字段忽略不填
	IsFill bool `protobuf:"varint,1,opt,name=is_fill,json=isFill,proto3" json:"is_fill,omitempty"`
	// 应用等级  [H1 | H2]
	// NOTE: 当该结构作为参数时，该字段忽略不填
	AppLevel string `protobuf:"bytes,2,opt,name=app_level,json=appLevel,proto3" json:"app_level,omitempty"`
	// 是否是主链路应用
	// NOTE: 当该结构作为参数时，该字段忽略不填
	IsMainLinkApp bool `protobuf:"varint,3,opt,name=is_main_link_app,json=isMainLinkApp,proto3" json:"is_main_link_app,omitempty"`
	// contains filtered or unexported fields
}

Exchange Attribute 多合一 attribute 属性

func (*ExchangeAttribute) Descriptor deprecated 

func (*ExchangeAttribute) Descriptor() ([]byte, []int)

Deprecated: Use ExchangeAttribute.ProtoReflect.Descriptor instead.

func (*ExchangeAttribute) GetAppLevel 

func (x *ExchangeAttribute) GetAppLevel() string

func (*ExchangeAttribute) GetIsFill 

func (x *ExchangeAttribute) GetIsFill() bool

func (*ExchangeAttribute) GetIsMainLinkApp 

func (x *ExchangeAttribute) GetIsMainLinkApp() bool

func (*ExchangeAttribute) ProtoMessage 

func (*ExchangeAttribute) ProtoMessage()

func (*ExchangeAttribute) ProtoReflect 

func (x *ExchangeAttribute) ProtoReflect() protoreflect.Message

func (*ExchangeAttribute) Reset 

func (x *ExchangeAttribute) Reset()

func (*ExchangeAttribute) String 

func (x *ExchangeAttribute) String() string

type ExchangeInfo 

type ExchangeInfo struct {

	// Exchange 基本信息
	E *Exchange `protobuf:"bytes,1,opt,name=e,proto3" json:"e,omitempty"`
	// Exchange 所有的绑定信息列表
	Bs []*BindingInfo `protobuf:"bytes,2,rep,name=bs,proto3" json:"bs,omitempty"`
	// Emonitor 监控链接
	EmonitorLink string `protobuf:"bytes,3,opt,name=emonitor_link,json=emonitorLink,proto3" json:"emonitor_link,omitempty"`
	// MaxQ 面板链接
	MaxqPanelLink string `protobuf:"bytes,4,opt,name=maxq_panel_link,json=maxqPanelLink,proto3" json:"maxq_panel_link,omitempty"`
	// contains filtered or unexported fields
}

ExchangeInfo 带额外附属信息的 Exchange 模型定义

func (*ExchangeInfo) Descriptor deprecated 

func (*ExchangeInfo) Descriptor() ([]byte, []int)

Deprecated: Use ExchangeInfo.ProtoReflect.Descriptor instead.

func (*ExchangeInfo) GetBs 

func (x *ExchangeInfo) GetBs() []*BindingInfo

func (*ExchangeInfo) GetE 

func (x *ExchangeInfo) GetE() *Exchange
func (x *ExchangeInfo) GetEmonitorLink() string
func (x *ExchangeInfo) GetMaxqPanelLink() string

func (*ExchangeInfo) ProtoMessage 

func (*ExchangeInfo) ProtoMessage()

func (*ExchangeInfo) ProtoReflect 

func (x *ExchangeInfo) ProtoReflect() protoreflect.Message

func (*ExchangeInfo) Reset 

func (x *ExchangeInfo) Reset()

func (*ExchangeInfo) String 

func (x *ExchangeInfo) String() string

type ExchangeType 

type ExchangeType int32

ExchangeType Exchange 类型 

const (
	// 未知
	ExchangeType_ExchangeTypeUnknown ExchangeType = 0
	// fanout
	ExchangeType_ExchangeTypeFanout ExchangeType = 1
	// topic
	ExchangeType_ExchangeTypeTopic ExchangeType = 2
	// direct
	ExchangeType_ExchangeTypeDirect ExchangeType = 3
	// headers
	ExchangeType_ExchangeTypeHeaders ExchangeType = 4
)

func (ExchangeType) Descriptor 

func (ExchangeType) Descriptor() protoreflect.EnumDescriptor

func (ExchangeType) Enum 

func (x ExchangeType) Enum() *ExchangeType

func (ExchangeType) EnumDescriptor deprecated 

func (ExchangeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExchangeType.Descriptor instead.

func (ExchangeType) Number 

func (x ExchangeType) Number() protoreflect.EnumNumber

func (ExchangeType) String 

func (x ExchangeType) String() string

func (ExchangeType) Type 

func (ExchangeType) Type() protoreflect.EnumType

type GetAppDetailByIDReply 

type GetAppDetailByIDReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 查询到的 App 信息
	App *AppInfo `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"`
	// contains filtered or unexported fields
}

The response message GetAppDetailByID

func (*GetAppDetailByIDReply) Descriptor deprecated 

func (*GetAppDetailByIDReply) Descriptor() ([]byte, []int)

Deprecated: Use GetAppDetailByIDReply.ProtoReflect.Descriptor instead.

func (*GetAppDetailByIDReply) GetApp 

func (x *GetAppDetailByIDReply) GetApp() *AppInfo

func (*GetAppDetailByIDReply) GetStatus 

func (x *GetAppDetailByIDReply) GetStatus() *Error

func (*GetAppDetailByIDReply) ProtoMessage 

func (*GetAppDetailByIDReply) ProtoMessage()

func (*GetAppDetailByIDReply) ProtoReflect 

func (x *GetAppDetailByIDReply) ProtoReflect() protoreflect.Message

func (*GetAppDetailByIDReply) Reset 

func (x *GetAppDetailByIDReply) Reset()

func (*GetAppDetailByIDReply) String 

func (x *GetAppDetailByIDReply) String() string

type GetAppDetailByIDRequest 

type GetAppDetailByIDRequest struct {

	// 应用数据库 ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

The request messaga GetAppDetailByID

func (*GetAppDetailByIDRequest) Descriptor deprecated 

func (*GetAppDetailByIDRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetAppDetailByIDRequest.ProtoReflect.Descriptor instead.

func (*GetAppDetailByIDRequest) GetId 

func (x *GetAppDetailByIDRequest) GetId() int64

func (*GetAppDetailByIDRequest) ProtoMessage 

func (*GetAppDetailByIDRequest) ProtoMessage()

func (*GetAppDetailByIDRequest) ProtoReflect 

func (x *GetAppDetailByIDRequest) ProtoReflect() protoreflect.Message

func (*GetAppDetailByIDRequest) Reset 

func (x *GetAppDetailByIDRequest) Reset()

func (*GetAppDetailByIDRequest) String 

func (x *GetAppDetailByIDRequest) String() string

type GetExchangeByIDReply 

type GetExchangeByIDReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 查询到的 Exchange 信息
	Exchange *ExchangeInfo `protobuf:"bytes,2,opt,name=exchange,proto3" json:"exchange,omitempty"`
	// contains filtered or unexported fields
}

The response message GetExchangeByID

func (*GetExchangeByIDReply) Descriptor deprecated 

func (*GetExchangeByIDReply) Descriptor() ([]byte, []int)

Deprecated: Use GetExchangeByIDReply.ProtoReflect.Descriptor instead.

func (*GetExchangeByIDReply) GetExchange 

func (x *GetExchangeByIDReply) GetExchange() *ExchangeInfo

func (*GetExchangeByIDReply) GetStatus 

func (x *GetExchangeByIDReply) GetStatus() *Error

func (*GetExchangeByIDReply) ProtoMessage 

func (*GetExchangeByIDReply) ProtoMessage()

func (*GetExchangeByIDReply) ProtoReflect 

func (x *GetExchangeByIDReply) ProtoReflect() protoreflect.Message

func (*GetExchangeByIDReply) Reset 

func (x *GetExchangeByIDReply) Reset()

func (*GetExchangeByIDReply) String 

func (x *GetExchangeByIDReply) String() string

type GetExchangeByIDRequest 

type GetExchangeByIDRequest struct {

	// Exchange 数据库 ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 是否请求获取额外相关信息 (Binding 信息)
	IsExtra bool `protobuf:"varint,2,opt,name=is_extra,json=isExtra,proto3" json:"is_extra,omitempty"`
	// 页信息
	Page *Pagination `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

The request message GetExchangeByID

func (*GetExchangeByIDRequest) Descriptor deprecated 

func (*GetExchangeByIDRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetExchangeByIDRequest.ProtoReflect.Descriptor instead.

func (*GetExchangeByIDRequest) GetId 

func (x *GetExchangeByIDRequest) GetId() int64

func (*GetExchangeByIDRequest) GetIsExtra 

func (x *GetExchangeByIDRequest) GetIsExtra() bool

func (*GetExchangeByIDRequest) GetPage 

func (x *GetExchangeByIDRequest) GetPage() *Pagination

func (*GetExchangeByIDRequest) ProtoMessage 

func (*GetExchangeByIDRequest) ProtoMessage()

func (*GetExchangeByIDRequest) ProtoReflect 

func (x *GetExchangeByIDRequest) ProtoReflect() protoreflect.Message

func (*GetExchangeByIDRequest) Reset 

func (x *GetExchangeByIDRequest) Reset()

func (*GetExchangeByIDRequest) String 

func (x *GetExchangeByIDRequest) String() string

type GetQueueByIDReply 

type GetQueueByIDReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 查询到的 Queue 信息
	Queue *QueueInfo `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

The response message GetQueueByID

func (*GetQueueByIDReply) Descriptor deprecated 

func (*GetQueueByIDReply) Descriptor() ([]byte, []int)

Deprecated: Use GetQueueByIDReply.ProtoReflect.Descriptor instead.

func (*GetQueueByIDReply) GetQueue 

func (x *GetQueueByIDReply) GetQueue() *QueueInfo

func (*GetQueueByIDReply) GetStatus 

func (x *GetQueueByIDReply) GetStatus() *Error

func (*GetQueueByIDReply) ProtoMessage 

func (*GetQueueByIDReply) ProtoMessage()

func (*GetQueueByIDReply) ProtoReflect 

func (x *GetQueueByIDReply) ProtoReflect() protoreflect.Message

func (*GetQueueByIDReply) Reset 

func (x *GetQueueByIDReply) Reset()

func (*GetQueueByIDReply) String 

func (x *GetQueueByIDReply) String() string

type GetQueueByIDRequest 

type GetQueueByIDRequest struct {

	// Queue 数据库 ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 是否请求获取额外相关信息 (Binding 信息)
	IsExtra bool `protobuf:"varint,2,opt,name=is_extra,json=isExtra,proto3" json:"is_extra,omitempty"`
	// 页信息
	Page *Pagination `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

The request message GetQueueByID

func (*GetQueueByIDRequest) Descriptor deprecated 

func (*GetQueueByIDRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetQueueByIDRequest.ProtoReflect.Descriptor instead.

func (*GetQueueByIDRequest) GetId 

func (x *GetQueueByIDRequest) GetId() int64

func (*GetQueueByIDRequest) GetIsExtra 

func (x *GetQueueByIDRequest) GetIsExtra() bool

func (*GetQueueByIDRequest) GetPage 

func (x *GetQueueByIDRequest) GetPage() *Pagination

func (*GetQueueByIDRequest) ProtoMessage 

func (*GetQueueByIDRequest) ProtoMessage()

func (*GetQueueByIDRequest) ProtoReflect 

func (x *GetQueueByIDRequest) ProtoReflect() protoreflect.Message

func (*GetQueueByIDRequest) Reset 

func (x *GetQueueByIDRequest) Reset()

func (*GetQueueByIDRequest) String 

func (x *GetQueueByIDRequest) String() string

type GetVhostsByClusterNameReply 

type GetVhostsByClusterNameReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// vhosts 总数
	Total uint32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// vhosts 列表
	Vhosts []string `protobuf:"bytes,3,rep,name=vhosts,proto3" json:"vhosts,omitempty"`
	// contains filtered or unexported fields
}

The response message GetVhostsByClusterName

func (*GetVhostsByClusterNameReply) Descriptor deprecated 

func (*GetVhostsByClusterNameReply) Descriptor() ([]byte, []int)

Deprecated: Use GetVhostsByClusterNameReply.ProtoReflect.Descriptor instead.

func (*GetVhostsByClusterNameReply) GetStatus 

func (x *GetVhostsByClusterNameReply) GetStatus() *Error

func (*GetVhostsByClusterNameReply) GetTotal 

func (x *GetVhostsByClusterNameReply) GetTotal() uint32

func (*GetVhostsByClusterNameReply) GetVhosts 

func (x *GetVhostsByClusterNameReply) GetVhosts() []string

func (*GetVhostsByClusterNameReply) ProtoMessage 

func (*GetVhostsByClusterNameReply) ProtoMessage()

func (*GetVhostsByClusterNameReply) ProtoReflect 

func (x *GetVhostsByClusterNameReply) ProtoReflect() protoreflect.Message

func (*GetVhostsByClusterNameReply) Reset 

func (x *GetVhostsByClusterNameReply) Reset()

func (*GetVhostsByClusterNameReply) String 

func (x *GetVhostsByClusterNameReply) String() string

type GetVhostsByClusterNameRequest 

type GetVhostsByClusterNameRequest struct {

	// 集群名称
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

The request message GetVhostsByClusterName

func (*GetVhostsByClusterNameRequest) Descriptor deprecated 

func (*GetVhostsByClusterNameRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetVhostsByClusterNameRequest.ProtoReflect.Descriptor instead.

func (*GetVhostsByClusterNameRequest) GetCluster 

func (x *GetVhostsByClusterNameRequest) GetCluster() string

func (*GetVhostsByClusterNameRequest) ProtoMessage 

func (*GetVhostsByClusterNameRequest) ProtoMessage()

func (*GetVhostsByClusterNameRequest) ProtoReflect 

func (x *GetVhostsByClusterNameRequest) ProtoReflect() protoreflect.Message

func (*GetVhostsByClusterNameRequest) Reset 

func (x *GetVhostsByClusterNameRequest) Reset()

func (*GetVhostsByClusterNameRequest) String 

func (x *GetVhostsByClusterNameRequest) String() string

type HandlerSendBucSSOTokenDoReply 

type HandlerSendBucSSOTokenDoReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message HandlerSendBucSSOTokenDo

func (*HandlerSendBucSSOTokenDoReply) Descriptor deprecated 

func (*HandlerSendBucSSOTokenDoReply) Descriptor() ([]byte, []int)

Deprecated: Use HandlerSendBucSSOTokenDoReply.ProtoReflect.Descriptor instead.

func (*HandlerSendBucSSOTokenDoReply) GetStatus 

func (x *HandlerSendBucSSOTokenDoReply) GetStatus() *Error

func (*HandlerSendBucSSOTokenDoReply) ProtoMessage 

func (*HandlerSendBucSSOTokenDoReply) ProtoMessage()

func (*HandlerSendBucSSOTokenDoReply) ProtoReflect 

func (x *HandlerSendBucSSOTokenDoReply) ProtoReflect() protoreflect.Message

func (*HandlerSendBucSSOTokenDoReply) Reset 

func (x *HandlerSendBucSSOTokenDoReply) Reset()

func (*HandlerSendBucSSOTokenDoReply) String 

func (x *HandlerSendBucSSOTokenDoReply) String() string

type HandlerSendBucSSOTokenDoRequest 

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

The request message HandlerSendBucSSOTokenDo

func (*HandlerSendBucSSOTokenDoRequest) Descriptor deprecated 

func (*HandlerSendBucSSOTokenDoRequest) Descriptor() ([]byte, []int)

Deprecated: Use HandlerSendBucSSOTokenDoRequest.ProtoReflect.Descriptor instead.

func (*HandlerSendBucSSOTokenDoRequest) ProtoMessage 

func (*HandlerSendBucSSOTokenDoRequest) ProtoMessage()

func (*HandlerSendBucSSOTokenDoRequest) ProtoReflect 

func (x *HandlerSendBucSSOTokenDoRequest) ProtoReflect() protoreflect.Message

func (*HandlerSendBucSSOTokenDoRequest) Reset 

func (x *HandlerSendBucSSOTokenDoRequest) Reset()

func (*HandlerSendBucSSOTokenDoRequest) String 

func (x *HandlerSendBucSSOTokenDoRequest) String() string

type HelloReply 

type HelloReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 响应消息
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the greetings

func (*HelloReply) Descriptor deprecated 

func (*HelloReply) Descriptor() ([]byte, []int)

Deprecated: Use HelloReply.ProtoReflect.Descriptor instead.

func (*HelloReply) GetMessage 

func (x *HelloReply) GetMessage() string

func (*HelloReply) GetStatus 

func (x *HelloReply) GetStatus() *Error

func (*HelloReply) ProtoMessage 

func (*HelloReply) ProtoMessage()

func (*HelloReply) ProtoReflect 

func (x *HelloReply) ProtoReflect() protoreflect.Message

func (*HelloReply) Reset 

func (x *HelloReply) Reset()

func (*HelloReply) String 

func (x *HelloReply) String() string

type HelloRequest 

type HelloRequest struct {

	//  名称
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the user's name

func (*HelloRequest) Descriptor deprecated 

func (*HelloRequest) Descriptor() ([]byte, []int)

Deprecated: Use HelloRequest.ProtoReflect.Descriptor instead.

func (*HelloRequest) GetName 

func (x *HelloRequest) GetName() string

func (*HelloRequest) ProtoMessage 

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) ProtoReflect 

func (x *HelloRequest) ProtoReflect() protoreflect.Message

func (*HelloRequest) Reset 

func (x *HelloRequest) Reset()

func (*HelloRequest) String 

func (x *HelloRequest) String() string

type IsBoolean 

type IsBoolean int32

IsBoolean 是否为真 

const (
	// 未知
	IsBoolean_IsBooleanUnknown IsBoolean = 0
	// 是
	IsBoolean_IsBooleanTrue IsBoolean = 1
	// 否
	IsBoolean_IsBooleanFalse IsBoolean = 2
)

func (IsBoolean) Descriptor 

func (IsBoolean) Descriptor() protoreflect.EnumDescriptor

func (IsBoolean) Enum 

func (x IsBoolean) Enum() *IsBoolean

func (IsBoolean) EnumDescriptor deprecated 

func (IsBoolean) EnumDescriptor() ([]byte, []int)

Deprecated: Use IsBoolean.Descriptor instead.

func (IsBoolean) Number 

func (x IsBoolean) Number() protoreflect.EnumNumber

func (IsBoolean) String 

func (x IsBoolean) String() string

func (IsBoolean) Type 

func (IsBoolean) Type() protoreflect.EnumType

type IsDeleted 

type IsDeleted int32

IsDelete 是否删除 

const (
	// 未知
	IsDeleted_IsDeletedUnknown IsDeleted = 0
	// 已逻辑删除
	IsDeleted_IsDeletedTrue IsDeleted = 1
	// 未逻辑删除
	IsDeleted_IsDeletedFalse IsDeleted = 2
)

func (IsDeleted) Descriptor 

func (IsDeleted) Descriptor() protoreflect.EnumDescriptor

func (IsDeleted) Enum 

func (x IsDeleted) Enum() *IsDeleted

func (IsDeleted) EnumDescriptor deprecated 

func (IsDeleted) EnumDescriptor() ([]byte, []int)

Deprecated: Use IsDeleted.Descriptor instead.

func (IsDeleted) Number 

func (x IsDeleted) Number() protoreflect.EnumNumber

func (IsDeleted) String 

func (x IsDeleted) String() string

func (IsDeleted) Type 

func (IsDeleted) Type() protoreflect.EnumType

type ListAppsReply 

type ListAppsReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 总数
	Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// 页信息
	Page *Pagination `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	// 查询到的 App 列表 信息
	Apps []*App `protobuf:"bytes,4,rep,name=apps,proto3" json:"apps,omitempty"`
	// contains filtered or unexported fields
}

The response message ListApps

func (*ListAppsReply) Descriptor deprecated 

func (*ListAppsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListAppsReply.ProtoReflect.Descriptor instead.

func (*ListAppsReply) GetApps 

func (x *ListAppsReply) GetApps() []*App

func (*ListAppsReply) GetPage 

func (x *ListAppsReply) GetPage() *Pagination

func (*ListAppsReply) GetStatus 

func (x *ListAppsReply) GetStatus() *Error

func (*ListAppsReply) GetTotal 

func (x *ListAppsReply) GetTotal() int64

func (*ListAppsReply) ProtoMessage 

func (*ListAppsReply) ProtoMessage()

func (*ListAppsReply) ProtoReflect 

func (x *ListAppsReply) ProtoReflect() protoreflect.Message

func (*ListAppsReply) Reset 

func (x *ListAppsReply) Reset()

func (*ListAppsReply) String 

func (x *ListAppsReply) String() string

type ListAppsRequest 

type ListAppsRequest struct {

	// 应用名称 NOTE: 支持模糊匹配
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// 页大小配置
	Page *Pagination `protobuf:"bytes,2,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

The request messaga ListApps

func (*ListAppsRequest) Descriptor deprecated 

func (*ListAppsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAppsRequest.ProtoReflect.Descriptor instead.

func (*ListAppsRequest) GetName 

func (x *ListAppsRequest) GetName() string

func (*ListAppsRequest) GetPage 

func (x *ListAppsRequest) GetPage() *Pagination

func (*ListAppsRequest) ProtoMessage 

func (*ListAppsRequest) ProtoMessage()

func (*ListAppsRequest) ProtoReflect 

func (x *ListAppsRequest) ProtoReflect() protoreflect.Message

func (*ListAppsRequest) Reset 

func (x *ListAppsRequest) Reset()

func (*ListAppsRequest) String 

func (x *ListAppsRequest) String() string

type ListAuditLogReply 

type ListAuditLogReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 总数
	Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// 页信息
	Page *Pagination `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	// 操作日志
	Logs []*AuditLog `protobuf:"bytes,4,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

The response message ListAuditLog

func (*ListAuditLogReply) Descriptor deprecated 

func (*ListAuditLogReply) Descriptor() ([]byte, []int)

Deprecated: Use ListAuditLogReply.ProtoReflect.Descriptor instead.

func (*ListAuditLogReply) GetLogs 

func (x *ListAuditLogReply) GetLogs() []*AuditLog

func (*ListAuditLogReply) GetPage 

func (x *ListAuditLogReply) GetPage() *Pagination

func (*ListAuditLogReply) GetStatus 

func (x *ListAuditLogReply) GetStatus() *Error

func (*ListAuditLogReply) GetTotal 

func (x *ListAuditLogReply) GetTotal() int64

func (*ListAuditLogReply) ProtoMessage 

func (*ListAuditLogReply) ProtoMessage()

func (*ListAuditLogReply) ProtoReflect 

func (x *ListAuditLogReply) ProtoReflect() protoreflect.Message

func (*ListAuditLogReply) Reset 

func (x *ListAuditLogReply) Reset()

func (*ListAuditLogReply) String 

func (x *ListAuditLogReply) String() string

type ListAuditLogRequest 

type ListAuditLogRequest struct {

	// 用户集团工号 EmpID
	EmpId string `protobuf:"bytes,1,opt,name=emp_id,json=empId,proto3" json:"emp_id,omitempty"`
	// 操作方法名称
	OperatorName string `protobuf:"bytes,2,opt,name=operator_name,json=operatorName,proto3" json:"operator_name,omitempty"`
	// 页信息
	Page *Pagination `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	// 时间范围
	TimeRange *TimeRange `protobuf:"bytes,4,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	// contains filtered or unexported fields
}

The response message ListAuditLog

func (*ListAuditLogRequest) Descriptor deprecated 

func (*ListAuditLogRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAuditLogRequest.ProtoReflect.Descriptor instead.

func (*ListAuditLogRequest) GetEmpId 

func (x *ListAuditLogRequest) GetEmpId() string

func (*ListAuditLogRequest) GetOperatorName 

func (x *ListAuditLogRequest) GetOperatorName() string

func (*ListAuditLogRequest) GetPage 

func (x *ListAuditLogRequest) GetPage() *Pagination

func (*ListAuditLogRequest) GetTimeRange 

func (x *ListAuditLogRequest) GetTimeRange() *TimeRange

func (*ListAuditLogRequest) ProtoMessage 

func (*ListAuditLogRequest) ProtoMessage()

func (*ListAuditLogRequest) ProtoReflect 

func (x *ListAuditLogRequest) ProtoReflect() protoreflect.Message

func (*ListAuditLogRequest) Reset 

func (x *ListAuditLogRequest) Reset()

func (*ListAuditLogRequest) String 

func (x *ListAuditLogRequest) String() string

type ListClusterNamesReply 

type ListClusterNamesReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// cluster 总数
	Total uint32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// Cluster 名称列表
	Clusters []string `protobuf:"bytes,3,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

The response message ListClusters

func (*ListClusterNamesReply) Descriptor deprecated 

func (*ListClusterNamesReply) Descriptor() ([]byte, []int)

Deprecated: Use ListClusterNamesReply.ProtoReflect.Descriptor instead.

func (*ListClusterNamesReply) GetClusters 

func (x *ListClusterNamesReply) GetClusters() []string

func (*ListClusterNamesReply) GetStatus 

func (x *ListClusterNamesReply) GetStatus() *Error

func (*ListClusterNamesReply) GetTotal 

func (x *ListClusterNamesReply) GetTotal() uint32

func (*ListClusterNamesReply) ProtoMessage 

func (*ListClusterNamesReply) ProtoMessage()

func (*ListClusterNamesReply) ProtoReflect 

func (x *ListClusterNamesReply) ProtoReflect() protoreflect.Message

func (*ListClusterNamesReply) Reset 

func (x *ListClusterNamesReply) Reset()

func (*ListClusterNamesReply) String 

func (x *ListClusterNamesReply) String() string

type ListClusterNamesRequest 

type ListClusterNamesRequest struct {

	// 机房 [al | albj | zb1 | nt1 | ppe | wg | xg | daily1]
	// NOTE: 为空则会获取所有集群的名称列表
	Idc string `protobuf:"bytes,1,opt,name=idc,proto3" json:"idc,omitempty"`
	// contains filtered or unexported fields
}

The request message ListClusterNames

func (*ListClusterNamesRequest) Descriptor deprecated 

func (*ListClusterNamesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListClusterNamesRequest.ProtoReflect.Descriptor instead.

func (*ListClusterNamesRequest) GetIdc 

func (x *ListClusterNamesRequest) GetIdc() string

func (*ListClusterNamesRequest) ProtoMessage 

func (*ListClusterNamesRequest) ProtoMessage()

func (*ListClusterNamesRequest) ProtoReflect 

func (x *ListClusterNamesRequest) ProtoReflect() protoreflect.Message

func (*ListClusterNamesRequest) Reset 

func (x *ListClusterNamesRequest) Reset()

func (*ListClusterNamesRequest) String 

func (x *ListClusterNamesRequest) String() string

type ListClustersReply 

type ListClustersReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// cluster 总数
	Total uint32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// Cluster 详情列表
	Clusters []*Cluster `protobuf:"bytes,3,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

The response message ListClusters

func (*ListClustersReply) Descriptor deprecated 

func (*ListClustersReply) Descriptor() ([]byte, []int)

Deprecated: Use ListClustersReply.ProtoReflect.Descriptor instead.

func (*ListClustersReply) GetClusters 

func (x *ListClustersReply) GetClusters() []*Cluster

func (*ListClustersReply) GetStatus 

func (x *ListClustersReply) GetStatus() *Error

func (*ListClustersReply) GetTotal 

func (x *ListClustersReply) GetTotal() uint32

func (*ListClustersReply) ProtoMessage 

func (*ListClustersReply) ProtoMessage()

func (*ListClustersReply) ProtoReflect 

func (x *ListClustersReply) ProtoReflect() protoreflect.Message

func (*ListClustersReply) Reset 

func (x *ListClustersReply) Reset()

func (*ListClustersReply) String 

func (x *ListClustersReply) String() string

type ListClustersRequest 

type ListClustersRequest struct {

	// 机房 [al | albj | zb1 | nt1 | ppe | wg | xg | daily1]
	// NOTE: 为空则会获取所有集群的名称列表
	Idc string `protobuf:"bytes,1,opt,name=idc,proto3" json:"idc,omitempty"`
	// contains filtered or unexported fields
}

The request message ListClusters

func (*ListClustersRequest) Descriptor deprecated 

func (*ListClustersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) GetIdc 

func (x *ListClustersRequest) GetIdc() string

func (*ListClustersRequest) ProtoMessage 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect 

func (x *ListClustersRequest) ProtoReflect() protoreflect.Message

func (*ListClustersRequest) Reset 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) String 

func (x *ListClustersRequest) String() string

type ListCollectionReply 

type ListCollectionReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 查询到的 App 列表 信息
	Apps []*App `protobuf:"bytes,2,rep,name=apps,proto3" json:"apps,omitempty"`
	// 查询到的队列详情列表
	Queues []*Queue `protobuf:"bytes,3,rep,name=queues,proto3" json:"queues,omitempty"`
	// 查询到的 Exchange 详情列表
	Exchanges []*Exchange `protobuf:"bytes,4,rep,name=exchanges,proto3" json:"exchanges,omitempty"`
	// contains filtered or unexported fields
}

The response message ListCollection

func (*ListCollectionReply) Descriptor deprecated 

func (*ListCollectionReply) Descriptor() ([]byte, []int)

Deprecated: Use ListCollectionReply.ProtoReflect.Descriptor instead.

func (*ListCollectionReply) GetApps 

func (x *ListCollectionReply) GetApps() []*App

func (*ListCollectionReply) GetExchanges 

func (x *ListCollectionReply) GetExchanges() []*Exchange

func (*ListCollectionReply) GetQueues 

func (x *ListCollectionReply) GetQueues() []*Queue

func (*ListCollectionReply) GetStatus 

func (x *ListCollectionReply) GetStatus() *Error

func (*ListCollectionReply) ProtoMessage 

func (*ListCollectionReply) ProtoMessage()

func (*ListCollectionReply) ProtoReflect 

func (x *ListCollectionReply) ProtoReflect() protoreflect.Message

func (*ListCollectionReply) Reset 

func (x *ListCollectionReply) Reset()

func (*ListCollectionReply) String 

func (x *ListCollectionReply) String() string

type ListCollectionRequest 

type ListCollectionRequest struct {

	// 要收藏的资源类型
	Type CollectionType `protobuf:"varint,1,opt,name=type,proto3,enum=qmgmt.CollectionType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

The request messaga ListCollection

func (*ListCollectionRequest) Descriptor deprecated 

func (*ListCollectionRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListCollectionRequest.ProtoReflect.Descriptor instead.

func (*ListCollectionRequest) GetType 

func (x *ListCollectionRequest) GetType() CollectionType

func (*ListCollectionRequest) ProtoMessage 

func (*ListCollectionRequest) ProtoMessage()

func (*ListCollectionRequest) ProtoReflect 

func (x *ListCollectionRequest) ProtoReflect() protoreflect.Message

func (*ListCollectionRequest) Reset 

func (x *ListCollectionRequest) Reset()

func (*ListCollectionRequest) String 

func (x *ListCollectionRequest) String() string

type ListCoreLevelAppsReply 

type ListCoreLevelAppsReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 总数
	Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// 查询到的 App 列表 信息
	Apps []*App `protobuf:"bytes,4,rep,name=apps,proto3" json:"apps,omitempty"`
	// contains filtered or unexported fields
}

The response message ListCoreLevelApps

func (*ListCoreLevelAppsReply) Descriptor deprecated 

func (*ListCoreLevelAppsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListCoreLevelAppsReply.ProtoReflect.Descriptor instead.

func (*ListCoreLevelAppsReply) GetApps 

func (x *ListCoreLevelAppsReply) GetApps() []*App

func (*ListCoreLevelAppsReply) GetStatus 

func (x *ListCoreLevelAppsReply) GetStatus() *Error

func (*ListCoreLevelAppsReply) GetTotal 

func (x *ListCoreLevelAppsReply) GetTotal() int64

func (*ListCoreLevelAppsReply) ProtoMessage 

func (*ListCoreLevelAppsReply) ProtoMessage()

func (*ListCoreLevelAppsReply) ProtoReflect 

func (x *ListCoreLevelAppsReply) ProtoReflect() protoreflect.Message

func (*ListCoreLevelAppsReply) Reset 

func (x *ListCoreLevelAppsReply) Reset()

func (*ListCoreLevelAppsReply) String 

func (x *ListCoreLevelAppsReply) String() string

type ListCoreLevelAppsRequest 

type ListCoreLevelAppsRequest struct {

	// 要获取的核心应用等级  [H1 | H2]
	Level string `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

The request messaga ListCoreLevelApps

func (*ListCoreLevelAppsRequest) Descriptor deprecated 

func (*ListCoreLevelAppsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListCoreLevelAppsRequest.ProtoReflect.Descriptor instead.

func (*ListCoreLevelAppsRequest) GetLevel 

func (x *ListCoreLevelAppsRequest) GetLevel() string

func (*ListCoreLevelAppsRequest) ProtoMessage 

func (*ListCoreLevelAppsRequest) ProtoMessage()

func (*ListCoreLevelAppsRequest) ProtoReflect 

func (x *ListCoreLevelAppsRequest) ProtoReflect() protoreflect.Message

func (*ListCoreLevelAppsRequest) Reset 

func (x *ListCoreLevelAppsRequest) Reset()

func (*ListCoreLevelAppsRequest) String 

func (x *ListCoreLevelAppsRequest) String() string

type ListExchangesByNameReply 

type ListExchangesByNameReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Exchange 总数
	Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// 页信息
	Page *Pagination `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	// 查询到的 Exchange 列表 信息
	Exchanges []*ExchangeInfo `protobuf:"bytes,4,rep,name=exchanges,proto3" json:"exchanges,omitempty"`
	// contains filtered or unexported fields
}

The response message ListExchangesByName

func (*ListExchangesByNameReply) Descriptor deprecated 

func (*ListExchangesByNameReply) Descriptor() ([]byte, []int)

Deprecated: Use ListExchangesByNameReply.ProtoReflect.Descriptor instead.

func (*ListExchangesByNameReply) GetExchanges 

func (x *ListExchangesByNameReply) GetExchanges() []*ExchangeInfo

func (*ListExchangesByNameReply) GetPage 

func (x *ListExchangesByNameReply) GetPage() *Pagination

func (*ListExchangesByNameReply) GetStatus 

func (x *ListExchangesByNameReply) GetStatus() *Error

func (*ListExchangesByNameReply) GetTotal 

func (x *ListExchangesByNameReply) GetTotal() int64

func (*ListExchangesByNameReply) ProtoMessage 

func (*ListExchangesByNameReply) ProtoMessage()

func (*ListExchangesByNameReply) ProtoReflect 

func (x *ListExchangesByNameReply) ProtoReflect() protoreflect.Message

func (*ListExchangesByNameReply) Reset 

func (x *ListExchangesByNameReply) Reset()

func (*ListExchangesByNameReply) String 

func (x *ListExchangesByNameReply) String() string

type ListExchangesByNameRequest 

type ListExchangesByNameRequest struct {

	// 集群名称
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Vhost 名称
	Vhost string `protobuf:"bytes,2,opt,name=vhost,proto3" json:"vhost,omitempty"`
	// Exchange 名称 NOTE: 支持模糊匹配
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// 是否精确匹配 Exchange name
	IsAccurate bool `protobuf:"varint,4,opt,name=is_accurate,json=isAccurate,proto3" json:"is_accurate,omitempty"`
	// 是否请求获取额外相关信息 (Queue & Binding 信息)
	IsExtra bool `protobuf:"varint,5,opt,name=is_extra,json=isExtra,proto3" json:"is_extra,omitempty"`
	// 页大小配置
	Page *Pagination `protobuf:"bytes,6,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

The request message ListExchangesByName

func (*ListExchangesByNameRequest) Descriptor deprecated 

func (*ListExchangesByNameRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListExchangesByNameRequest.ProtoReflect.Descriptor instead.

func (*ListExchangesByNameRequest) GetCluster 

func (x *ListExchangesByNameRequest) GetCluster() string

func (*ListExchangesByNameRequest) GetIsAccurate 

func (x *ListExchangesByNameRequest) GetIsAccurate() bool

func (*ListExchangesByNameRequest) GetIsExtra 

func (x *ListExchangesByNameRequest) GetIsExtra() bool

func (*ListExchangesByNameRequest) GetName 

func (x *ListExchangesByNameRequest) GetName() string

func (*ListExchangesByNameRequest) GetPage 

func (x *ListExchangesByNameRequest) GetPage() *Pagination

func (*ListExchangesByNameRequest) GetVhost 

func (x *ListExchangesByNameRequest) GetVhost() string

func (*ListExchangesByNameRequest) ProtoMessage 

func (*ListExchangesByNameRequest) ProtoMessage()

func (*ListExchangesByNameRequest) ProtoReflect 

func (x *ListExchangesByNameRequest) ProtoReflect() protoreflect.Message

func (*ListExchangesByNameRequest) Reset 

func (x *ListExchangesByNameRequest) Reset()

func (*ListExchangesByNameRequest) String 

func (x *ListExchangesByNameRequest) String() string

type ListMainLinkAppsReply 

type ListMainLinkAppsReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 总数
	Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// 查询到的 App 列表 信息
	Apps []*App `protobuf:"bytes,4,rep,name=apps,proto3" json:"apps,omitempty"`
	// contains filtered or unexported fields
}

The response message ListMainLinkApps

func (*ListMainLinkAppsReply) Descriptor deprecated 

func (*ListMainLinkAppsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListMainLinkAppsReply.ProtoReflect.Descriptor instead.

func (*ListMainLinkAppsReply) GetApps 

func (x *ListMainLinkAppsReply) GetApps() []*App

func (*ListMainLinkAppsReply) GetStatus 

func (x *ListMainLinkAppsReply) GetStatus() *Error

func (*ListMainLinkAppsReply) GetTotal 

func (x *ListMainLinkAppsReply) GetTotal() int64

func (*ListMainLinkAppsReply) ProtoMessage 

func (*ListMainLinkAppsReply) ProtoMessage()

func (*ListMainLinkAppsReply) ProtoReflect 

func (x *ListMainLinkAppsReply) ProtoReflect() protoreflect.Message

func (*ListMainLinkAppsReply) Reset 

func (x *ListMainLinkAppsReply) Reset()

func (*ListMainLinkAppsReply) String 

func (x *ListMainLinkAppsReply) String() string

type ListMainLinkAppsRequest 

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

The request messaga ListMainLinkApps

func (*ListMainLinkAppsRequest) Descriptor deprecated 

func (*ListMainLinkAppsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListMainLinkAppsRequest.ProtoReflect.Descriptor instead.

func (*ListMainLinkAppsRequest) ProtoMessage 

func (*ListMainLinkAppsRequest) ProtoMessage()

func (*ListMainLinkAppsRequest) ProtoReflect 

func (x *ListMainLinkAppsRequest) ProtoReflect() protoreflect.Message

func (*ListMainLinkAppsRequest) Reset 

func (x *ListMainLinkAppsRequest) Reset()

func (*ListMainLinkAppsRequest) String 

func (x *ListMainLinkAppsRequest) String() string

type ListMetaDataByAppNameReply 

type ListMetaDataByAppNameReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 队列总数
	QueueTotal int64 `protobuf:"varint,2,opt,name=queue_total,json=queueTotal,proto3" json:"queue_total,omitempty"`
	// Exchange 总数
	ExchangeTotal int64 `protobuf:"varint,3,opt,name=exchange_total,json=exchangeTotal,proto3" json:"exchange_total,omitempty"`
	// 页信息
	Page *Pagination `protobuf:"bytes,4,opt,name=page,proto3" json:"page,omitempty"`
	// 查询到的 Queue 列表 信息
	Queues []*QueueInfo `protobuf:"bytes,5,rep,name=queues,proto3" json:"queues,omitempty"`
	// 查询到的 Exchange 列表 信息
	Exchanges []*ExchangeInfo `protobuf:"bytes,6,rep,name=exchanges,proto3" json:"exchanges,omitempty"`
	// contains filtered or unexported fields
}

The response message ListMetaDataByAppName

func (*ListMetaDataByAppNameReply) Descriptor deprecated 

func (*ListMetaDataByAppNameReply) Descriptor() ([]byte, []int)

Deprecated: Use ListMetaDataByAppNameReply.ProtoReflect.Descriptor instead.

func (*ListMetaDataByAppNameReply) GetExchangeTotal 

func (x *ListMetaDataByAppNameReply) GetExchangeTotal() int64

func (*ListMetaDataByAppNameReply) GetExchanges 

func (x *ListMetaDataByAppNameReply) GetExchanges() []*ExchangeInfo

func (*ListMetaDataByAppNameReply) GetPage 

func (x *ListMetaDataByAppNameReply) GetPage() *Pagination

func (*ListMetaDataByAppNameReply) GetQueueTotal 

func (x *ListMetaDataByAppNameReply) GetQueueTotal() int64

func (*ListMetaDataByAppNameReply) GetQueues 

func (x *ListMetaDataByAppNameReply) GetQueues() []*QueueInfo

func (*ListMetaDataByAppNameReply) GetStatus 

func (x *ListMetaDataByAppNameReply) GetStatus() *Error

func (*ListMetaDataByAppNameReply) ProtoMessage 

func (*ListMetaDataByAppNameReply) ProtoMessage()

func (*ListMetaDataByAppNameReply) ProtoReflect 

func (x *ListMetaDataByAppNameReply) ProtoReflect() protoreflect.Message

func (*ListMetaDataByAppNameReply) Reset 

func (x *ListMetaDataByAppNameReply) Reset()

func (*ListMetaDataByAppNameReply) String 

func (x *ListMetaDataByAppNameReply) String() string

type ListMetaDataByAppNameRequest 

type ListMetaDataByAppNameRequest struct {

	// Aone 应用名称 NOTE: 支持模糊匹配
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// queue 所在 集群名称 NOTE: 可以为空
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// queue 所在 Vhost 名称 NOTE: 可以为空
	Vhost string `protobuf:"bytes,3,opt,name=vhost,proto3" json:"vhost,omitempty"`
	// 是否精确匹配应用名称
	IsAccurate bool `protobuf:"varint,4,opt,name=is_accurate,json=isAccurate,proto3" json:"is_accurate,omitempty"`
	// 是否请求获取额外相关信息 (Exchange & Binding 信息)
	IsExtra bool `protobuf:"varint,5,opt,name=is_extra,json=isExtra,proto3" json:"is_extra,omitempty"`
	// 页大小配置
	Page *Pagination `protobuf:"bytes,6,opt,name=page,proto3" json:"page,omitempty"`
	// 应用作为 生产者 或 消费者 获取元数据信息 [publisher | consumer | all]
	MetaDataType string `protobuf:"bytes,7,opt,name=meta_data_type,json=metaDataType,proto3" json:"meta_data_type,omitempty"`
	// contains filtered or unexported fields
}

The request message ListMetaDataByAppName

func (*ListMetaDataByAppNameRequest) Descriptor deprecated 

func (*ListMetaDataByAppNameRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListMetaDataByAppNameRequest.ProtoReflect.Descriptor instead.

func (*ListMetaDataByAppNameRequest) GetCluster 

func (x *ListMetaDataByAppNameRequest) GetCluster() string

func (*ListMetaDataByAppNameRequest) GetIsAccurate 

func (x *ListMetaDataByAppNameRequest) GetIsAccurate() bool

func (*ListMetaDataByAppNameRequest) GetIsExtra 

func (x *ListMetaDataByAppNameRequest) GetIsExtra() bool

func (*ListMetaDataByAppNameRequest) GetMetaDataType 

func (x *ListMetaDataByAppNameRequest) GetMetaDataType() string

func (*ListMetaDataByAppNameRequest) GetName 

func (x *ListMetaDataByAppNameRequest) GetName() string

func (*ListMetaDataByAppNameRequest) GetPage 

func (x *ListMetaDataByAppNameRequest) GetPage() *Pagination

func (*ListMetaDataByAppNameRequest) GetVhost 

func (x *ListMetaDataByAppNameRequest) GetVhost() string

func (*ListMetaDataByAppNameRequest) ProtoMessage 

func (*ListMetaDataByAppNameRequest) ProtoMessage()

func (*ListMetaDataByAppNameRequest) ProtoReflect 

func (x *ListMetaDataByAppNameRequest) ProtoReflect() protoreflect.Message

func (*ListMetaDataByAppNameRequest) Reset 

func (x *ListMetaDataByAppNameRequest) Reset()

func (*ListMetaDataByAppNameRequest) String 

func (x *ListMetaDataByAppNameRequest) String() string

type ListMyselfAppsReply 

type ListMyselfAppsReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 总数
	Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// 页信息
	Page *Pagination `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	// 查询到的 App 列表 信息
	Apps []*App `protobuf:"bytes,4,rep,name=apps,proto3" json:"apps,omitempty"`
	// contains filtered or unexported fields
}

The response message ListMyselfApps

func (*ListMyselfAppsReply) Descriptor deprecated 

func (*ListMyselfAppsReply) Descriptor() ([]byte, []int)

Deprecated: Use ListMyselfAppsReply.ProtoReflect.Descriptor instead.

func (*ListMyselfAppsReply) GetApps 

func (x *ListMyselfAppsReply) GetApps() []*App

func (*ListMyselfAppsReply) GetPage 

func (x *ListMyselfAppsReply) GetPage() *Pagination

func (*ListMyselfAppsReply) GetStatus 

func (x *ListMyselfAppsReply) GetStatus() *Error

func (*ListMyselfAppsReply) GetTotal 

func (x *ListMyselfAppsReply) GetTotal() int64

func (*ListMyselfAppsReply) ProtoMessage 

func (*ListMyselfAppsReply) ProtoMessage()

func (*ListMyselfAppsReply) ProtoReflect 

func (x *ListMyselfAppsReply) ProtoReflect() protoreflect.Message

func (*ListMyselfAppsReply) Reset 

func (x *ListMyselfAppsReply) Reset()

func (*ListMyselfAppsReply) String 

func (x *ListMyselfAppsReply) String() string

type ListMyselfAppsRequest 

type ListMyselfAppsRequest struct {

	// 页大小配置
	Page *Pagination `protobuf:"bytes,1,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

The request messaga ListMyselfApps

func (*ListMyselfAppsRequest) Descriptor deprecated 

func (*ListMyselfAppsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListMyselfAppsRequest.ProtoReflect.Descriptor instead.

func (*ListMyselfAppsRequest) GetPage 

func (x *ListMyselfAppsRequest) GetPage() *Pagination

func (*ListMyselfAppsRequest) ProtoMessage 

func (*ListMyselfAppsRequest) ProtoMessage()

func (*ListMyselfAppsRequest) ProtoReflect 

func (x *ListMyselfAppsRequest) ProtoReflect() protoreflect.Message

func (*ListMyselfAppsRequest) Reset 

func (x *ListMyselfAppsRequest) Reset()

func (*ListMyselfAppsRequest) String 

func (x *ListMyselfAppsRequest) String() string

type ListQueuesByNameReply 

type ListQueuesByNameReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 队列总数
	Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// 页信息
	Page *Pagination `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	// 查询到的 Queue 列表 信息
	Queues []*QueueInfo `protobuf:"bytes,4,rep,name=queues,proto3" json:"queues,omitempty"`
	// contains filtered or unexported fields
}

The response message ListQueuesByName

func (*ListQueuesByNameReply) Descriptor deprecated 

func (*ListQueuesByNameReply) Descriptor() ([]byte, []int)

Deprecated: Use ListQueuesByNameReply.ProtoReflect.Descriptor instead.

func (*ListQueuesByNameReply) GetPage 

func (x *ListQueuesByNameReply) GetPage() *Pagination

func (*ListQueuesByNameReply) GetQueues 

func (x *ListQueuesByNameReply) GetQueues() []*QueueInfo

func (*ListQueuesByNameReply) GetStatus 

func (x *ListQueuesByNameReply) GetStatus() *Error

func (*ListQueuesByNameReply) GetTotal 

func (x *ListQueuesByNameReply) GetTotal() int64

func (*ListQueuesByNameReply) ProtoMessage 

func (*ListQueuesByNameReply) ProtoMessage()

func (*ListQueuesByNameReply) ProtoReflect 

func (x *ListQueuesByNameReply) ProtoReflect() protoreflect.Message

func (*ListQueuesByNameReply) Reset 

func (x *ListQueuesByNameReply) Reset()

func (*ListQueuesByNameReply) String 

func (x *ListQueuesByNameReply) String() string

type ListQueuesByNameRequest 

type ListQueuesByNameRequest struct {

	// 集群名称
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Vhost 名称
	Vhost string `protobuf:"bytes,2,opt,name=vhost,proto3" json:"vhost,omitempty"`
	// Queue 名称 NOTE: 支持模糊匹配
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// 是否精确匹配 Queue name
	IsAccurate bool `protobuf:"varint,4,opt,name=is_accurate,json=isAccurate,proto3" json:"is_accurate,omitempty"`
	// 是否请求获取额外相关信息 (Exchange & Binding 信息)
	IsExtra bool `protobuf:"varint,5,opt,name=is_extra,json=isExtra,proto3" json:"is_extra,omitempty"`
	// 页大小配置
	Page *Pagination `protobuf:"bytes,6,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

The request message ListQueuesByName

func (*ListQueuesByNameRequest) Descriptor deprecated 

func (*ListQueuesByNameRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListQueuesByNameRequest.ProtoReflect.Descriptor instead.

func (*ListQueuesByNameRequest) GetCluster 

func (x *ListQueuesByNameRequest) GetCluster() string

func (*ListQueuesByNameRequest) GetIsAccurate 

func (x *ListQueuesByNameRequest) GetIsAccurate() bool

func (*ListQueuesByNameRequest) GetIsExtra 

func (x *ListQueuesByNameRequest) GetIsExtra() bool

func (*ListQueuesByNameRequest) GetName 

func (x *ListQueuesByNameRequest) GetName() string

func (*ListQueuesByNameRequest) GetPage 

func (x *ListQueuesByNameRequest) GetPage() *Pagination

func (*ListQueuesByNameRequest) GetVhost 

func (x *ListQueuesByNameRequest) GetVhost() string

func (*ListQueuesByNameRequest) ProtoMessage 

func (*ListQueuesByNameRequest) ProtoMessage()

func (*ListQueuesByNameRequest) ProtoReflect 

func (x *ListQueuesByNameRequest) ProtoReflect() protoreflect.Message

func (*ListQueuesByNameRequest) Reset 

func (x *ListQueuesByNameRequest) Reset()

func (*ListQueuesByNameRequest) String 

func (x *ListQueuesByNameRequest) String() string

type LogOutReply 

type LogOutReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message LogOut

func (*LogOutReply) Descriptor deprecated 

func (*LogOutReply) Descriptor() ([]byte, []int)

Deprecated: Use LogOutReply.ProtoReflect.Descriptor instead.

func (*LogOutReply) GetStatus 

func (x *LogOutReply) GetStatus() *Error

func (*LogOutReply) ProtoMessage 

func (*LogOutReply) ProtoMessage()

func (*LogOutReply) ProtoReflect 

func (x *LogOutReply) ProtoReflect() protoreflect.Message

func (*LogOutReply) Reset 

func (x *LogOutReply) Reset()

func (*LogOutReply) String 

func (x *LogOutReply) String() string

type LogOutRequest 

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

The request message LogOut

func (*LogOutRequest) Descriptor deprecated 

func (*LogOutRequest) Descriptor() ([]byte, []int)

Deprecated: Use LogOutRequest.ProtoReflect.Descriptor instead.

func (*LogOutRequest) ProtoMessage 

func (*LogOutRequest) ProtoMessage()

func (*LogOutRequest) ProtoReflect 

func (x *LogOutRequest) ProtoReflect() protoreflect.Message

func (*LogOutRequest) Reset 

func (x *LogOutRequest) Reset()

func (*LogOutRequest) String 

func (x *LogOutRequest) String() string

type LoginStatusReply 

type LoginStatusReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message LoginStatus

func (*LoginStatusReply) Descriptor deprecated 

func (*LoginStatusReply) Descriptor() ([]byte, []int)

Deprecated: Use LoginStatusReply.ProtoReflect.Descriptor instead.

func (*LoginStatusReply) GetStatus 

func (x *LoginStatusReply) GetStatus() *Error

func (*LoginStatusReply) ProtoMessage 

func (*LoginStatusReply) ProtoMessage()

func (*LoginStatusReply) ProtoReflect 

func (x *LoginStatusReply) ProtoReflect() protoreflect.Message

func (*LoginStatusReply) Reset 

func (x *LoginStatusReply) Reset()

func (*LoginStatusReply) String 

func (x *LoginStatusReply) String() string

type LoginStatusRequest 

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

The request message LoginStatus

func (*LoginStatusRequest) Descriptor deprecated 

func (*LoginStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoginStatusRequest.ProtoReflect.Descriptor instead.

func (*LoginStatusRequest) ProtoMessage 

func (*LoginStatusRequest) ProtoMessage()

func (*LoginStatusRequest) ProtoReflect 

func (x *LoginStatusRequest) ProtoReflect() protoreflect.Message

func (*LoginStatusRequest) Reset 

func (x *LoginStatusRequest) Reset()

func (*LoginStatusRequest) String 

func (x *LoginStatusRequest) String() string

type MessageBodySize 

type MessageBodySize int32

MessageBodySize 消息体大小范围 

const (
	// 未知
	MessageBodySize_MessageBodySizeUnknown MessageBodySize = 0
	// 1B ~ 512B
	MessageBodySize_MessageBodySizeLess512B MessageBodySize = 1
	// 512B ~ 2KB
	MessageBodySize_MessageBodySizeLess2KB MessageBodySize = 2
	// 2KB ~ 16KB
	MessageBodySize_MessageBodySizeLess16KB MessageBodySize = 3
	// 16KB ~ 32KB
	MessageBodySize_MessageBodySizeLess32KB MessageBodySize = 4
)

func (MessageBodySize) Descriptor 

func (MessageBodySize) Descriptor() protoreflect.EnumDescriptor

func (MessageBodySize) Enum 

func (x MessageBodySize) Enum() *MessageBodySize

func (MessageBodySize) EnumDescriptor deprecated 

func (MessageBodySize) EnumDescriptor() ([]byte, []int)

Deprecated: Use MessageBodySize.Descriptor instead.

func (MessageBodySize) Number 

func (x MessageBodySize) Number() protoreflect.EnumNumber

func (MessageBodySize) String 

func (x MessageBodySize) String() string

func (MessageBodySize) Type 

func (MessageBodySize) Type() protoreflect.EnumType

type ModifyExchangeAtributeReply 

type ModifyExchangeAtributeReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message ModifyExchangeAtribute

func (*ModifyExchangeAtributeReply) Descriptor deprecated 

func (*ModifyExchangeAtributeReply) Descriptor() ([]byte, []int)

Deprecated: Use ModifyExchangeAtributeReply.ProtoReflect.Descriptor instead.

func (*ModifyExchangeAtributeReply) GetStatus 

func (x *ModifyExchangeAtributeReply) GetStatus() *Error

func (*ModifyExchangeAtributeReply) ProtoMessage 

func (*ModifyExchangeAtributeReply) ProtoMessage()

func (*ModifyExchangeAtributeReply) ProtoReflect 

func (x *ModifyExchangeAtributeReply) ProtoReflect() protoreflect.Message

func (*ModifyExchangeAtributeReply) Reset 

func (x *ModifyExchangeAtributeReply) Reset()

func (*ModifyExchangeAtributeReply) String 

func (x *ModifyExchangeAtributeReply) String() string

type ModifyExchangeAtributeRequest 

type ModifyExchangeAtributeRequest struct {

	// Exchange 数据库 id
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Exchange 用途描述
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Exchange 消息流入速率 单位: tps/s
	PublisherRate uint32 `protobuf:"varint,3,opt,name=publisher_rate,json=publisherRate,proto3" json:"publisher_rate,omitempty"`
	// 消息体大小范围
	MessageBodySize uint32 `protobuf:"varint,4,opt,name=message_body_size,json=messageBodySize,proto3" json:"message_body_size,omitempty"`
	// Exchange 属性
	Attribute *ExchangeAttribute `protobuf:"bytes,5,opt,name=attribute,proto3" json:"attribute,omitempty"`
	// contains filtered or unexported fields
}

The response message ModifyExchangeAtribute

func (*ModifyExchangeAtributeRequest) Descriptor deprecated 

func (*ModifyExchangeAtributeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ModifyExchangeAtributeRequest.ProtoReflect.Descriptor instead.

func (*ModifyExchangeAtributeRequest) GetAttribute 

func (x *ModifyExchangeAtributeRequest) GetAttribute() *ExchangeAttribute

func (*ModifyExchangeAtributeRequest) GetDescription 

func (x *ModifyExchangeAtributeRequest) GetDescription() string

func (*ModifyExchangeAtributeRequest) GetId 

func (x *ModifyExchangeAtributeRequest) GetId() uint64

func (*ModifyExchangeAtributeRequest) GetMessageBodySize 

func (x *ModifyExchangeAtributeRequest) GetMessageBodySize() uint32

func (*ModifyExchangeAtributeRequest) GetPublisherRate 

func (x *ModifyExchangeAtributeRequest) GetPublisherRate() uint32

func (*ModifyExchangeAtributeRequest) ProtoMessage 

func (*ModifyExchangeAtributeRequest) ProtoMessage()

func (*ModifyExchangeAtributeRequest) ProtoReflect 

func (x *ModifyExchangeAtributeRequest) ProtoReflect() protoreflect.Message

func (*ModifyExchangeAtributeRequest) Reset 

func (x *ModifyExchangeAtributeRequest) Reset()

func (*ModifyExchangeAtributeRequest) String 

func (x *ModifyExchangeAtributeRequest) String() string

type ModifyQueueAtributeReply 

type ModifyQueueAtributeReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message ModifyQueueAtribute

func (*ModifyQueueAtributeReply) Descriptor deprecated 

func (*ModifyQueueAtributeReply) Descriptor() ([]byte, []int)

Deprecated: Use ModifyQueueAtributeReply.ProtoReflect.Descriptor instead.

func (*ModifyQueueAtributeReply) GetStatus 

func (x *ModifyQueueAtributeReply) GetStatus() *Error

func (*ModifyQueueAtributeReply) ProtoMessage 

func (*ModifyQueueAtributeReply) ProtoMessage()

func (*ModifyQueueAtributeReply) ProtoReflect 

func (x *ModifyQueueAtributeReply) ProtoReflect() protoreflect.Message

func (*ModifyQueueAtributeReply) Reset 

func (x *ModifyQueueAtributeReply) Reset()

func (*ModifyQueueAtributeReply) String 

func (x *ModifyQueueAtributeReply) String() string

type ModifyQueueAtributeRequest 

type ModifyQueueAtributeRequest struct {

	// queue 数据库 id
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 队列用途描述
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// 队列消费速率 单位: tps/s
	ConsumerRate uint32 `protobuf:"varint,3,opt,name=consumer_rate,json=consumerRate,proto3" json:"consumer_rate,omitempty"`
	// 最大消息堆积量
	MaxMsgAccumulationCount uint32 `` /* 135-byte string literal not displayed */
	// 是否是延迟队列
	IsDelay bool `protobuf:"varint,5,opt,name=is_delay,json=isDelay,proto3" json:"is_delay,omitempty"`
	// 延迟队列最大超时时间  单位: 毫秒 ms
	DelayTimeout uint32 `protobuf:"varint,6,opt,name=delay_timeout,json=delayTimeout,proto3" json:"delay_timeout,omitempty"`
	// Queue 重要等级属性，用于给 queue 打分, 判断 queue 的重要等级
	Attribute *QueueAttribute `protobuf:"bytes,7,opt,name=attribute,proto3" json:"attribute,omitempty"`
	// contains filtered or unexported fields
}

The response message ModifyQueueAtribute

func (*ModifyQueueAtributeRequest) Descriptor deprecated 

func (*ModifyQueueAtributeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ModifyQueueAtributeRequest.ProtoReflect.Descriptor instead.

func (*ModifyQueueAtributeRequest) GetAttribute 

func (x *ModifyQueueAtributeRequest) GetAttribute() *QueueAttribute

func (*ModifyQueueAtributeRequest) GetConsumerRate 

func (x *ModifyQueueAtributeRequest) GetConsumerRate() uint32

func (*ModifyQueueAtributeRequest) GetDelayTimeout 

func (x *ModifyQueueAtributeRequest) GetDelayTimeout() uint32

func (*ModifyQueueAtributeRequest) GetDescription 

func (x *ModifyQueueAtributeRequest) GetDescription() string

func (*ModifyQueueAtributeRequest) GetId 

func (x *ModifyQueueAtributeRequest) GetId() uint64

func (*ModifyQueueAtributeRequest) GetIsDelay 

func (x *ModifyQueueAtributeRequest) GetIsDelay() bool

func (*ModifyQueueAtributeRequest) GetMaxMsgAccumulationCount 

func (x *ModifyQueueAtributeRequest) GetMaxMsgAccumulationCount() uint32

func (*ModifyQueueAtributeRequest) ProtoMessage 

func (*ModifyQueueAtributeRequest) ProtoMessage()

func (*ModifyQueueAtributeRequest) ProtoReflect 

func (x *ModifyQueueAtributeRequest) ProtoReflect() protoreflect.Message

func (*ModifyQueueAtributeRequest) Reset 

func (x *ModifyQueueAtributeRequest) Reset()

func (*ModifyQueueAtributeRequest) String 

func (x *ModifyQueueAtributeRequest) String() string

type MoveAmountQueuesToNodeReply 

type MoveAmountQueuesToNodeReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message MoveAmountQueuesToNodeReply

func (*MoveAmountQueuesToNodeReply) Descriptor deprecated 

func (*MoveAmountQueuesToNodeReply) Descriptor() ([]byte, []int)

Deprecated: Use MoveAmountQueuesToNodeReply.ProtoReflect.Descriptor instead.

func (*MoveAmountQueuesToNodeReply) GetStatus 

func (x *MoveAmountQueuesToNodeReply) GetStatus() *Error

func (*MoveAmountQueuesToNodeReply) ProtoMessage 

func (*MoveAmountQueuesToNodeReply) ProtoMessage()

func (*MoveAmountQueuesToNodeReply) ProtoReflect 

func (x *MoveAmountQueuesToNodeReply) ProtoReflect() protoreflect.Message

func (*MoveAmountQueuesToNodeReply) Reset 

func (x *MoveAmountQueuesToNodeReply) Reset()

func (*MoveAmountQueuesToNodeReply) String 

func (x *MoveAmountQueuesToNodeReply) String() string

type MoveAmountQueuesToNodeRequest 

type MoveAmountQueuesToNodeRequest struct {

	// cluster 名称
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// vhost 名称
	Vhost string `protobuf:"bytes,2,opt,name=vhost,proto3" json:"vhost,omitempty"`
	// 需要移动队列的 node
	SrcNode string `protobuf:"bytes,3,opt,name=src_node,json=srcNode,proto3" json:"src_node,omitempty"`
	// queues 移动的目标节点 (节点 hostname)
	Node string `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
	// 需要移动的 queues 数量
	// NOTE: 如果 nodeDst queues 数量不足，则默认移动剩余的 queues
	Amount uint32 `protobuf:"varint,5,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

The response message MoveAmountQueuesToNode

func (*MoveAmountQueuesToNodeRequest) Descriptor deprecated 

func (*MoveAmountQueuesToNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use MoveAmountQueuesToNodeRequest.ProtoReflect.Descriptor instead.

func (*MoveAmountQueuesToNodeRequest) GetAmount 

func (x *MoveAmountQueuesToNodeRequest) GetAmount() uint32

func (*MoveAmountQueuesToNodeRequest) GetCluster 

func (x *MoveAmountQueuesToNodeRequest) GetCluster() string

func (*MoveAmountQueuesToNodeRequest) GetNode 

func (x *MoveAmountQueuesToNodeRequest) GetNode() string

func (*MoveAmountQueuesToNodeRequest) GetSrcNode 

func (x *MoveAmountQueuesToNodeRequest) GetSrcNode() string

func (*MoveAmountQueuesToNodeRequest) GetVhost 

func (x *MoveAmountQueuesToNodeRequest) GetVhost() string

func (*MoveAmountQueuesToNodeRequest) ProtoMessage 

func (*MoveAmountQueuesToNodeRequest) ProtoMessage()

func (*MoveAmountQueuesToNodeRequest) ProtoReflect 

func (x *MoveAmountQueuesToNodeRequest) ProtoReflect() protoreflect.Message

func (*MoveAmountQueuesToNodeRequest) Reset 

func (x *MoveAmountQueuesToNodeRequest) Reset()

func (*MoveAmountQueuesToNodeRequest) String 

func (x *MoveAmountQueuesToNodeRequest) String() string

type MoveQueuesToNodeReply 

type MoveQueuesToNodeReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message MoveQueuesToNode

func (*MoveQueuesToNodeReply) Descriptor deprecated 

func (*MoveQueuesToNodeReply) Descriptor() ([]byte, []int)

Deprecated: Use MoveQueuesToNodeReply.ProtoReflect.Descriptor instead.

func (*MoveQueuesToNodeReply) GetStatus 

func (x *MoveQueuesToNodeReply) GetStatus() *Error

func (*MoveQueuesToNodeReply) ProtoMessage 

func (*MoveQueuesToNodeReply) ProtoMessage()

func (*MoveQueuesToNodeReply) ProtoReflect 

func (x *MoveQueuesToNodeReply) ProtoReflect() protoreflect.Message

func (*MoveQueuesToNodeReply) Reset 

func (x *MoveQueuesToNodeReply) Reset()

func (*MoveQueuesToNodeReply) String 

func (x *MoveQueuesToNodeReply) String() string

type MoveQueuesToNodeRequest 

type MoveQueuesToNodeRequest struct {

	// cluster 名称
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// vhost 名称
	Vhost string `protobuf:"bytes,2,opt,name=vhost,proto3" json:"vhost,omitempty"`
	// queues 名称列表
	Queues []string `protobuf:"bytes,3,rep,name=queues,proto3" json:"queues,omitempty"`
	// queues 移动的目标节点(节点 hostname)
	Node string `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

The request message MoveQueuesToNode

func (*MoveQueuesToNodeRequest) Descriptor deprecated 

func (*MoveQueuesToNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use MoveQueuesToNodeRequest.ProtoReflect.Descriptor instead.

func (*MoveQueuesToNodeRequest) GetCluster 

func (x *MoveQueuesToNodeRequest) GetCluster() string

func (*MoveQueuesToNodeRequest) GetNode 

func (x *MoveQueuesToNodeRequest) GetNode() string

func (*MoveQueuesToNodeRequest) GetQueues 

func (x *MoveQueuesToNodeRequest) GetQueues() []string

func (*MoveQueuesToNodeRequest) GetVhost 

func (x *MoveQueuesToNodeRequest) GetVhost() string

func (*MoveQueuesToNodeRequest) ProtoMessage 

func (*MoveQueuesToNodeRequest) ProtoMessage()

func (*MoveQueuesToNodeRequest) ProtoReflect 

func (x *MoveQueuesToNodeRequest) ProtoReflect() protoreflect.Message

func (*MoveQueuesToNodeRequest) Reset 

func (x *MoveQueuesToNodeRequest) Reset()

func (*MoveQueuesToNodeRequest) String 

func (x *MoveQueuesToNodeRequest) String() string

type Pagination 

type Pagination struct {

	// 当前页码
	Page uint32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	// 当前页数据条数
	Size uint32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

Pagination page, page_size and page_limit

func (*Pagination) Descriptor deprecated 

func (*Pagination) Descriptor() ([]byte, []int)

Deprecated: Use Pagination.ProtoReflect.Descriptor instead.

func (*Pagination) GetPage 

func (x *Pagination) GetPage() uint32

func (*Pagination) GetSize 

func (x *Pagination) GetSize() uint32

func (*Pagination) ProtoMessage 

func (*Pagination) ProtoMessage()

func (*Pagination) ProtoReflect 

func (x *Pagination) ProtoReflect() protoreflect.Message

func (*Pagination) Reset 

func (x *Pagination) Reset()

func (*Pagination) String 

func (x *Pagination) String() string

type PingReply 

type PingReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 响应消息
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

The response message ping

func (*PingReply) Descriptor deprecated 

func (*PingReply) Descriptor() ([]byte, []int)

Deprecated: Use PingReply.ProtoReflect.Descriptor instead.

func (*PingReply) GetMessage 

func (x *PingReply) GetMessage() string

func (*PingReply) GetStatus 

func (x *PingReply) GetStatus() *Error

func (*PingReply) ProtoMessage 

func (*PingReply) ProtoMessage()

func (*PingReply) ProtoReflect 

func (x *PingReply) ProtoReflect() protoreflect.Message

func (*PingReply) Reset 

func (x *PingReply) Reset()

func (*PingReply) String 

func (x *PingReply) String() string

type PingRequest 

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

The request message ping

func (*PingRequest) Descriptor deprecated 

func (*PingRequest) Descriptor() ([]byte, []int)

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

func (x *PingRequest) ProtoReflect() protoreflect.Message

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type Priority 

type Priority int32

Priority 重要性枚举 

const (
	// 未知
	Priority_PriorityUnknown Priority = 0
	// 一般的
	Priority_PriorityGeneral Priority = 10
	// 重要的
	Priority_PriorityImportant Priority = 20
	// 非常重要的
	Priority_PriorityVeryImportant Priority = 30
)

func (Priority) Descriptor 

func (Priority) Descriptor() protoreflect.EnumDescriptor

func (Priority) Enum 

func (x Priority) Enum() *Priority

func (Priority) EnumDescriptor deprecated 

func (Priority) EnumDescriptor() ([]byte, []int)

Deprecated: Use Priority.Descriptor instead.

func (Priority) Number 

func (x Priority) Number() protoreflect.EnumNumber

func (Priority) String 

func (x Priority) String() string

func (Priority) Type 

func (Priority) Type() protoreflect.EnumType

type QMgmtClient 

type QMgmtClient interface {
	// Sends a greeting hello world
	SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloReply, error)
	// Sends a greeting ping
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingReply, error)
	// Sends a nginx_status
	NginxStatus(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingReply, error)
	// HandlerSendBucSSOTokenDo receive sso auth callback invoke
	HandlerSendBucSSOTokenDo(ctx context.Context, in *HandlerSendBucSSOTokenDoRequest, opts ...grpc.CallOption) (*HandlerSendBucSSOTokenDoReply, error)
	// LogOut user logout
	LogOut(ctx context.Context, in *LogOutRequest, opts ...grpc.CallOption) (*LogOutReply, error)
	// LoginStatus 用户登陆状态检查
	LoginStatus(ctx context.Context, in *LoginStatusRequest, opts ...grpc.CallOption) (*LoginStatusReply, error)
	// UpdateDiamondExtConfig 更新 diamond 配置
	UpdateDiamondExtConfig(ctx context.Context, in *UpdateDiamondExtConfigRequest, opts ...grpc.CallOption) (*UpdateDiamondExtConfigReply, error)
	// DeleteDistributedLock 删除分布式锁
	DeleteDistributedLock(ctx context.Context, in *DeleteDistributedLockRequest, opts ...grpc.CallOption) (*DeleteDistributedLockReply, error)
	// SyncClusterMetaData sync clusters meta data to db.
	SyncClusterMetaData(ctx context.Context, in *SyncClusterMetaDataRequest, opts ...grpc.CallOption) (*SyncClusterMetaDataReply, error)
	// DeleteAllData delete all database data  // NOTE:会删除所有数据库数据 谨慎调用!!!
	DeleteAllData(ctx context.Context, in *DeleteAllDataRequest, opts ...grpc.CallOption) (*DeleteAllDataReply, error)
	// ListMetaDataByAppName 根据应用名称查询该应用 Exchange 列表与 Queue 列表信息
	ListMetaDataByAppName(ctx context.Context, in *ListMetaDataByAppNameRequest, opts ...grpc.CallOption) (*ListMetaDataByAppNameReply, error)
	// ListExchangesByName Exchange 列表
	ListExchangesByName(ctx context.Context, in *ListExchangesByNameRequest, opts ...grpc.CallOption) (*ListExchangesByNameReply, error)
	// GetExchangeByID 根据 ID 获取 Exchange 详情
	GetExchangeByID(ctx context.Context, in *GetExchangeByIDRequest, opts ...grpc.CallOption) (*GetExchangeByIDReply, error)
	// ModifyExchangeAtribute 修改 Exchange 元数据
	ModifyExchangeAtribute(ctx context.Context, in *ModifyExchangeAtributeRequest, opts ...grpc.CallOption) (*ModifyExchangeAtributeReply, error)
	// ListQueuesByName Queue 列表
	ListQueuesByName(ctx context.Context, in *ListQueuesByNameRequest, opts ...grpc.CallOption) (*ListQueuesByNameReply, error)
	// GetQueueByID 根据 ID 获取 Queue 详情
	GetQueueByID(ctx context.Context, in *GetQueueByIDRequest, opts ...grpc.CallOption) (*GetQueueByIDReply, error)
	// ModifyQueueAtribute Queue 列表
	ModifyQueueAtribute(ctx context.Context, in *ModifyQueueAtributeRequest, opts ...grpc.CallOption) (*ModifyQueueAtributeReply, error)
	// MoveQueuesToNode 移动 Queues 到指定节点
	MoveQueuesToNode(ctx context.Context, in *MoveQueuesToNodeRequest, opts ...grpc.CallOption) (*MoveQueuesToNodeReply, error)
	// MoveAmountQueuesToNode 移动指定数量的 Queues 到指定节点
	MoveAmountQueuesToNode(ctx context.Context, in *MoveAmountQueuesToNodeRequest, opts ...grpc.CallOption) (*MoveAmountQueuesToNodeReply, error)
	// SyncApps 同步应用列表(手动)
	SyncApps(ctx context.Context, in *SyncAppsRequest, opts ...grpc.CallOption) (*SyncAppsReply, error)
	// ListApps 应用列表
	ListApps(ctx context.Context, in *ListAppsRequest, opts ...grpc.CallOption) (*ListAppsReply, error)
	// GetAppDetailByID 获取指定 ID 应用详情
	GetAppDetailByID(ctx context.Context, in *GetAppDetailByIDRequest, opts ...grpc.CallOption) (*GetAppDetailByIDReply, error)
	// ListMyselfApps 获取应用 Owner 的应用列表
	ListMyselfApps(ctx context.Context, in *ListMyselfAppsRequest, opts ...grpc.CallOption) (*ListMyselfAppsReply, error)
	// ListCoreLevelApps 获取核心 H1,H2 应用列表
	ListCoreLevelApps(ctx context.Context, in *ListCoreLevelAppsRequest, opts ...grpc.CallOption) (*ListCoreLevelAppsReply, error)
	// ListMainLinkApps 获取 主链路 应用列表信息
	ListMainLinkApps(ctx context.Context, in *ListMainLinkAppsRequest, opts ...grpc.CallOption) (*ListMainLinkAppsReply, error)
	// SyncClusters 从 Qboard 手动同步集群信息
	SyncClusters(ctx context.Context, in *SyncClustersRequest, opts ...grpc.CallOption) (*SyncClustersReply, error)
	// ListClusterNames 获取 所有集群名称 列表
	ListClusterNames(ctx context.Context, in *ListClusterNamesRequest, opts ...grpc.CallOption) (*ListClusterNamesReply, error)
	// ListClusters 获取 Cluster 列表
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersReply, error)
	// GetVhostsByClusterName 根据 Cluster 名称 获取 Cluster Vhost 名称列表
	GetVhostsByClusterName(ctx context.Context, in *GetVhostsByClusterNameRequest, opts ...grpc.CallOption) (*GetVhostsByClusterNameReply, error)
	// CollectionResource 用户收藏各种资源
	CollectionResource(ctx context.Context, in *CollectionResourceRequest, opts ...grpc.CallOption) (*CollectionResourceReply, error)
	// CancelCollection 用户收藏各种资源
	CancelCollection(ctx context.Context, in *CancelCollectionRequest, opts ...grpc.CallOption) (*CancelCollectionReply, error)
	// ListCollection 获取用户收藏的资源列表
	ListCollection(ctx context.Context, in *ListCollectionRequest, opts ...grpc.CallOption) (*ListCollectionReply, error)
	// ListAuditLog 获取用户收藏的资源列表
	ListAuditLog(ctx context.Context, in *ListAuditLogRequest, opts ...grpc.CallOption) (*ListAuditLogReply, error)
}

QMgmtClient is the client API for QMgmt service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQMgmtClient 

func NewQMgmtClient(cc grpc.ClientConnInterface) QMgmtClient

type QMgmtServer 

type QMgmtServer interface {
	// Sends a greeting hello world
	SayHello(context.Context, *HelloRequest) (*HelloReply, error)
	// Sends a greeting ping
	Ping(context.Context, *PingRequest) (*PingReply, error)
	// Sends a nginx_status
	NginxStatus(context.Context, *PingRequest) (*PingReply, error)
	// HandlerSendBucSSOTokenDo receive sso auth callback invoke
	HandlerSendBucSSOTokenDo(context.Context, *HandlerSendBucSSOTokenDoRequest) (*HandlerSendBucSSOTokenDoReply, error)
	// LogOut user logout
	LogOut(context.Context, *LogOutRequest) (*LogOutReply, error)
	// LoginStatus 用户登陆状态检查
	LoginStatus(context.Context, *LoginStatusRequest) (*LoginStatusReply, error)
	// UpdateDiamondExtConfig 更新 diamond 配置
	UpdateDiamondExtConfig(context.Context, *UpdateDiamondExtConfigRequest) (*UpdateDiamondExtConfigReply, error)
	// DeleteDistributedLock 删除分布式锁
	DeleteDistributedLock(context.Context, *DeleteDistributedLockRequest) (*DeleteDistributedLockReply, error)
	// SyncClusterMetaData sync clusters meta data to db.
	SyncClusterMetaData(context.Context, *SyncClusterMetaDataRequest) (*SyncClusterMetaDataReply, error)
	// DeleteAllData delete all database data  // NOTE:会删除所有数据库数据 谨慎调用!!!
	DeleteAllData(context.Context, *DeleteAllDataRequest) (*DeleteAllDataReply, error)
	// ListMetaDataByAppName 根据应用名称查询该应用 Exchange 列表与 Queue 列表信息
	ListMetaDataByAppName(context.Context, *ListMetaDataByAppNameRequest) (*ListMetaDataByAppNameReply, error)
	// ListExchangesByName Exchange 列表
	ListExchangesByName(context.Context, *ListExchangesByNameRequest) (*ListExchangesByNameReply, error)
	// GetExchangeByID 根据 ID 获取 Exchange 详情
	GetExchangeByID(context.Context, *GetExchangeByIDRequest) (*GetExchangeByIDReply, error)
	// ModifyExchangeAtribute 修改 Exchange 元数据
	ModifyExchangeAtribute(context.Context, *ModifyExchangeAtributeRequest) (*ModifyExchangeAtributeReply, error)
	// ListQueuesByName Queue 列表
	ListQueuesByName(context.Context, *ListQueuesByNameRequest) (*ListQueuesByNameReply, error)
	// GetQueueByID 根据 ID 获取 Queue 详情
	GetQueueByID(context.Context, *GetQueueByIDRequest) (*GetQueueByIDReply, error)
	// ModifyQueueAtribute Queue 列表
	ModifyQueueAtribute(context.Context, *ModifyQueueAtributeRequest) (*ModifyQueueAtributeReply, error)
	// MoveQueuesToNode 移动 Queues 到指定节点
	MoveQueuesToNode(context.Context, *MoveQueuesToNodeRequest) (*MoveQueuesToNodeReply, error)
	// MoveAmountQueuesToNode 移动指定数量的 Queues 到指定节点
	MoveAmountQueuesToNode(context.Context, *MoveAmountQueuesToNodeRequest) (*MoveAmountQueuesToNodeReply, error)
	// SyncApps 同步应用列表(手动)
	SyncApps(context.Context, *SyncAppsRequest) (*SyncAppsReply, error)
	// ListApps 应用列表
	ListApps(context.Context, *ListAppsRequest) (*ListAppsReply, error)
	// GetAppDetailByID 获取指定 ID 应用详情
	GetAppDetailByID(context.Context, *GetAppDetailByIDRequest) (*GetAppDetailByIDReply, error)
	// ListMyselfApps 获取应用 Owner 的应用列表
	ListMyselfApps(context.Context, *ListMyselfAppsRequest) (*ListMyselfAppsReply, error)
	// ListCoreLevelApps 获取核心 H1,H2 应用列表
	ListCoreLevelApps(context.Context, *ListCoreLevelAppsRequest) (*ListCoreLevelAppsReply, error)
	// ListMainLinkApps 获取 主链路 应用列表信息
	ListMainLinkApps(context.Context, *ListMainLinkAppsRequest) (*ListMainLinkAppsReply, error)
	// SyncClusters 从 Qboard 手动同步集群信息
	SyncClusters(context.Context, *SyncClustersRequest) (*SyncClustersReply, error)
	// ListClusterNames 获取 所有集群名称 列表
	ListClusterNames(context.Context, *ListClusterNamesRequest) (*ListClusterNamesReply, error)
	// ListClusters 获取 Cluster 列表
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersReply, error)
	// GetVhostsByClusterName 根据 Cluster 名称 获取 Cluster Vhost 名称列表
	GetVhostsByClusterName(context.Context, *GetVhostsByClusterNameRequest) (*GetVhostsByClusterNameReply, error)
	// CollectionResource 用户收藏各种资源
	CollectionResource(context.Context, *CollectionResourceRequest) (*CollectionResourceReply, error)
	// CancelCollection 用户收藏各种资源
	CancelCollection(context.Context, *CancelCollectionRequest) (*CancelCollectionReply, error)
	// ListCollection 获取用户收藏的资源列表
	ListCollection(context.Context, *ListCollectionRequest) (*ListCollectionReply, error)
	// ListAuditLog 获取用户收藏的资源列表
	ListAuditLog(context.Context, *ListAuditLogRequest) (*ListAuditLogReply, error)
	// contains filtered or unexported methods
}

QMgmtServer is the server API for QMgmt service. All implementations must embed UnimplementedQMgmtServer for forward compatibility

type Queue 

type Queue struct {

	// 数据库 id
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 创建时间戳
	CreatedAt int64 `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// 更新时间
	UpdatedAt int64 `protobuf:"varint,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// 是否删除
	IsDelete bool `protobuf:"varint,4,opt,name=is_delete,json=isDelete,proto3" json:"is_delete,omitempty"`
	// 是否删除 文案
	IsDeleteDesc string `protobuf:"bytes,5,opt,name=is_delete_desc,json=isDeleteDesc,proto3" json:"is_delete_desc,omitempty"`
	// idc 机房 [zb1 | nt1 | ppe]
	Idc string `protobuf:"bytes,6,opt,name=idc,proto3" json:"idc,omitempty"`
	// MaxQ 集群名称
	Cluster string `protobuf:"bytes,7,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// MaxQ Vhost 名称
	Vhost string `protobuf:"bytes,8,opt,name=vhost,proto3" json:"vhost,omitempty"`
	// Queue 名称
	Name string `protobuf:"bytes,9,opt,name=Name,proto3" json:"Name,omitempty"`
	// 队列状态
	Status Status `protobuf:"varint,10,opt,name=status,proto3,enum=qmgmt.Status" json:"status,omitempty"`
	// 队列状态 文案
	StatusDesc string `protobuf:"bytes,11,opt,name=status_desc,json=statusDesc,proto3" json:"status_desc,omitempty"`
	// 消费者应用列表  NOTE: 以逗号分隔
	ConsumerApps string `protobuf:"bytes,12,opt,name=consumer_apps,json=consumerApps,proto3" json:"consumer_apps,omitempty"`
	// 推送模式 消费者数量
	ConsumersCount uint32 `protobuf:"varint,13,opt,name=consumers_count,json=consumersCount,proto3" json:"consumers_count,omitempty"`
	// 拉取模式 消费者 hosts 数量
	BasicGetHostsCount uint32 `protobuf:"varint,14,opt,name=basic_get_hosts_count,json=basicGetHostsCount,proto3" json:"basic_get_hosts_count,omitempty"`
	// Queue 重要等级
	Priority Priority `protobuf:"varint,15,opt,name=priority,proto3,enum=qmgmt.Priority" json:"priority,omitempty"`
	// Queue 重要等级 文案
	PriorityDesc string `protobuf:"bytes,16,opt,name=priority_desc,json=priorityDesc,proto3" json:"priority_desc,omitempty"`
	// Queue 用途描述备注
	Description string `protobuf:"bytes,17,opt,name=description,proto3" json:"description,omitempty"`
	// Queue 消息消费速率 NOTE: 单位: tps/s
	ConsumerRate uint32 `protobuf:"varint,18,opt,name=consumer_rate,json=consumerRate,proto3" json:"consumer_rate,omitempty"`
	// 最大消息堆积量
	MaxMsgAccumulationCount uint32 `` /* 136-byte string literal not displayed */
	// 是否是延迟队列
	IsDelay bool `protobuf:"varint,20,opt,name=is_delay,json=isDelay,proto3" json:"is_delay,omitempty"`
	// 是否是延迟队列 文案
	IsDelayDesc string `protobuf:"bytes,21,opt,name=is_delay_desc,json=isDelayDesc,proto3" json:"is_delay_desc,omitempty"`
	// 延迟队列最大超时  NOTE: 单位: 毫秒 ms
	DelayTimeout uint32 `protobuf:"varint,22,opt,name=delay_timeout,json=delayTimeout,proto3" json:"delay_timeout,omitempty"`
	// Queue 所在 Server 节点 HostName
	Node string `protobuf:"bytes,23,opt,name=node,proto3" json:"node,omitempty"`
	// mirroe queue slave 节点列表   NOTE: 以逗号分隔
	SlaveNodes []string `protobuf:"bytes,24,rep,name=slave_nodes,json=slaveNodes,proto3" json:"slave_nodes,omitempty"`
	// Queue 重要等级属性，用于给 queue 打分, 判断 queue 的重要等级
	Attribute *QueueAttribute `protobuf:"bytes,25,opt,name=attribute,proto3" json:"attribute,omitempty"`
	// queue 重要等级分数
	PriorityScore uint32 `protobuf:"varint,26,opt,name=priority_score,json=priorityScore,proto3" json:"priority_score,omitempty"`
	// 创建人工号
	CreateEmpId string `protobuf:"bytes,27,opt,name=create_emp_id,json=createEmpId,proto3" json:"create_emp_id,omitempty"`
	// 编辑修改人工号
	ModifyEmpId string `protobuf:"bytes,28,opt,name=modify_emp_id,json=modifyEmpId,proto3" json:"modify_emp_id,omitempty"`
	// 当前用户是否收藏该应用
	IsCollection bool `protobuf:"varint,50,opt,name=is_collection,json=isCollection,proto3" json:"is_collection,omitempty"`
	// contains filtered or unexported fields
}

Queue 队列模型定义

func (*Queue) Descriptor deprecated 

func (*Queue) Descriptor() ([]byte, []int)

Deprecated: Use Queue.ProtoReflect.Descriptor instead.

func (*Queue) GetAttribute 

func (x *Queue) GetAttribute() *QueueAttribute

func (*Queue) GetBasicGetHostsCount 

func (x *Queue) GetBasicGetHostsCount() uint32

func (*Queue) GetCluster 

func (x *Queue) GetCluster() string

func (*Queue) GetConsumerApps 

func (x *Queue) GetConsumerApps() string

func (*Queue) GetConsumerRate 

func (x *Queue) GetConsumerRate() uint32

func (*Queue) GetConsumersCount 

func (x *Queue) GetConsumersCount() uint32

func (*Queue) GetCreateEmpId 

func (x *Queue) GetCreateEmpId() string

func (*Queue) GetCreatedAt 

func (x *Queue) GetCreatedAt() int64

func (*Queue) GetDelayTimeout 

func (x *Queue) GetDelayTimeout() uint32

func (*Queue) GetDescription 

func (x *Queue) GetDescription() string

func (*Queue) GetId 

func (x *Queue) GetId() uint64

func (*Queue) GetIdc 

func (x *Queue) GetIdc() string

func (*Queue) GetIsCollection 

func (x *Queue) GetIsCollection() bool

func (*Queue) GetIsDelay 

func (x *Queue) GetIsDelay() bool

func (*Queue) GetIsDelayDesc 

func (x *Queue) GetIsDelayDesc() string

func (*Queue) GetIsDelete 

func (x *Queue) GetIsDelete() bool

func (*Queue) GetIsDeleteDesc 

func (x *Queue) GetIsDeleteDesc() string

func (*Queue) GetMaxMsgAccumulationCount 

func (x *Queue) GetMaxMsgAccumulationCount() uint32

func (*Queue) GetModifyEmpId 

func (x *Queue) GetModifyEmpId() string

func (*Queue) GetName 

func (x *Queue) GetName() string

func (*Queue) GetNode 

func (x *Queue) GetNode() string

func (*Queue) GetPriority 

func (x *Queue) GetPriority() Priority

func (*Queue) GetPriorityDesc 

func (x *Queue) GetPriorityDesc() string

func (*Queue) GetPriorityScore 

func (x *Queue) GetPriorityScore() uint32

func (*Queue) GetSlaveNodes 

func (x *Queue) GetSlaveNodes() []string

func (*Queue) GetStatus 

func (x *Queue) GetStatus() Status

func (*Queue) GetStatusDesc 

func (x *Queue) GetStatusDesc() string

func (*Queue) GetUpdatedAt 

func (x *Queue) GetUpdatedAt() int64

func (*Queue) GetVhost 

func (x *Queue) GetVhost() string

func (*Queue) ProtoMessage 

func (*Queue) ProtoMessage()

func (*Queue) ProtoReflect 

func (x *Queue) ProtoReflect() protoreflect.Message

func (*Queue) Reset 

func (x *Queue) Reset()

func (*Queue) String 

func (x *Queue) String() string

type QueueAttribute 

type QueueAttribute struct {

	// 表示业务方是否填写了该 队列 业务安全属性
	// NOTE: 当该结构作为参数时，该字段忽略不填
	IsFill bool `protobuf:"varint,1,opt,name=is_fill,json=isFill,proto3" json:"is_fill,omitempty"`
	// 应用等级  [H1 | H2]
	// NOTE: 当该结构作为参数时，该字段忽略不填
	AppLevel string `protobuf:"bytes,2,opt,name=app_level,json=appLevel,proto3" json:"app_level,omitempty"`
	// 是否是主链路应用
	// NOTE: 当该结构作为参数时，该字段忽略不填
	IsMainLinkApp bool `protobuf:"varint,3,opt,name=is_main_link_app,json=isMainLinkApp,proto3" json:"is_main_link_app,omitempty"`
	// 是否有故障风险
	IsFailureRisk bool `protobuf:"varint,4,opt,name=is_failure_risk,json=isFailureRisk,proto3" json:"is_failure_risk,omitempty"`
	// 故障风险描述
	FailureRiskDescription string `` /* 129-byte string literal not displayed */
	// 是否有资损风险
	IsCapitalLossRisk bool `protobuf:"varint,6,opt,name=is_capital_loss_risk,json=isCapitalLossRisk,proto3" json:"is_capital_loss_risk,omitempty"`
	// 资损风险描述
	CapitalLossRiskDescription string `` /* 143-byte string literal not displayed */
	// 是否有消息时效性要求
	IsRealTime bool `protobuf:"varint,8,opt,name=is_real_time,json=isRealTime,proto3" json:"is_real_time,omitempty"`
	// 是否有兜底方案
	IsBackPlan bool `protobuf:"varint,9,opt,name=is_back_plan,json=isBackPlan,proto3" json:"is_back_plan,omitempty"`
	// 兜底方案描述
	BackupPlaneDescription string `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

QueueAttribute 多合一 attribute 属性，用于给 queue 打分, 判断 queue 的重要等级

func (*QueueAttribute) Descriptor deprecated 

func (*QueueAttribute) Descriptor() ([]byte, []int)

Deprecated: Use QueueAttribute.ProtoReflect.Descriptor instead.

func (*QueueAttribute) GetAppLevel 

func (x *QueueAttribute) GetAppLevel() string

func (*QueueAttribute) GetBackupPlaneDescription 

func (x *QueueAttribute) GetBackupPlaneDescription() string

func (*QueueAttribute) GetCapitalLossRiskDescription 

func (x *QueueAttribute) GetCapitalLossRiskDescription() string

func (*QueueAttribute) GetFailureRiskDescription 

func (x *QueueAttribute) GetFailureRiskDescription() string

func (*QueueAttribute) GetIsBackPlan 

func (x *QueueAttribute) GetIsBackPlan() bool

func (*QueueAttribute) GetIsCapitalLossRisk 

func (x *QueueAttribute) GetIsCapitalLossRisk() bool

func (*QueueAttribute) GetIsFailureRisk 

func (x *QueueAttribute) GetIsFailureRisk() bool

func (*QueueAttribute) GetIsFill 

func (x *QueueAttribute) GetIsFill() bool

func (*QueueAttribute) GetIsMainLinkApp 

func (x *QueueAttribute) GetIsMainLinkApp() bool

func (*QueueAttribute) GetIsRealTime 

func (x *QueueAttribute) GetIsRealTime() bool

func (*QueueAttribute) ProtoMessage 

func (*QueueAttribute) ProtoMessage()

func (*QueueAttribute) ProtoReflect 

func (x *QueueAttribute) ProtoReflect() protoreflect.Message

func (*QueueAttribute) Reset 

func (x *QueueAttribute) Reset()

func (*QueueAttribute) String 

func (x *QueueAttribute) String() string

type QueueInfo 

type QueueInfo struct {

	// Queue 基本信息
	Q *Queue `protobuf:"bytes,1,opt,name=q,proto3" json:"q,omitempty"`
	// queue 对应的 Bindings 对象列表
	Bs []*BindingInfo `protobuf:"bytes,2,rep,name=bs,proto3" json:"bs,omitempty"`
	// Emonitor 监控链接
	EmonitorLink string `protobuf:"bytes,3,opt,name=emonitor_link,json=emonitorLink,proto3" json:"emonitor_link,omitempty"`
	// MaxQ 面板链接
	MaxqPanelLink string `protobuf:"bytes,4,opt,name=maxq_panel_link,json=maxqPanelLink,proto3" json:"maxq_panel_link,omitempty"`
	// contains filtered or unexported fields
}

QueueInfo 带额外附属信息的 Queue 模型定义

func (*QueueInfo) Descriptor deprecated 

func (*QueueInfo) Descriptor() ([]byte, []int)

Deprecated: Use QueueInfo.ProtoReflect.Descriptor instead.

func (*QueueInfo) GetBs 

func (x *QueueInfo) GetBs() []*BindingInfo
func (x *QueueInfo) GetEmonitorLink() string
func (x *QueueInfo) GetMaxqPanelLink() string

func (*QueueInfo) GetQ 

func (x *QueueInfo) GetQ() *Queue

func (*QueueInfo) ProtoMessage 

func (*QueueInfo) ProtoMessage()

func (*QueueInfo) ProtoReflect 

func (x *QueueInfo) ProtoReflect() protoreflect.Message

func (*QueueInfo) Reset 

func (x *QueueInfo) Reset()

func (*QueueInfo) String 

func (x *QueueInfo) String() string

type Status 

type Status int32

Status exchange & queue 状态 

const (
	// 未知
	Status_StatusUnknown Status = 0
	// 待上线
	// NOTE: 仅在平台录入预上线状态，MaxQ Server 上没有相关 Exchange, Queue 信息
	Status_StatusStayOnline Status = 10
	// 在线
	// NOTE: 在线有客户端链接, 生产于消费速率不为0, 但小于活跃状态的速率
	Status_StatusOnline Status = 20
	// 活跃的
	// NOTE: 消息生产和消费速率不为0, 并且大于活跃速率数值
	Status_StatusActive Status = 30
	// 不活跃的
	// NOTE: 消息生产和消费速率为0, 但是有客户端链接
	// 如果 链接或者 hosts 没有，但是平均速率 不为 0，先将状态置为 不活跃
	Status_StatusInActive Status = 40
	// 离线
	// NOTE: 没有客户端链接状态
	Status_StatusOffline Status = 50
	// 已下线
	// NOTE: 已通过平台手动下线删除状态
	Status_StatusDownline Status = 60
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type SyncAppsReply 

type SyncAppsReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message SyncApps

func (*SyncAppsReply) Descriptor deprecated 

func (*SyncAppsReply) Descriptor() ([]byte, []int)

Deprecated: Use SyncAppsReply.ProtoReflect.Descriptor instead.

func (*SyncAppsReply) GetStatus 

func (x *SyncAppsReply) GetStatus() *Error

func (*SyncAppsReply) ProtoMessage 

func (*SyncAppsReply) ProtoMessage()

func (*SyncAppsReply) ProtoReflect 

func (x *SyncAppsReply) ProtoReflect() protoreflect.Message

func (*SyncAppsReply) Reset 

func (x *SyncAppsReply) Reset()

func (*SyncAppsReply) String 

func (x *SyncAppsReply) String() string

type SyncAppsRequest 

type SyncAppsRequest struct {

	// 要同步的应用名称
	// NOTE: 如果应用名为空,则表示同步所有应用,并且该字段只能是应用 AoneName
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	// contains filtered or unexported fields
}

The response message SyncApps

func (*SyncAppsRequest) Descriptor deprecated 

func (*SyncAppsRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncAppsRequest.ProtoReflect.Descriptor instead.

func (*SyncAppsRequest) GetAppName 

func (x *SyncAppsRequest) GetAppName() string

func (*SyncAppsRequest) ProtoMessage 

func (*SyncAppsRequest) ProtoMessage()

func (*SyncAppsRequest) ProtoReflect 

func (x *SyncAppsRequest) ProtoReflect() protoreflect.Message

func (*SyncAppsRequest) Reset 

func (x *SyncAppsRequest) Reset()

func (*SyncAppsRequest) String 

func (x *SyncAppsRequest) String() string

type SyncClusterMetaDataReply 

type SyncClusterMetaDataReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 响应消息
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

The response message SyncClusterMetaData

func (*SyncClusterMetaDataReply) Descriptor deprecated 

func (*SyncClusterMetaDataReply) Descriptor() ([]byte, []int)

Deprecated: Use SyncClusterMetaDataReply.ProtoReflect.Descriptor instead.

func (*SyncClusterMetaDataReply) GetMessage 

func (x *SyncClusterMetaDataReply) GetMessage() string

func (*SyncClusterMetaDataReply) GetStatus 

func (x *SyncClusterMetaDataReply) GetStatus() *Error

func (*SyncClusterMetaDataReply) ProtoMessage 

func (*SyncClusterMetaDataReply) ProtoMessage()

func (*SyncClusterMetaDataReply) ProtoReflect 

func (x *SyncClusterMetaDataReply) ProtoReflect() protoreflect.Message

func (*SyncClusterMetaDataReply) Reset 

func (x *SyncClusterMetaDataReply) Reset()

func (*SyncClusterMetaDataReply) String 

func (x *SyncClusterMetaDataReply) String() string

type SyncClusterMetaDataRequest 

type SyncClusterMetaDataRequest struct {

	// 集群名称   NOTE: 如果不指定, 则同步所有集群
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

The request message SyncClusterMetaData

func (*SyncClusterMetaDataRequest) Descriptor deprecated 

func (*SyncClusterMetaDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncClusterMetaDataRequest.ProtoReflect.Descriptor instead.

func (*SyncClusterMetaDataRequest) GetCluster 

func (x *SyncClusterMetaDataRequest) GetCluster() string

func (*SyncClusterMetaDataRequest) ProtoMessage 

func (*SyncClusterMetaDataRequest) ProtoMessage()

func (*SyncClusterMetaDataRequest) ProtoReflect 

func (x *SyncClusterMetaDataRequest) ProtoReflect() protoreflect.Message

func (*SyncClusterMetaDataRequest) Reset 

func (x *SyncClusterMetaDataRequest) Reset()

func (*SyncClusterMetaDataRequest) String 

func (x *SyncClusterMetaDataRequest) String() string

type SyncClustersReply 

type SyncClustersReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message SyncClusters

func (*SyncClustersReply) Descriptor deprecated 

func (*SyncClustersReply) Descriptor() ([]byte, []int)

Deprecated: Use SyncClustersReply.ProtoReflect.Descriptor instead.

func (*SyncClustersReply) GetStatus 

func (x *SyncClustersReply) GetStatus() *Error

func (*SyncClustersReply) ProtoMessage 

func (*SyncClustersReply) ProtoMessage()

func (*SyncClustersReply) ProtoReflect 

func (x *SyncClustersReply) ProtoReflect() protoreflect.Message

func (*SyncClustersReply) Reset 

func (x *SyncClustersReply) Reset()

func (*SyncClustersReply) String 

func (x *SyncClustersReply) String() string

type SyncClustersRequest 

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

The request message SyncClusters

func (*SyncClustersRequest) Descriptor deprecated 

func (*SyncClustersRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncClustersRequest.ProtoReflect.Descriptor instead.

func (*SyncClustersRequest) ProtoMessage 

func (*SyncClustersRequest) ProtoMessage()

func (*SyncClustersRequest) ProtoReflect 

func (x *SyncClustersRequest) ProtoReflect() protoreflect.Message

func (*SyncClustersRequest) Reset 

func (x *SyncClustersRequest) Reset()

func (*SyncClustersRequest) String 

func (x *SyncClustersRequest) String() string

type TimeRange 

type TimeRange struct {

	// 开始时间戳  十位时间戳
	StartTime int64 `protobuf:"varint,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// 结束时间戳  十位时间戳
	EndTime int64 `protobuf:"varint,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

TimeRange start_time and end_time range

func (*TimeRange) Descriptor deprecated 

func (*TimeRange) Descriptor() ([]byte, []int)

Deprecated: Use TimeRange.ProtoReflect.Descriptor instead.

func (*TimeRange) GetEndTime 

func (x *TimeRange) GetEndTime() int64

func (*TimeRange) GetStartTime 

func (x *TimeRange) GetStartTime() int64

func (*TimeRange) ProtoMessage 

func (*TimeRange) ProtoMessage()

func (*TimeRange) ProtoReflect 

func (x *TimeRange) ProtoReflect() protoreflect.Message

func (*TimeRange) Reset 

func (x *TimeRange) Reset()

func (*TimeRange) String 

func (x *TimeRange) String() string

type UnimplementedQMgmtServer 

type UnimplementedQMgmtServer struct {
}

UnimplementedQMgmtServer must be embedded to have forward compatible implementations.

func (UnimplementedQMgmtServer) CancelCollection 

func (UnimplementedQMgmtServer) CancelCollection(context.Context, *CancelCollectionRequest) (*CancelCollectionReply, error)

func (UnimplementedQMgmtServer) CollectionResource 

func (UnimplementedQMgmtServer) CollectionResource(context.Context, *CollectionResourceRequest) (*CollectionResourceReply, error)

func (UnimplementedQMgmtServer) DeleteAllData 

func (UnimplementedQMgmtServer) DeleteAllData(context.Context, *DeleteAllDataRequest) (*DeleteAllDataReply, error)

func (UnimplementedQMgmtServer) DeleteDistributedLock 

func (UnimplementedQMgmtServer) DeleteDistributedLock(context.Context, *DeleteDistributedLockRequest) (*DeleteDistributedLockReply, error)

func (UnimplementedQMgmtServer) GetAppDetailByID 

func (UnimplementedQMgmtServer) GetAppDetailByID(context.Context, *GetAppDetailByIDRequest) (*GetAppDetailByIDReply, error)

func (UnimplementedQMgmtServer) GetExchangeByID 

func (UnimplementedQMgmtServer) GetExchangeByID(context.Context, *GetExchangeByIDRequest) (*GetExchangeByIDReply, error)

func (UnimplementedQMgmtServer) GetQueueByID 

func (UnimplementedQMgmtServer) GetQueueByID(context.Context, *GetQueueByIDRequest) (*GetQueueByIDReply, error)

func (UnimplementedQMgmtServer) GetVhostsByClusterName 

func (UnimplementedQMgmtServer) GetVhostsByClusterName(context.Context, *GetVhostsByClusterNameRequest) (*GetVhostsByClusterNameReply, error)

func (UnimplementedQMgmtServer) HandlerSendBucSSOTokenDo 

func (UnimplementedQMgmtServer) HandlerSendBucSSOTokenDo(context.Context, *HandlerSendBucSSOTokenDoRequest) (*HandlerSendBucSSOTokenDoReply, error)

func (UnimplementedQMgmtServer) ListApps 

func (UnimplementedQMgmtServer) ListApps(context.Context, *ListAppsRequest) (*ListAppsReply, error)

func (UnimplementedQMgmtServer) ListAuditLog 

func (UnimplementedQMgmtServer) ListAuditLog(context.Context, *ListAuditLogRequest) (*ListAuditLogReply, error)

func (UnimplementedQMgmtServer) ListClusterNames 

func (UnimplementedQMgmtServer) ListClusterNames(context.Context, *ListClusterNamesRequest) (*ListClusterNamesReply, error)

func (UnimplementedQMgmtServer) ListClusters 

func (UnimplementedQMgmtServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersReply, error)

func (UnimplementedQMgmtServer) ListCollection 

func (UnimplementedQMgmtServer) ListCollection(context.Context, *ListCollectionRequest) (*ListCollectionReply, error)

func (UnimplementedQMgmtServer) ListCoreLevelApps 

func (UnimplementedQMgmtServer) ListCoreLevelApps(context.Context, *ListCoreLevelAppsRequest) (*ListCoreLevelAppsReply, error)

func (UnimplementedQMgmtServer) ListExchangesByName 

func (UnimplementedQMgmtServer) ListExchangesByName(context.Context, *ListExchangesByNameRequest) (*ListExchangesByNameReply, error)

func (UnimplementedQMgmtServer) ListMainLinkApps 

func (UnimplementedQMgmtServer) ListMainLinkApps(context.Context, *ListMainLinkAppsRequest) (*ListMainLinkAppsReply, error)

func (UnimplementedQMgmtServer) ListMetaDataByAppName 

func (UnimplementedQMgmtServer) ListMetaDataByAppName(context.Context, *ListMetaDataByAppNameRequest) (*ListMetaDataByAppNameReply, error)

func (UnimplementedQMgmtServer) ListMyselfApps 

func (UnimplementedQMgmtServer) ListMyselfApps(context.Context, *ListMyselfAppsRequest) (*ListMyselfAppsReply, error)

func (UnimplementedQMgmtServer) ListQueuesByName 

func (UnimplementedQMgmtServer) ListQueuesByName(context.Context, *ListQueuesByNameRequest) (*ListQueuesByNameReply, error)

func (UnimplementedQMgmtServer) LogOut 

func (UnimplementedQMgmtServer) LogOut(context.Context, *LogOutRequest) (*LogOutReply, error)

func (UnimplementedQMgmtServer) LoginStatus 

func (UnimplementedQMgmtServer) LoginStatus(context.Context, *LoginStatusRequest) (*LoginStatusReply, error)

func (UnimplementedQMgmtServer) ModifyExchangeAtribute 

func (UnimplementedQMgmtServer) ModifyExchangeAtribute(context.Context, *ModifyExchangeAtributeRequest) (*ModifyExchangeAtributeReply, error)

func (UnimplementedQMgmtServer) ModifyQueueAtribute 

func (UnimplementedQMgmtServer) ModifyQueueAtribute(context.Context, *ModifyQueueAtributeRequest) (*ModifyQueueAtributeReply, error)

func (UnimplementedQMgmtServer) MoveAmountQueuesToNode 

func (UnimplementedQMgmtServer) MoveAmountQueuesToNode(context.Context, *MoveAmountQueuesToNodeRequest) (*MoveAmountQueuesToNodeReply, error)

func (UnimplementedQMgmtServer) MoveQueuesToNode 

func (UnimplementedQMgmtServer) MoveQueuesToNode(context.Context, *MoveQueuesToNodeRequest) (*MoveQueuesToNodeReply, error)

func (UnimplementedQMgmtServer) NginxStatus 

func (UnimplementedQMgmtServer) NginxStatus(context.Context, *PingRequest) (*PingReply, error)

func (UnimplementedQMgmtServer) Ping 

func (UnimplementedQMgmtServer) Ping(context.Context, *PingRequest) (*PingReply, error)

func (UnimplementedQMgmtServer) SayHello 

func (UnimplementedQMgmtServer) SayHello(context.Context, *HelloRequest) (*HelloReply, error)

func (UnimplementedQMgmtServer) SyncApps 

func (UnimplementedQMgmtServer) SyncApps(context.Context, *SyncAppsRequest) (*SyncAppsReply, error)

func (UnimplementedQMgmtServer) SyncClusterMetaData 

func (UnimplementedQMgmtServer) SyncClusterMetaData(context.Context, *SyncClusterMetaDataRequest) (*SyncClusterMetaDataReply, error)

func (UnimplementedQMgmtServer) SyncClusters 

func (UnimplementedQMgmtServer) SyncClusters(context.Context, *SyncClustersRequest) (*SyncClustersReply, error)

func (UnimplementedQMgmtServer) UpdateDiamondExtConfig 

func (UnimplementedQMgmtServer) UpdateDiamondExtConfig(context.Context, *UpdateDiamondExtConfigRequest) (*UpdateDiamondExtConfigReply, error)

type UnsafeQMgmtServer 

type UnsafeQMgmtServer interface {
	// contains filtered or unexported methods
}

UnsafeQMgmtServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QMgmtServer will result in compilation errors.

type UpdateDiamondExtConfigReply 

type UpdateDiamondExtConfigReply struct {
	Status *Error `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The response message UpdateDiamondExtConfig

func (*UpdateDiamondExtConfigReply) Descriptor deprecated 

func (*UpdateDiamondExtConfigReply) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDiamondExtConfigReply.ProtoReflect.Descriptor instead.

func (*UpdateDiamondExtConfigReply) GetStatus 

func (x *UpdateDiamondExtConfigReply) GetStatus() *Error

func (*UpdateDiamondExtConfigReply) ProtoMessage 

func (*UpdateDiamondExtConfigReply) ProtoMessage()

func (*UpdateDiamondExtConfigReply) ProtoReflect 

func (x *UpdateDiamondExtConfigReply) ProtoReflect() protoreflect.Message

func (*UpdateDiamondExtConfigReply) Reset 

func (x *UpdateDiamondExtConfigReply) Reset()

func (*UpdateDiamondExtConfigReply) String 

func (x *UpdateDiamondExtConfigReply) String() string

type UpdateDiamondExtConfigRequest 

type UpdateDiamondExtConfigRequest struct {

	// diamond 配置内容  需要讲配置的 json 转义一下
	Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

The request message UpdateDiamondExtConfig

func (*UpdateDiamondExtConfigRequest) Descriptor deprecated 

func (*UpdateDiamondExtConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDiamondExtConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateDiamondExtConfigRequest) GetConfig 

func (x *UpdateDiamondExtConfigRequest) GetConfig() string

func (*UpdateDiamondExtConfigRequest) ProtoMessage 

func (*UpdateDiamondExtConfigRequest) ProtoMessage()

func (*UpdateDiamondExtConfigRequest) ProtoReflect 

func (x *UpdateDiamondExtConfigRequest) ProtoReflect() protoreflect.Message

func (*UpdateDiamondExtConfigRequest) Reset 

func (x *UpdateDiamondExtConfigRequest) Reset()

func (*UpdateDiamondExtConfigRequest) String 

func (x *UpdateDiamondExtConfigRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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