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) Enum

func (x BindingStatus) Enum() *BindingStatus

func (BindingStatus) EnumDescriptor deprecated

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

Deprecated: Use BindingStatus.Descriptor instead.

func (BindingStatus) Number

func (BindingStatus) String

func (x BindingStatus) String() string

func (BindingStatus) Type

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 (*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 (*CollectionResourceRequest) ProtoMessage

func (*CollectionResourceRequest) ProtoMessage()

func (*CollectionResourceRequest) ProtoReflect

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) Enum

func (x CollectionType) Enum() *CollectionType

func (CollectionType) EnumDescriptor deprecated

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

Deprecated: Use CollectionType.Descriptor instead.

func (CollectionType) Number

func (CollectionType) String

func (x CollectionType) String() string

func (CollectionType) Type

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

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 (*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 (*DeleteDistributedLockRequest) ProtoMessage

func (*DeleteDistributedLockRequest) ProtoMessage()

func (*DeleteDistributedLockRequest) ProtoReflect

func (*DeleteDistributedLockRequest) Reset

func (x *DeleteDistributedLockRequest) Reset()

func (*DeleteDistributedLockRequest) 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) Enum

func (x ExchangeType) Enum() *ExchangeType

func (ExchangeType) EnumDescriptor deprecated

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

Deprecated: Use ExchangeType.Descriptor instead.

func (ExchangeType) Number

func (ExchangeType) String

func (x ExchangeType) String() string

func (ExchangeType) Type

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 (*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 (*GetVhostsByClusterNameRequest) Reset

func (x *GetVhostsByClusterNameRequest) Reset()

func (*GetVhostsByClusterNameRequest) 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 (*HandlerSendBucSSOTokenDoReply) Reset

func (x *HandlerSendBucSSOTokenDoReply) Reset()

func (*HandlerSendBucSSOTokenDoReply) 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 (*HandlerSendBucSSOTokenDoRequest) Reset

func (*HandlerSendBucSSOTokenDoRequest) 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

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

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 (*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 (*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 (*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 (*ListMetaDataByAppNameRequest) GetVhost

func (x *ListMetaDataByAppNameRequest) GetVhost() string

func (*ListMetaDataByAppNameRequest) ProtoMessage

func (*ListMetaDataByAppNameRequest) ProtoMessage()

func (*ListMetaDataByAppNameRequest) ProtoReflect

func (*ListMetaDataByAppNameRequest) Reset

func (x *ListMetaDataByAppNameRequest) Reset()

func (*ListMetaDataByAppNameRequest) 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) Enum

func (x MessageBodySize) Enum() *MessageBodySize

func (MessageBodySize) EnumDescriptor deprecated

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

Deprecated: Use MessageBodySize.Descriptor instead.

func (MessageBodySize) Number

func (MessageBodySize) String

func (x MessageBodySize) String() string

func (MessageBodySize) Type

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 (*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 (*ModifyExchangeAtributeRequest) GetDescription

func (x *ModifyExchangeAtributeRequest) GetDescription() string

func (*ModifyExchangeAtributeRequest) GetId

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 (*ModifyExchangeAtributeRequest) Reset

func (x *ModifyExchangeAtributeRequest) Reset()

func (*ModifyExchangeAtributeRequest) 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 (*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 (*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 (*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 (*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 (*MoveAmountQueuesToNodeRequest) Reset

func (x *MoveAmountQueuesToNodeRequest) Reset()

func (*MoveAmountQueuesToNodeRequest) 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

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 (*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) CollectionResource

func (UnimplementedQMgmtServer) DeleteAllData

func (UnimplementedQMgmtServer) GetAppDetailByID

func (UnimplementedQMgmtServer) GetExchangeByID

func (UnimplementedQMgmtServer) GetQueueByID

func (UnimplementedQMgmtServer) ListApps

func (UnimplementedQMgmtServer) ListAuditLog

func (UnimplementedQMgmtServer) ListClusterNames

func (UnimplementedQMgmtServer) ListClusters

func (UnimplementedQMgmtServer) ListCollection

func (UnimplementedQMgmtServer) ListCoreLevelApps

func (UnimplementedQMgmtServer) ListMainLinkApps

func (UnimplementedQMgmtServer) ListMyselfApps

func (UnimplementedQMgmtServer) ListQueuesByName

func (UnimplementedQMgmtServer) LogOut

func (UnimplementedQMgmtServer) LoginStatus

func (UnimplementedQMgmtServer) MoveQueuesToNode

func (UnimplementedQMgmtServer) NginxStatus

func (UnimplementedQMgmtServer) Ping

func (UnimplementedQMgmtServer) SayHello

func (UnimplementedQMgmtServer) SyncApps

func (UnimplementedQMgmtServer) SyncClusters

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 (*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 (*UpdateDiamondExtConfigRequest) Reset

func (x *UpdateDiamondExtConfigRequest) Reset()

func (*UpdateDiamondExtConfigRequest) String

Jump to

Keyboard shortcuts

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