protocol

package
v0.0.0-...-a2e0f46 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0, BSD-3-Clause, MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ResponseHeader_Status_name = map[int32]string{
		0: "SUCCESS",
		1: "ERROR",
		2: "FATAL",
	}
	ResponseHeader_Status_value = map[string]int32{
		"SUCCESS": 0,
		"ERROR":   1,
		"FATAL":   2,
	}
)

Enum value maps for ResponseHeader_Status.

View Source 
var File_BrokerService_proto protoreflect.FileDescriptor
View Source 
var File_MasterService_proto protoreflect.FileDescriptor
View Source 
var File_RPC_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ApprovedClientConfig 

type ApprovedClientConfig struct {
	ConfigId   *int64 `protobuf:"varint,1,req,name=configId" json:"configId,omitempty"`
	MaxMsgSize *int32 `protobuf:"varint,2,opt,name=maxMsgSize" json:"maxMsgSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ApprovedClientConfig) Descriptor deprecated 

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

Deprecated: Use ApprovedClientConfig.ProtoReflect.Descriptor instead.

func (*ApprovedClientConfig) GetConfigId 

func (x *ApprovedClientConfig) GetConfigId() int64

func (*ApprovedClientConfig) GetMaxMsgSize 

func (x *ApprovedClientConfig) GetMaxMsgSize() int32

func (*ApprovedClientConfig) ProtoMessage 

func (*ApprovedClientConfig) ProtoMessage()

func (*ApprovedClientConfig) ProtoReflect 

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

func (*ApprovedClientConfig) Reset 

func (x *ApprovedClientConfig) Reset()

func (*ApprovedClientConfig) String 

func (x *ApprovedClientConfig) String() string

type AuthenticateInfo 

type AuthenticateInfo struct {
	UserName  *string `protobuf:"bytes,1,req,name=userName" json:"userName,omitempty"`
	Timestamp *int64  `protobuf:"varint,2,req,name=timestamp" json:"timestamp,omitempty"`
	Nonce     *int32  `protobuf:"varint,3,req,name=nonce" json:"nonce,omitempty"`
	OthParams *string `protobuf:"bytes,4,req,name=othParams" json:"othParams,omitempty"`
	Signature *string `protobuf:"bytes,5,req,name=signature" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthenticateInfo) Descriptor deprecated 

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

Deprecated: Use AuthenticateInfo.ProtoReflect.Descriptor instead.

func (*AuthenticateInfo) GetNonce 

func (x *AuthenticateInfo) GetNonce() int32

func (*AuthenticateInfo) GetOthParams 

func (x *AuthenticateInfo) GetOthParams() string

func (*AuthenticateInfo) GetSignature 

func (x *AuthenticateInfo) GetSignature() string

func (*AuthenticateInfo) GetTimestamp 

func (x *AuthenticateInfo) GetTimestamp() int64

func (*AuthenticateInfo) GetUserName 

func (x *AuthenticateInfo) GetUserName() string

func (*AuthenticateInfo) ProtoMessage 

func (*AuthenticateInfo) ProtoMessage()

func (*AuthenticateInfo) ProtoReflect 

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

func (*AuthenticateInfo) Reset 

func (x *AuthenticateInfo) Reset()

func (*AuthenticateInfo) String 

func (x *AuthenticateInfo) String() string

type AuthorizedInfo 

type AuthorizedInfo struct {
	VisitAuthorizedToken *int64  `protobuf:"varint,1,req,name=visitAuthorizedToken" json:"visitAuthorizedToken,omitempty"`
	AuthAuthorizedToken  *string `protobuf:"bytes,2,opt,name=authAuthorizedToken" json:"authAuthorizedToken,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthorizedInfo) Descriptor deprecated 

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

Deprecated: Use AuthorizedInfo.ProtoReflect.Descriptor instead.

func (*AuthorizedInfo) GetAuthAuthorizedToken 

func (x *AuthorizedInfo) GetAuthAuthorizedToken() string

func (*AuthorizedInfo) GetVisitAuthorizedToken 

func (x *AuthorizedInfo) GetVisitAuthorizedToken() int64

func (*AuthorizedInfo) ProtoMessage 

func (*AuthorizedInfo) ProtoMessage()

func (*AuthorizedInfo) ProtoReflect 

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

func (*AuthorizedInfo) Reset 

func (x *AuthorizedInfo) Reset()

func (*AuthorizedInfo) String 

func (x *AuthorizedInfo) String() string

type BrokerConfigInfo 

type BrokerConfigInfo struct {
	BrokerConfId     *int64             `protobuf:"varint,1,req,name=brokerConfId" json:"brokerConfId,omitempty"`
	ConfCheckSumId   *int32             `protobuf:"varint,2,req,name=confCheckSumId" json:"confCheckSumId,omitempty"`
	DefConfigInfo    *DefaultConfigInfo `protobuf:"bytes,3,opt,name=defConfigInfo" json:"defConfigInfo,omitempty"`
	TopicConfigInfos []*TopicConfigInfo `protobuf:"bytes,4,rep,name=topicConfigInfos" json:"topicConfigInfos,omitempty"`
	EnableTls        *bool              `protobuf:"varint,5,opt,name=enableTls" json:"enableTls,omitempty"`
	TlsPort          *int32             `protobuf:"varint,6,opt,name=tlsPort" json:"tlsPort,omitempty"`
	WebPort          *int32             `protobuf:"varint,7,opt,name=webPort" json:"webPort,omitempty"`
	// contains filtered or unexported fields
}

func (*BrokerConfigInfo) Descriptor deprecated 

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

Deprecated: Use BrokerConfigInfo.ProtoReflect.Descriptor instead.

func (*BrokerConfigInfo) GetBrokerConfId 

func (x *BrokerConfigInfo) GetBrokerConfId() int64

func (*BrokerConfigInfo) GetConfCheckSumId 

func (x *BrokerConfigInfo) GetConfCheckSumId() int32

func (*BrokerConfigInfo) GetDefConfigInfo 

func (x *BrokerConfigInfo) GetDefConfigInfo() *DefaultConfigInfo

func (*BrokerConfigInfo) GetEnableTls 

func (x *BrokerConfigInfo) GetEnableTls() bool

func (*BrokerConfigInfo) GetTlsPort 

func (x *BrokerConfigInfo) GetTlsPort() int32

func (*BrokerConfigInfo) GetTopicConfigInfos 

func (x *BrokerConfigInfo) GetTopicConfigInfos() []*TopicConfigInfo

func (*BrokerConfigInfo) GetWebPort 

func (x *BrokerConfigInfo) GetWebPort() int32

func (*BrokerConfigInfo) ProtoMessage 

func (*BrokerConfigInfo) ProtoMessage()

func (*BrokerConfigInfo) ProtoReflect 

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

func (*BrokerConfigInfo) Reset 

func (x *BrokerConfigInfo) Reset()

func (*BrokerConfigInfo) String 

func (x *BrokerConfigInfo) String() string

type BrokerOperateInfo 

type BrokerOperateInfo struct {
	OperateId *int32 `protobuf:"varint,1,req,name=operateId" json:"operateId,omitempty"`
	// 00:normal, 01:stop read, 10:stop write, 11:stop read and write
	FrcServiceStatus          *int32          `protobuf:"varint,2,req,name=frcServiceStatus" json:"frcServiceStatus,omitempty"`
	FrcRptConfig              *bool           `protobuf:"varint,3,opt,name=frcRptConfig" json:"frcRptConfig,omitempty"`
	EnableConsumeAuthenticate *bool           `protobuf:"varint,4,opt,name=enableConsumeAuthenticate" json:"enableConsumeAuthenticate,omitempty"`
	EnableConsumeAuthorize    *bool           `protobuf:"varint,5,opt,name=enableConsumeAuthorize" json:"enableConsumeAuthorize,omitempty"`
	EnableProduceAuthenticate *bool           `protobuf:"varint,6,opt,name=enableProduceAuthenticate" json:"enableProduceAuthenticate,omitempty"`
	EnableProduceAuthorize    *bool           `protobuf:"varint,7,opt,name=enableProduceAuthorize" json:"enableProduceAuthorize,omitempty"`
	EnableVisitTokenCheck     *bool           `protobuf:"varint,8,opt,name=enableVisitTokenCheck" json:"enableVisitTokenCheck,omitempty"`
	RmvTopicsInfo             []*TopicRmvInfo `protobuf:"bytes,9,rep,name=rmvTopicsInfo" json:"rmvTopicsInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*BrokerOperateInfo) Descriptor deprecated 

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

Deprecated: Use BrokerOperateInfo.ProtoReflect.Descriptor instead.

func (*BrokerOperateInfo) GetEnableConsumeAuthenticate 

func (x *BrokerOperateInfo) GetEnableConsumeAuthenticate() bool

func (*BrokerOperateInfo) GetEnableConsumeAuthorize 

func (x *BrokerOperateInfo) GetEnableConsumeAuthorize() bool

func (*BrokerOperateInfo) GetEnableProduceAuthenticate 

func (x *BrokerOperateInfo) GetEnableProduceAuthenticate() bool

func (*BrokerOperateInfo) GetEnableProduceAuthorize 

func (x *BrokerOperateInfo) GetEnableProduceAuthorize() bool

func (*BrokerOperateInfo) GetEnableVisitTokenCheck 

func (x *BrokerOperateInfo) GetEnableVisitTokenCheck() bool

func (*BrokerOperateInfo) GetFrcRptConfig 

func (x *BrokerOperateInfo) GetFrcRptConfig() bool

func (*BrokerOperateInfo) GetFrcServiceStatus 

func (x *BrokerOperateInfo) GetFrcServiceStatus() int32

func (*BrokerOperateInfo) GetOperateId 

func (x *BrokerOperateInfo) GetOperateId() int32

func (*BrokerOperateInfo) GetRmvTopicsInfo 

func (x *BrokerOperateInfo) GetRmvTopicsInfo() []*TopicRmvInfo

func (*BrokerOperateInfo) ProtoMessage 

func (*BrokerOperateInfo) ProtoMessage()

func (*BrokerOperateInfo) ProtoReflect 

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

func (*BrokerOperateInfo) Reset 

func (x *BrokerOperateInfo) Reset()

func (*BrokerOperateInfo) String 

func (x *BrokerOperateInfo) String() string

type BrokerPolicyInfo 

type BrokerPolicyInfo struct {
	PolicyId      *int64  `protobuf:"varint,1,opt,name=policyId" json:"policyId,omitempty"`
	QryPriorityId *int32  `protobuf:"varint,2,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	PolicyInfo    *string `protobuf:"bytes,3,opt,name=policyInfo" json:"policyInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*BrokerPolicyInfo) Descriptor deprecated 

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

Deprecated: Use BrokerPolicyInfo.ProtoReflect.Descriptor instead.

func (*BrokerPolicyInfo) GetPolicyId 

func (x *BrokerPolicyInfo) GetPolicyId() int64

func (*BrokerPolicyInfo) GetPolicyInfo 

func (x *BrokerPolicyInfo) GetPolicyInfo() string

func (*BrokerPolicyInfo) GetQryPriorityId 

func (x *BrokerPolicyInfo) GetQryPriorityId() int32

func (*BrokerPolicyInfo) ProtoMessage 

func (*BrokerPolicyInfo) ProtoMessage()

func (*BrokerPolicyInfo) ProtoReflect 

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

func (*BrokerPolicyInfo) Reset 

func (x *BrokerPolicyInfo) Reset()

func (*BrokerPolicyInfo) String 

func (x *BrokerPolicyInfo) String() string

type BrokerStatusInfo 

type BrokerStatusInfo struct {
	IsOnline       *bool  `protobuf:"varint,1,req,name=isOnline" json:"isOnline,omitempty"`
	ReadStatusRpt  *int32 `protobuf:"varint,2,req,name=readStatusRpt" json:"readStatusRpt,omitempty"`
	WriteStatusRpt *int32 `protobuf:"varint,3,req,name=writeStatusRpt" json:"writeStatusRpt,omitempty"`
	LastOperateId  *int32 `protobuf:"varint,4,opt,name=lastOperateId" json:"lastOperateId,omitempty"`
	// contains filtered or unexported fields
}

func (*BrokerStatusInfo) Descriptor deprecated 

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

Deprecated: Use BrokerStatusInfo.ProtoReflect.Descriptor instead.

func (*BrokerStatusInfo) GetIsOnline 

func (x *BrokerStatusInfo) GetIsOnline() bool

func (*BrokerStatusInfo) GetLastOperateId 

func (x *BrokerStatusInfo) GetLastOperateId() int32

func (*BrokerStatusInfo) GetReadStatusRpt 

func (x *BrokerStatusInfo) GetReadStatusRpt() int32

func (*BrokerStatusInfo) GetWriteStatusRpt 

func (x *BrokerStatusInfo) GetWriteStatusRpt() int32

func (*BrokerStatusInfo) ProtoMessage 

func (*BrokerStatusInfo) ProtoMessage()

func (*BrokerStatusInfo) ProtoReflect 

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

func (*BrokerStatusInfo) Reset 

func (x *BrokerStatusInfo) Reset()

func (*BrokerStatusInfo) String 

func (x *BrokerStatusInfo) String() string

type CloseRequestB2M 

type CloseRequestB2M struct {
	BrokerId *string                `protobuf:"bytes,1,req,name=brokerId" json:"brokerId,omitempty"`
	AuthInfo *MasterCertificateInfo `protobuf:"bytes,2,opt,name=authInfo" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseRequestB2M) Descriptor deprecated 

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

Deprecated: Use CloseRequestB2M.ProtoReflect.Descriptor instead.

func (*CloseRequestB2M) GetAuthInfo 

func (x *CloseRequestB2M) GetAuthInfo() *MasterCertificateInfo

func (*CloseRequestB2M) GetBrokerId 

func (x *CloseRequestB2M) GetBrokerId() string

func (*CloseRequestB2M) ProtoMessage 

func (*CloseRequestB2M) ProtoMessage()

func (*CloseRequestB2M) ProtoReflect 

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

func (*CloseRequestB2M) Reset 

func (x *CloseRequestB2M) Reset()

func (*CloseRequestB2M) String 

func (x *CloseRequestB2M) String() string

type CloseRequestC2M 

type CloseRequestC2M struct {
	ClientId  *string                `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	GroupName *string                `protobuf:"bytes,2,req,name=groupName" json:"groupName,omitempty"`
	AuthInfo  *MasterCertificateInfo `protobuf:"bytes,3,opt,name=authInfo" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseRequestC2M) Descriptor deprecated 

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

Deprecated: Use CloseRequestC2M.ProtoReflect.Descriptor instead.

func (*CloseRequestC2M) GetAuthInfo 

func (x *CloseRequestC2M) GetAuthInfo() *MasterCertificateInfo

func (*CloseRequestC2M) GetClientId 

func (x *CloseRequestC2M) GetClientId() string

func (*CloseRequestC2M) GetGroupName 

func (x *CloseRequestC2M) GetGroupName() string

func (*CloseRequestC2M) ProtoMessage 

func (*CloseRequestC2M) ProtoMessage()

func (*CloseRequestC2M) ProtoReflect 

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

func (*CloseRequestC2M) Reset 

func (x *CloseRequestC2M) Reset()

func (*CloseRequestC2M) String 

func (x *CloseRequestC2M) String() string

type CloseRequestP2M 

type CloseRequestP2M struct {
	ClientId *string                `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	AuthInfo *MasterCertificateInfo `protobuf:"bytes,2,opt,name=authInfo" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseRequestP2M) Descriptor deprecated 

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

Deprecated: Use CloseRequestP2M.ProtoReflect.Descriptor instead.

func (*CloseRequestP2M) GetAuthInfo 

func (x *CloseRequestP2M) GetAuthInfo() *MasterCertificateInfo

func (*CloseRequestP2M) GetClientId 

func (x *CloseRequestP2M) GetClientId() string

func (*CloseRequestP2M) ProtoMessage 

func (*CloseRequestP2M) ProtoMessage()

func (*CloseRequestP2M) ProtoReflect 

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

func (*CloseRequestP2M) Reset 

func (x *CloseRequestP2M) Reset()

func (*CloseRequestP2M) String 

func (x *CloseRequestP2M) String() string

type CloseRequest_V2_B2M 

type CloseRequest_V2_B2M struct {
	BrokerId *string                `protobuf:"bytes,1,req,name=brokerId" json:"brokerId,omitempty"`
	AuthInfo *MasterCertificateInfo `protobuf:"bytes,2,opt,name=authInfo" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseRequest_V2_B2M) Descriptor deprecated 

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

Deprecated: Use CloseRequest_V2_B2M.ProtoReflect.Descriptor instead.

func (*CloseRequest_V2_B2M) GetAuthInfo 

func (x *CloseRequest_V2_B2M) GetAuthInfo() *MasterCertificateInfo

func (*CloseRequest_V2_B2M) GetBrokerId 

func (x *CloseRequest_V2_B2M) GetBrokerId() string

func (*CloseRequest_V2_B2M) ProtoMessage 

func (*CloseRequest_V2_B2M) ProtoMessage()

func (*CloseRequest_V2_B2M) ProtoReflect 

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

func (*CloseRequest_V2_B2M) Reset 

func (x *CloseRequest_V2_B2M) Reset()

func (*CloseRequest_V2_B2M) String 

func (x *CloseRequest_V2_B2M) String() string

type CloseResponseM2B 

type CloseResponseM2B struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode *int32  `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg  *string `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseResponseM2B) Descriptor deprecated 

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

Deprecated: Use CloseResponseM2B.ProtoReflect.Descriptor instead.

func (*CloseResponseM2B) GetErrCode 

func (x *CloseResponseM2B) GetErrCode() int32

func (*CloseResponseM2B) GetErrMsg 

func (x *CloseResponseM2B) GetErrMsg() string

func (*CloseResponseM2B) GetSuccess 

func (x *CloseResponseM2B) GetSuccess() bool

func (*CloseResponseM2B) ProtoMessage 

func (*CloseResponseM2B) ProtoMessage()

func (*CloseResponseM2B) ProtoReflect 

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

func (*CloseResponseM2B) Reset 

func (x *CloseResponseM2B) Reset()

func (*CloseResponseM2B) String 

func (x *CloseResponseM2B) String() string

type CloseResponseM2C 

type CloseResponseM2C struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode *int32  `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg  *string `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseResponseM2C) Descriptor deprecated 

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

Deprecated: Use CloseResponseM2C.ProtoReflect.Descriptor instead.

func (*CloseResponseM2C) GetErrCode 

func (x *CloseResponseM2C) GetErrCode() int32

func (*CloseResponseM2C) GetErrMsg 

func (x *CloseResponseM2C) GetErrMsg() string

func (*CloseResponseM2C) GetSuccess 

func (x *CloseResponseM2C) GetSuccess() bool

func (*CloseResponseM2C) ProtoMessage 

func (*CloseResponseM2C) ProtoMessage()

func (*CloseResponseM2C) ProtoReflect 

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

func (*CloseResponseM2C) Reset 

func (x *CloseResponseM2C) Reset()

func (*CloseResponseM2C) String 

func (x *CloseResponseM2C) String() string

type CloseResponseM2P 

type CloseResponseM2P struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode *int32  `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg  *string `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseResponseM2P) Descriptor deprecated 

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

Deprecated: Use CloseResponseM2P.ProtoReflect.Descriptor instead.

func (*CloseResponseM2P) GetErrCode 

func (x *CloseResponseM2P) GetErrCode() int32

func (*CloseResponseM2P) GetErrMsg 

func (x *CloseResponseM2P) GetErrMsg() string

func (*CloseResponseM2P) GetSuccess 

func (x *CloseResponseM2P) GetSuccess() bool

func (*CloseResponseM2P) ProtoMessage 

func (*CloseResponseM2P) ProtoMessage()

func (*CloseResponseM2P) ProtoReflect 

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

func (*CloseResponseM2P) Reset 

func (x *CloseResponseM2P) Reset()

func (*CloseResponseM2P) String 

func (x *CloseResponseM2P) String() string

type CloseResponse_V2_M2B 

type CloseResponse_V2_M2B struct {
	ErrCode *int32  `protobuf:"varint,1,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg  *string `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseResponse_V2_M2B) Descriptor deprecated 

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

Deprecated: Use CloseResponse_V2_M2B.ProtoReflect.Descriptor instead.

func (*CloseResponse_V2_M2B) GetErrCode 

func (x *CloseResponse_V2_M2B) GetErrCode() int32

func (*CloseResponse_V2_M2B) GetErrMsg 

func (x *CloseResponse_V2_M2B) GetErrMsg() string

func (*CloseResponse_V2_M2B) ProtoMessage 

func (*CloseResponse_V2_M2B) ProtoMessage()

func (*CloseResponse_V2_M2B) ProtoReflect 

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

func (*CloseResponse_V2_M2B) Reset 

func (x *CloseResponse_V2_M2B) Reset()

func (*CloseResponse_V2_M2B) String 

func (x *CloseResponse_V2_M2B) String() string

type ClusterConfig 

type ClusterConfig struct {
	ConfigId   *int64 `protobuf:"varint,1,req,name=configId" json:"configId,omitempty"`
	MaxMsgSize *int32 `protobuf:"varint,2,opt,name=maxMsgSize" json:"maxMsgSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterConfig) Descriptor deprecated 

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

Deprecated: Use ClusterConfig.ProtoReflect.Descriptor instead.

func (*ClusterConfig) GetConfigId 

func (x *ClusterConfig) GetConfigId() int64

func (*ClusterConfig) GetMaxMsgSize 

func (x *ClusterConfig) GetMaxMsgSize() int32

func (*ClusterConfig) ProtoMessage 

func (*ClusterConfig) ProtoMessage()

func (*ClusterConfig) ProtoReflect 

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

func (*ClusterConfig) Reset 

func (x *ClusterConfig) Reset()

func (*ClusterConfig) String 

func (x *ClusterConfig) String() string

type CommitOffsetRequestC2B 

type CommitOffsetRequestC2B struct {
	ClientId         *string `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	TopicName        *string `protobuf:"bytes,2,req,name=topicName" json:"topicName,omitempty"`
	PartitionId      *int32  `protobuf:"varint,3,req,name=partitionId" json:"partitionId,omitempty"`
	GroupName        *string `protobuf:"bytes,4,req,name=groupName" json:"groupName,omitempty"`
	LastPackConsumed *bool   `protobuf:"varint,5,opt,name=lastPackConsumed" json:"lastPackConsumed,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitOffsetRequestC2B) Descriptor deprecated 

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

Deprecated: Use CommitOffsetRequestC2B.ProtoReflect.Descriptor instead.

func (*CommitOffsetRequestC2B) GetClientId 

func (x *CommitOffsetRequestC2B) GetClientId() string

func (*CommitOffsetRequestC2B) GetGroupName 

func (x *CommitOffsetRequestC2B) GetGroupName() string

func (*CommitOffsetRequestC2B) GetLastPackConsumed 

func (x *CommitOffsetRequestC2B) GetLastPackConsumed() bool

func (*CommitOffsetRequestC2B) GetPartitionId 

func (x *CommitOffsetRequestC2B) GetPartitionId() int32

func (*CommitOffsetRequestC2B) GetTopicName 

func (x *CommitOffsetRequestC2B) GetTopicName() string

func (*CommitOffsetRequestC2B) ProtoMessage 

func (*CommitOffsetRequestC2B) ProtoMessage()

func (*CommitOffsetRequestC2B) ProtoReflect 

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

func (*CommitOffsetRequestC2B) Reset 

func (x *CommitOffsetRequestC2B) Reset()

func (*CommitOffsetRequestC2B) String 

func (x *CommitOffsetRequestC2B) String() string

type CommitOffsetResponseB2C 

type CommitOffsetResponseB2C struct {
	Success    *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode    *int32  `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg     *string `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	CurrOffset *int64  `protobuf:"varint,4,opt,name=currOffset" json:"currOffset,omitempty"`
	MaxOffset  *int64  `protobuf:"varint,5,opt,name=maxOffset" json:"maxOffset,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitOffsetResponseB2C) Descriptor deprecated 

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

Deprecated: Use CommitOffsetResponseB2C.ProtoReflect.Descriptor instead.

func (*CommitOffsetResponseB2C) GetCurrOffset 

func (x *CommitOffsetResponseB2C) GetCurrOffset() int64

func (*CommitOffsetResponseB2C) GetErrCode 

func (x *CommitOffsetResponseB2C) GetErrCode() int32

func (*CommitOffsetResponseB2C) GetErrMsg 

func (x *CommitOffsetResponseB2C) GetErrMsg() string

func (*CommitOffsetResponseB2C) GetMaxOffset 

func (x *CommitOffsetResponseB2C) GetMaxOffset() int64

func (*CommitOffsetResponseB2C) GetSuccess 

func (x *CommitOffsetResponseB2C) GetSuccess() bool

func (*CommitOffsetResponseB2C) ProtoMessage 

func (*CommitOffsetResponseB2C) ProtoMessage()

func (*CommitOffsetResponseB2C) ProtoReflect 

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

func (*CommitOffsetResponseB2C) Reset 

func (x *CommitOffsetResponseB2C) Reset()

func (*CommitOffsetResponseB2C) String 

func (x *CommitOffsetResponseB2C) String() string

type DataStorePath 

type DataStorePath struct {
	RecordId  *int32  `protobuf:"varint,1,req,name=recordId" json:"recordId,omitempty"`
	IsActive  *bool   `protobuf:"varint,2,req,name=isActive" json:"isActive,omitempty"`
	IsDefPath *bool   `protobuf:"varint,3,req,name=isDefPath" json:"isDefPath,omitempty"`
	DataPath  *string `protobuf:"bytes,4,opt,name=dataPath" json:"dataPath,omitempty"`
	// contains filtered or unexported fields
}

func (*DataStorePath) Descriptor deprecated 

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

Deprecated: Use DataStorePath.ProtoReflect.Descriptor instead.

func (*DataStorePath) GetDataPath 

func (x *DataStorePath) GetDataPath() string

func (*DataStorePath) GetIsActive 

func (x *DataStorePath) GetIsActive() bool

func (*DataStorePath) GetIsDefPath 

func (x *DataStorePath) GetIsDefPath() bool

func (*DataStorePath) GetRecordId 

func (x *DataStorePath) GetRecordId() int32

func (*DataStorePath) ProtoMessage 

func (*DataStorePath) ProtoMessage()

func (*DataStorePath) ProtoReflect 

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

func (*DataStorePath) Reset 

func (x *DataStorePath) Reset()

func (*DataStorePath) String 

func (x *DataStorePath) String() string

type DefaultConfigInfo 

type DefaultConfigInfo struct {
	NumTopicStores    *int32  `protobuf:"varint,1,req,name=numTopicStores" json:"numTopicStores,omitempty"`
	NumPartitions     *int32  `protobuf:"varint,2,req,name=numPartitions" json:"numPartitions,omitempty"`
	UnflushMsgCnt     *int32  `protobuf:"varint,3,req,name=unflushMsgCnt" json:"unflushMsgCnt,omitempty"`
	UnflushInterval   *int32  `protobuf:"varint,4,req,name=unflushInterval" json:"unflushInterval,omitempty"`
	UnflushDataSize   *int32  `protobuf:"varint,5,req,name=unflushDataSize" json:"unflushDataSize,omitempty"`
	MemCacheBlockSize *int32  `protobuf:"varint,6,req,name=memCacheBlockSize" json:"memCacheBlockSize,omitempty"`
	NumMemCacheBlock  *int32  `protobuf:"varint,7,req,name=numMemCacheBlock" json:"numMemCacheBlock,omitempty"`
	BathDiskWriteUnit *int32  `protobuf:"varint,8,req,name=bathDiskWriteUnit" json:"bathDiskWriteUnit,omitempty"`
	BathDiskReadUnit  *int32  `protobuf:"varint,9,req,name=bathDiskReadUnit" json:"bathDiskReadUnit,omitempty"`
	AcceptPublish     *bool   `protobuf:"varint,10,req,name=acceptPublish" json:"acceptPublish,omitempty"`
	AcceptSubscribe   *bool   `protobuf:"varint,11,req,name=acceptSubscribe" json:"acceptSubscribe,omitempty"`
	DeletePolicy      *string `protobuf:"bytes,12,req,name=deletePolicy" json:"deletePolicy,omitempty"`
	// contains filtered or unexported fields
}

func (*DefaultConfigInfo) Descriptor deprecated 

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

Deprecated: Use DefaultConfigInfo.ProtoReflect.Descriptor instead.

func (*DefaultConfigInfo) GetAcceptPublish 

func (x *DefaultConfigInfo) GetAcceptPublish() bool

func (*DefaultConfigInfo) GetAcceptSubscribe 

func (x *DefaultConfigInfo) GetAcceptSubscribe() bool

func (*DefaultConfigInfo) GetBathDiskReadUnit 

func (x *DefaultConfigInfo) GetBathDiskReadUnit() int32

func (*DefaultConfigInfo) GetBathDiskWriteUnit 

func (x *DefaultConfigInfo) GetBathDiskWriteUnit() int32

func (*DefaultConfigInfo) GetDeletePolicy 

func (x *DefaultConfigInfo) GetDeletePolicy() string

func (*DefaultConfigInfo) GetMemCacheBlockSize 

func (x *DefaultConfigInfo) GetMemCacheBlockSize() int32

func (*DefaultConfigInfo) GetNumMemCacheBlock 

func (x *DefaultConfigInfo) GetNumMemCacheBlock() int32

func (*DefaultConfigInfo) GetNumPartitions 

func (x *DefaultConfigInfo) GetNumPartitions() int32

func (*DefaultConfigInfo) GetNumTopicStores 

func (x *DefaultConfigInfo) GetNumTopicStores() int32

func (*DefaultConfigInfo) GetUnflushDataSize 

func (x *DefaultConfigInfo) GetUnflushDataSize() int32

func (*DefaultConfigInfo) GetUnflushInterval 

func (x *DefaultConfigInfo) GetUnflushInterval() int32

func (*DefaultConfigInfo) GetUnflushMsgCnt 

func (x *DefaultConfigInfo) GetUnflushMsgCnt() int32

func (*DefaultConfigInfo) ProtoMessage 

func (*DefaultConfigInfo) ProtoMessage()

func (*DefaultConfigInfo) ProtoReflect 

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

func (*DefaultConfigInfo) Reset 

func (x *DefaultConfigInfo) Reset()

func (*DefaultConfigInfo) String 

func (x *DefaultConfigInfo) String() string

type EnableBrokerFunInfo 

type EnableBrokerFunInfo struct {
	EnableConsumeAuthenticate *bool `protobuf:"varint,1,req,name=enableConsumeAuthenticate" json:"enableConsumeAuthenticate,omitempty"`
	EnableConsumeAuthorize    *bool `protobuf:"varint,2,req,name=enableConsumeAuthorize" json:"enableConsumeAuthorize,omitempty"`
	EnableProduceAuthenticate *bool `protobuf:"varint,3,req,name=enableProduceAuthenticate" json:"enableProduceAuthenticate,omitempty"`
	EnableProduceAuthorize    *bool `protobuf:"varint,4,req,name=enableProduceAuthorize" json:"enableProduceAuthorize,omitempty"`
	EnableVisitTokenCheck     *bool `protobuf:"varint,5,opt,name=enableVisitTokenCheck" json:"enableVisitTokenCheck,omitempty"`
	// contains filtered or unexported fields
}

func (*EnableBrokerFunInfo) Descriptor deprecated 

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

Deprecated: Use EnableBrokerFunInfo.ProtoReflect.Descriptor instead.

func (*EnableBrokerFunInfo) GetEnableConsumeAuthenticate 

func (x *EnableBrokerFunInfo) GetEnableConsumeAuthenticate() bool

func (*EnableBrokerFunInfo) GetEnableConsumeAuthorize 

func (x *EnableBrokerFunInfo) GetEnableConsumeAuthorize() bool

func (*EnableBrokerFunInfo) GetEnableProduceAuthenticate 

func (x *EnableBrokerFunInfo) GetEnableProduceAuthenticate() bool

func (*EnableBrokerFunInfo) GetEnableProduceAuthorize 

func (x *EnableBrokerFunInfo) GetEnableProduceAuthorize() bool

func (*EnableBrokerFunInfo) GetEnableVisitTokenCheck 

func (x *EnableBrokerFunInfo) GetEnableVisitTokenCheck() bool

func (*EnableBrokerFunInfo) ProtoMessage 

func (*EnableBrokerFunInfo) ProtoMessage()

func (*EnableBrokerFunInfo) ProtoReflect 

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

func (*EnableBrokerFunInfo) Reset 

func (x *EnableBrokerFunInfo) Reset()

func (*EnableBrokerFunInfo) String 

func (x *EnableBrokerFunInfo) String() string

type EventProto 

type EventProto struct {
	RebalanceId *int64 `protobuf:"varint,1,opt,name=rebalanceId" json:"rebalanceId,omitempty"`
	OpType      *int32 `protobuf:"varint,2,opt,name=opType" json:"opType,omitempty"`
	Status      *int32 `protobuf:"varint,3,opt,name=status" json:"status,omitempty"`
	// consumerId@group-brokerId:host:port-topic:partitionId
	SubscribeInfo []string `protobuf:"bytes,4,rep,name=subscribeInfo" json:"subscribeInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*EventProto) Descriptor deprecated 

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

Deprecated: Use EventProto.ProtoReflect.Descriptor instead.

func (*EventProto) GetOpType 

func (x *EventProto) GetOpType() int32

func (*EventProto) GetRebalanceId 

func (x *EventProto) GetRebalanceId() int64

func (*EventProto) GetStatus 

func (x *EventProto) GetStatus() int32

func (*EventProto) GetSubscribeInfo 

func (x *EventProto) GetSubscribeInfo() []string

func (*EventProto) ProtoMessage 

func (*EventProto) ProtoMessage()

func (*EventProto) ProtoReflect 

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

func (*EventProto) Reset 

func (x *EventProto) Reset()

func (*EventProto) String 

func (x *EventProto) String() string

type GetMessageRequestC2B 

type GetMessageRequestC2B struct {
	ClientId           *string `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	PartitionId        *int32  `protobuf:"varint,2,req,name=partitionId" json:"partitionId,omitempty"`
	GroupName          *string `protobuf:"bytes,3,req,name=groupName" json:"groupName,omitempty"`
	TopicName          *string `protobuf:"bytes,4,req,name=topicName" json:"topicName,omitempty"`
	LastPackConsumed   *bool   `protobuf:"varint,5,opt,name=lastPackConsumed" json:"lastPackConsumed,omitempty"`
	ManualCommitOffset *bool   `protobuf:"varint,6,opt,name=manualCommitOffset" json:"manualCommitOffset,omitempty"`
	EscFlowCtrl        *bool   `protobuf:"varint,7,opt,name=escFlowCtrl" json:"escFlowCtrl,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMessageRequestC2B) Descriptor deprecated 

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

Deprecated: Use GetMessageRequestC2B.ProtoReflect.Descriptor instead.

func (*GetMessageRequestC2B) GetClientId 

func (x *GetMessageRequestC2B) GetClientId() string

func (*GetMessageRequestC2B) GetEscFlowCtrl 

func (x *GetMessageRequestC2B) GetEscFlowCtrl() bool

func (*GetMessageRequestC2B) GetGroupName 

func (x *GetMessageRequestC2B) GetGroupName() string

func (*GetMessageRequestC2B) GetLastPackConsumed 

func (x *GetMessageRequestC2B) GetLastPackConsumed() bool

func (*GetMessageRequestC2B) GetManualCommitOffset 

func (x *GetMessageRequestC2B) GetManualCommitOffset() bool

func (*GetMessageRequestC2B) GetPartitionId 

func (x *GetMessageRequestC2B) GetPartitionId() int32

func (*GetMessageRequestC2B) GetTopicName 

func (x *GetMessageRequestC2B) GetTopicName() string

func (*GetMessageRequestC2B) ProtoMessage 

func (*GetMessageRequestC2B) ProtoMessage()

func (*GetMessageRequestC2B) ProtoReflect 

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

func (*GetMessageRequestC2B) Reset 

func (x *GetMessageRequestC2B) Reset()

func (*GetMessageRequestC2B) String 

func (x *GetMessageRequestC2B) String() string

type GetMessageResponseB2C 

type GetMessageResponseB2C struct {
	Success      *bool                `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode      *int32               `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg       *string              `protobuf:"bytes,3,opt,name=errMsg" json:"errMsg,omitempty"`
	Messages     []*TransferedMessage `protobuf:"bytes,4,rep,name=messages" json:"messages,omitempty"`
	CurrOffset   *int64               `protobuf:"varint,5,opt,name=currOffset" json:"currOffset,omitempty"`
	MinLimitTime *int32               `protobuf:"varint,6,opt,name=minLimitTime" json:"minLimitTime,omitempty"`
	EscFlowCtrl  *bool                `protobuf:"varint,7,opt,name=escFlowCtrl" json:"escFlowCtrl,omitempty"`
	CurrDataDlt  *int64               `protobuf:"varint,8,opt,name=currDataDlt" json:"currDataDlt,omitempty"`
	RequireSlow  *bool                `protobuf:"varint,9,opt,name=requireSlow" json:"requireSlow,omitempty"`
	MaxOffset    *int64               `protobuf:"varint,10,opt,name=maxOffset" json:"maxOffset,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMessageResponseB2C) Descriptor deprecated 

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

Deprecated: Use GetMessageResponseB2C.ProtoReflect.Descriptor instead.

func (*GetMessageResponseB2C) GetCurrDataDlt 

func (x *GetMessageResponseB2C) GetCurrDataDlt() int64

func (*GetMessageResponseB2C) GetCurrOffset 

func (x *GetMessageResponseB2C) GetCurrOffset() int64

func (*GetMessageResponseB2C) GetErrCode 

func (x *GetMessageResponseB2C) GetErrCode() int32

func (*GetMessageResponseB2C) GetErrMsg 

func (x *GetMessageResponseB2C) GetErrMsg() string

func (*GetMessageResponseB2C) GetEscFlowCtrl 

func (x *GetMessageResponseB2C) GetEscFlowCtrl() bool

func (*GetMessageResponseB2C) GetMaxOffset 

func (x *GetMessageResponseB2C) GetMaxOffset() int64

func (*GetMessageResponseB2C) GetMessages 

func (x *GetMessageResponseB2C) GetMessages() []*TransferedMessage

func (*GetMessageResponseB2C) GetMinLimitTime 

func (x *GetMessageResponseB2C) GetMinLimitTime() int32

func (*GetMessageResponseB2C) GetRequireSlow 

func (x *GetMessageResponseB2C) GetRequireSlow() bool

func (*GetMessageResponseB2C) GetSuccess 

func (x *GetMessageResponseB2C) GetSuccess() bool

func (*GetMessageResponseB2C) ProtoMessage 

func (*GetMessageResponseB2C) ProtoMessage()

func (*GetMessageResponseB2C) ProtoReflect 

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

func (*GetMessageResponseB2C) Reset 

func (x *GetMessageResponseB2C) Reset()

func (*GetMessageResponseB2C) String 

func (x *GetMessageResponseB2C) String() string

type HeartBeatRequestC2B 

type HeartBeatRequestC2B struct {
	ClientId   *string `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	GroupName  *string `protobuf:"bytes,2,req,name=groupName" json:"groupName,omitempty"`
	ReadStatus *int32  `protobuf:"varint,3,req,name=readStatus" json:"readStatus,omitempty"`
	// brokerId:host:port:topic:partitionId:delayTimeStamp
	PartitionInfo []string        `protobuf:"bytes,4,rep,name=partitionInfo" json:"partitionInfo,omitempty"`
	SsdStoreId    *int64          `protobuf:"varint,5,opt,name=ssdStoreId" json:"ssdStoreId,omitempty"` // Deprecated
	QryPriorityId *int32          `protobuf:"varint,6,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	AuthInfo      *AuthorizedInfo `protobuf:"bytes,7,opt,name=authInfo" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartBeatRequestC2B) Descriptor deprecated 

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

Deprecated: Use HeartBeatRequestC2B.ProtoReflect.Descriptor instead.

func (*HeartBeatRequestC2B) GetAuthInfo 

func (x *HeartBeatRequestC2B) GetAuthInfo() *AuthorizedInfo

func (*HeartBeatRequestC2B) GetClientId 

func (x *HeartBeatRequestC2B) GetClientId() string

func (*HeartBeatRequestC2B) GetGroupName 

func (x *HeartBeatRequestC2B) GetGroupName() string

func (*HeartBeatRequestC2B) GetPartitionInfo 

func (x *HeartBeatRequestC2B) GetPartitionInfo() []string

func (*HeartBeatRequestC2B) GetQryPriorityId 

func (x *HeartBeatRequestC2B) GetQryPriorityId() int32

func (*HeartBeatRequestC2B) GetReadStatus 

func (x *HeartBeatRequestC2B) GetReadStatus() int32

func (*HeartBeatRequestC2B) GetSsdStoreId 

func (x *HeartBeatRequestC2B) GetSsdStoreId() int64

func (*HeartBeatRequestC2B) ProtoMessage 

func (*HeartBeatRequestC2B) ProtoMessage()

func (*HeartBeatRequestC2B) ProtoReflect 

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

func (*HeartBeatRequestC2B) Reset 

func (x *HeartBeatRequestC2B) Reset()

func (*HeartBeatRequestC2B) String 

func (x *HeartBeatRequestC2B) String() string

type HeartBeatResponseB2C 

type HeartBeatResponseB2C struct {
	Success        *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode        *int32  `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg         *string `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	HasPartFailure *bool   `protobuf:"varint,4,opt,name=hasPartFailure" json:"hasPartFailure,omitempty"`
	// failCode:brokerId:host:port:topic:partitionId:delayTimeStamp
	FailureInfo []string `protobuf:"bytes,5,rep,name=failureInfo" json:"failureInfo,omitempty"`
	RequireAuth *bool    `protobuf:"varint,6,opt,name=requireAuth" json:"requireAuth,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartBeatResponseB2C) Descriptor deprecated 

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

Deprecated: Use HeartBeatResponseB2C.ProtoReflect.Descriptor instead.

func (*HeartBeatResponseB2C) GetErrCode 

func (x *HeartBeatResponseB2C) GetErrCode() int32

func (*HeartBeatResponseB2C) GetErrMsg 

func (x *HeartBeatResponseB2C) GetErrMsg() string

func (*HeartBeatResponseB2C) GetFailureInfo 

func (x *HeartBeatResponseB2C) GetFailureInfo() []string

func (*HeartBeatResponseB2C) GetHasPartFailure 

func (x *HeartBeatResponseB2C) GetHasPartFailure() bool

func (*HeartBeatResponseB2C) GetRequireAuth 

func (x *HeartBeatResponseB2C) GetRequireAuth() bool

func (*HeartBeatResponseB2C) GetSuccess 

func (x *HeartBeatResponseB2C) GetSuccess() bool

func (*HeartBeatResponseB2C) ProtoMessage 

func (*HeartBeatResponseB2C) ProtoMessage()

func (*HeartBeatResponseB2C) ProtoReflect 

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

func (*HeartBeatResponseB2C) Reset 

func (x *HeartBeatResponseB2C) Reset()

func (*HeartBeatResponseB2C) String 

func (x *HeartBeatResponseB2C) String() string

type HeartRequestB2M 

type HeartRequestB2M struct {
	BrokerId             *string `protobuf:"bytes,1,req,name=brokerId" json:"brokerId,omitempty"`
	BrokerOnline         *bool   `protobuf:"varint,2,req,name=brokerOnline" json:"brokerOnline,omitempty"`
	ReadStatusRpt        *int32  `protobuf:"varint,3,req,name=readStatusRpt" json:"readStatusRpt,omitempty"`
	WriteStatusRpt       *int32  `protobuf:"varint,4,req,name=writeStatusRpt" json:"writeStatusRpt,omitempty"`
	CurBrokerConfId      *int64  `protobuf:"varint,5,req,name=curBrokerConfId" json:"curBrokerConfId,omitempty"`
	ConfCheckSumId       *int32  `protobuf:"varint,6,req,name=confCheckSumId" json:"confCheckSumId,omitempty"`
	TakeConfInfo         *bool   `protobuf:"varint,7,req,name=takeConfInfo" json:"takeConfInfo,omitempty"`
	TakeRemovedTopicInfo *bool   `protobuf:"varint,8,req,name=takeRemovedTopicInfo" json:"takeRemovedTopicInfo,omitempty"`
	// defaultPartNum:acceptPublish:acceptSubscribe:unflushThreshold:unflushInterval:deleteWhen:deletePolicy
	BrokerDefaultConfInfo *string `protobuf:"bytes,9,opt,name=brokerDefaultConfInfo" json:"brokerDefaultConfInfo,omitempty"`
	// topic:partNum:acceptPublish:acceptSubscribe:unflushThreshold:unflushInterval:deleteWhen:deletePolicy:filterStatusId:statusId:attributes
	BrokerTopicSetConfInfo []string               `protobuf:"bytes,10,rep,name=brokerTopicSetConfInfo" json:"brokerTopicSetConfInfo,omitempty"`
	RemovedTopicsInfo      []string               `protobuf:"bytes,11,rep,name=removedTopicsInfo" json:"removedTopicsInfo,omitempty"`
	SsdStoreId             *int64                 `protobuf:"varint,12,opt,name=ssdStoreId" json:"ssdStoreId,omitempty"` // Deprecated
	FlowCheckId            *int64                 `protobuf:"varint,13,opt,name=flowCheckId" json:"flowCheckId,omitempty"`
	QryPriorityId          *int32                 `protobuf:"varint,14,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	AuthInfo               *MasterCertificateInfo `protobuf:"bytes,15,opt,name=authInfo" json:"authInfo,omitempty"`
	ClsConfig              *ClusterConfig         `protobuf:"bytes,16,opt,name=clsConfig" json:"clsConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartRequestB2M) Descriptor deprecated 

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

Deprecated: Use HeartRequestB2M.ProtoReflect.Descriptor instead.

func (*HeartRequestB2M) GetAuthInfo 

func (x *HeartRequestB2M) GetAuthInfo() *MasterCertificateInfo

func (*HeartRequestB2M) GetBrokerDefaultConfInfo 

func (x *HeartRequestB2M) GetBrokerDefaultConfInfo() string

func (*HeartRequestB2M) GetBrokerId 

func (x *HeartRequestB2M) GetBrokerId() string

func (*HeartRequestB2M) GetBrokerOnline 

func (x *HeartRequestB2M) GetBrokerOnline() bool

func (*HeartRequestB2M) GetBrokerTopicSetConfInfo 

func (x *HeartRequestB2M) GetBrokerTopicSetConfInfo() []string

func (*HeartRequestB2M) GetClsConfig 

func (x *HeartRequestB2M) GetClsConfig() *ClusterConfig

func (*HeartRequestB2M) GetConfCheckSumId 

func (x *HeartRequestB2M) GetConfCheckSumId() int32

func (*HeartRequestB2M) GetCurBrokerConfId 

func (x *HeartRequestB2M) GetCurBrokerConfId() int64

func (*HeartRequestB2M) GetFlowCheckId 

func (x *HeartRequestB2M) GetFlowCheckId() int64

func (*HeartRequestB2M) GetQryPriorityId 

func (x *HeartRequestB2M) GetQryPriorityId() int32

func (*HeartRequestB2M) GetReadStatusRpt 

func (x *HeartRequestB2M) GetReadStatusRpt() int32

func (*HeartRequestB2M) GetRemovedTopicsInfo 

func (x *HeartRequestB2M) GetRemovedTopicsInfo() []string

func (*HeartRequestB2M) GetSsdStoreId 

func (x *HeartRequestB2M) GetSsdStoreId() int64

func (*HeartRequestB2M) GetTakeConfInfo 

func (x *HeartRequestB2M) GetTakeConfInfo() bool

func (*HeartRequestB2M) GetTakeRemovedTopicInfo 

func (x *HeartRequestB2M) GetTakeRemovedTopicInfo() bool

func (*HeartRequestB2M) GetWriteStatusRpt 

func (x *HeartRequestB2M) GetWriteStatusRpt() int32

func (*HeartRequestB2M) ProtoMessage 

func (*HeartRequestB2M) ProtoMessage()

func (*HeartRequestB2M) ProtoReflect 

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

func (*HeartRequestB2M) Reset 

func (x *HeartRequestB2M) Reset()

func (*HeartRequestB2M) String 

func (x *HeartRequestB2M) String() string

type HeartRequestC2M 

type HeartRequestC2M struct {
	ClientId            *string                `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	GroupName           *string                `protobuf:"bytes,2,req,name=groupName" json:"groupName,omitempty"`
	SubscribeInfo       []string               `protobuf:"bytes,3,rep,name=subscribeInfo" json:"subscribeInfo,omitempty"`
	ReportSubscribeInfo *bool                  `protobuf:"varint,4,req,name=reportSubscribeInfo" json:"reportSubscribeInfo,omitempty"`
	Event               *EventProto            `protobuf:"bytes,5,opt,name=event" json:"event,omitempty"`
	DefFlowCheckId      *int64                 `protobuf:"varint,6,opt,name=defFlowCheckId" json:"defFlowCheckId,omitempty"`
	GroupFlowCheckId    *int64                 `protobuf:"varint,7,opt,name=groupFlowCheckId" json:"groupFlowCheckId,omitempty"`
	SsdStoreId          *int64                 `protobuf:"varint,8,opt,name=ssdStoreId" json:"ssdStoreId,omitempty"` // Deprecated
	QryPriorityId       *int32                 `protobuf:"varint,9,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	AuthInfo            *MasterCertificateInfo `protobuf:"bytes,10,opt,name=authInfo" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartRequestC2M) Descriptor deprecated 

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

Deprecated: Use HeartRequestC2M.ProtoReflect.Descriptor instead.

func (*HeartRequestC2M) GetAuthInfo 

func (x *HeartRequestC2M) GetAuthInfo() *MasterCertificateInfo

func (*HeartRequestC2M) GetClientId 

func (x *HeartRequestC2M) GetClientId() string

func (*HeartRequestC2M) GetDefFlowCheckId 

func (x *HeartRequestC2M) GetDefFlowCheckId() int64

func (*HeartRequestC2M) GetEvent 

func (x *HeartRequestC2M) GetEvent() *EventProto

func (*HeartRequestC2M) GetGroupFlowCheckId 

func (x *HeartRequestC2M) GetGroupFlowCheckId() int64

func (*HeartRequestC2M) GetGroupName 

func (x *HeartRequestC2M) GetGroupName() string

func (*HeartRequestC2M) GetQryPriorityId 

func (x *HeartRequestC2M) GetQryPriorityId() int32

func (*HeartRequestC2M) GetReportSubscribeInfo 

func (x *HeartRequestC2M) GetReportSubscribeInfo() bool

func (*HeartRequestC2M) GetSsdStoreId 

func (x *HeartRequestC2M) GetSsdStoreId() int64

func (*HeartRequestC2M) GetSubscribeInfo 

func (x *HeartRequestC2M) GetSubscribeInfo() []string

func (*HeartRequestC2M) ProtoMessage 

func (*HeartRequestC2M) ProtoMessage()

func (*HeartRequestC2M) ProtoReflect 

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

func (*HeartRequestC2M) Reset 

func (x *HeartRequestC2M) Reset()

func (*HeartRequestC2M) String 

func (x *HeartRequestC2M) String() string

type HeartRequestP2M 

type HeartRequestP2M struct {
	ClientId       *string                `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	BrokerCheckSum *int64                 `protobuf:"varint,2,req,name=brokerCheckSum" json:"brokerCheckSum,omitempty"`
	HostName       *string                `protobuf:"bytes,3,req,name=hostName" json:"hostName,omitempty"`
	TopicList      []string               `protobuf:"bytes,4,rep,name=topicList" json:"topicList,omitempty"`
	AuthInfo       *MasterCertificateInfo `protobuf:"bytes,5,opt,name=authInfo" json:"authInfo,omitempty"`
	AppdConfig     *ApprovedClientConfig  `protobuf:"bytes,6,opt,name=appdConfig" json:"appdConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartRequestP2M) Descriptor deprecated 

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

Deprecated: Use HeartRequestP2M.ProtoReflect.Descriptor instead.

func (*HeartRequestP2M) GetAppdConfig 

func (x *HeartRequestP2M) GetAppdConfig() *ApprovedClientConfig

func (*HeartRequestP2M) GetAuthInfo 

func (x *HeartRequestP2M) GetAuthInfo() *MasterCertificateInfo

func (*HeartRequestP2M) GetBrokerCheckSum 

func (x *HeartRequestP2M) GetBrokerCheckSum() int64

func (*HeartRequestP2M) GetClientId 

func (x *HeartRequestP2M) GetClientId() string

func (*HeartRequestP2M) GetHostName 

func (x *HeartRequestP2M) GetHostName() string

func (*HeartRequestP2M) GetTopicList 

func (x *HeartRequestP2M) GetTopicList() []string

func (*HeartRequestP2M) ProtoMessage 

func (*HeartRequestP2M) ProtoMessage()

func (*HeartRequestP2M) ProtoReflect 

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

func (*HeartRequestP2M) Reset 

func (x *HeartRequestP2M) Reset()

func (*HeartRequestP2M) String 

func (x *HeartRequestP2M) String() string

type HeartRequest_V2_B2M 

type HeartRequest_V2_B2M struct {
	BrokerId      *string                `protobuf:"bytes,1,req,name=brokerId" json:"brokerId,omitempty"`
	StatusRptInfo *BrokerStatusInfo      `protobuf:"bytes,2,req,name=statusRptInfo" json:"statusRptInfo,omitempty"`
	ConfigInfo    *BrokerConfigInfo      `protobuf:"bytes,3,req,name=configInfo" json:"configInfo,omitempty"`
	PolicyInfo    *BrokerPolicyInfo      `protobuf:"bytes,4,opt,name=policyInfo" json:"policyInfo,omitempty"`
	AuthInfo      *MasterCertificateInfo `protobuf:"bytes,5,opt,name=authInfo" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartRequest_V2_B2M) Descriptor deprecated 

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

Deprecated: Use HeartRequest_V2_B2M.ProtoReflect.Descriptor instead.

func (*HeartRequest_V2_B2M) GetAuthInfo 

func (x *HeartRequest_V2_B2M) GetAuthInfo() *MasterCertificateInfo

func (*HeartRequest_V2_B2M) GetBrokerId 

func (x *HeartRequest_V2_B2M) GetBrokerId() string

func (*HeartRequest_V2_B2M) GetConfigInfo 

func (x *HeartRequest_V2_B2M) GetConfigInfo() *BrokerConfigInfo

func (*HeartRequest_V2_B2M) GetPolicyInfo 

func (x *HeartRequest_V2_B2M) GetPolicyInfo() *BrokerPolicyInfo

func (*HeartRequest_V2_B2M) GetStatusRptInfo 

func (x *HeartRequest_V2_B2M) GetStatusRptInfo() *BrokerStatusInfo

func (*HeartRequest_V2_B2M) ProtoMessage 

func (*HeartRequest_V2_B2M) ProtoMessage()

func (*HeartRequest_V2_B2M) ProtoReflect 

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

func (*HeartRequest_V2_B2M) Reset 

func (x *HeartRequest_V2_B2M) Reset()

func (*HeartRequest_V2_B2M) String 

func (x *HeartRequest_V2_B2M) String() string

type HeartResponseM2B 

type HeartResponseM2B struct {
	Success             *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode             *int32  `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg              *string `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	StopRead            *bool   `protobuf:"varint,4,req,name=stopRead" json:"stopRead,omitempty"`
	StopWrite           *bool   `protobuf:"varint,5,req,name=stopWrite" json:"stopWrite,omitempty"`
	CurBrokerConfId     *int64  `protobuf:"varint,6,req,name=curBrokerConfId" json:"curBrokerConfId,omitempty"`
	ConfCheckSumId      *int32  `protobuf:"varint,7,req,name=confCheckSumId" json:"confCheckSumId,omitempty"`
	NeedReportData      *bool   `protobuf:"varint,8,req,name=needReportData" json:"needReportData,omitempty"`
	TakeConfInfo        *bool   `protobuf:"varint,9,req,name=takeConfInfo" json:"takeConfInfo,omitempty"`
	TakeRemoveTopicInfo *bool   `protobuf:"varint,10,req,name=takeRemoveTopicInfo" json:"takeRemoveTopicInfo,omitempty"`
	// defaultPartNum:acceptPublish:acceptSubscribe:unflushThreshold:unflushInterval:deleteWhen:deletePolicy
	BrokerDefaultConfInfo *string `protobuf:"bytes,11,opt,name=brokerDefaultConfInfo" json:"brokerDefaultConfInfo,omitempty"`
	// topic:partNum:acceptPublish:acceptSubscribe:unflushThreshold:unflushInterval:deleteWhen:deletePolicy:filterStatusId:statusId:attributes
	BrokerTopicSetConfInfo []string `protobuf:"bytes,12,rep,name=brokerTopicSetConfInfo" json:"brokerTopicSetConfInfo,omitempty"`
	// topic:partNum:acceptPublish:acceptSubscribe:unflushThreshold:unflushInterval:deleteWhen:deletePolicy:filterStatusId:statusId:attributes
	RemoveTopicConfInfo  []string                    `protobuf:"bytes,13,rep,name=removeTopicConfInfo" json:"removeTopicConfInfo,omitempty"`
	SsdStoreId           *int64                      `protobuf:"varint,14,opt,name=ssdStoreId" json:"ssdStoreId,omitempty"` // Deprecated
	FlowCheckId          *int64                      `protobuf:"varint,15,opt,name=flowCheckId" json:"flowCheckId,omitempty"`
	FlowControlInfo      *string                     `protobuf:"bytes,16,opt,name=flowControlInfo" json:"flowControlInfo,omitempty"`
	QryPriorityId        *int32                      `protobuf:"varint,17,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	AuthorizedInfo       *MasterAuthorizedInfo       `protobuf:"bytes,18,opt,name=authorizedInfo" json:"authorizedInfo,omitempty"` // Deprecated
	BrokerAuthorizedInfo *MasterBrokerAuthorizedInfo `protobuf:"bytes,19,opt,name=brokerAuthorizedInfo" json:"brokerAuthorizedInfo,omitempty"`
	ClsConfig            *ClusterConfig              `protobuf:"bytes,20,opt,name=clsConfig" json:"clsConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartResponseM2B) Descriptor deprecated 

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

Deprecated: Use HeartResponseM2B.ProtoReflect.Descriptor instead.

func (*HeartResponseM2B) GetAuthorizedInfo 

func (x *HeartResponseM2B) GetAuthorizedInfo() *MasterAuthorizedInfo

func (*HeartResponseM2B) GetBrokerAuthorizedInfo 

func (x *HeartResponseM2B) GetBrokerAuthorizedInfo() *MasterBrokerAuthorizedInfo

func (*HeartResponseM2B) GetBrokerDefaultConfInfo 

func (x *HeartResponseM2B) GetBrokerDefaultConfInfo() string

func (*HeartResponseM2B) GetBrokerTopicSetConfInfo 

func (x *HeartResponseM2B) GetBrokerTopicSetConfInfo() []string

func (*HeartResponseM2B) GetClsConfig 

func (x *HeartResponseM2B) GetClsConfig() *ClusterConfig

func (*HeartResponseM2B) GetConfCheckSumId 

func (x *HeartResponseM2B) GetConfCheckSumId() int32

func (*HeartResponseM2B) GetCurBrokerConfId 

func (x *HeartResponseM2B) GetCurBrokerConfId() int64

func (*HeartResponseM2B) GetErrCode 

func (x *HeartResponseM2B) GetErrCode() int32

func (*HeartResponseM2B) GetErrMsg 

func (x *HeartResponseM2B) GetErrMsg() string

func (*HeartResponseM2B) GetFlowCheckId 

func (x *HeartResponseM2B) GetFlowCheckId() int64

func (*HeartResponseM2B) GetFlowControlInfo 

func (x *HeartResponseM2B) GetFlowControlInfo() string

func (*HeartResponseM2B) GetNeedReportData 

func (x *HeartResponseM2B) GetNeedReportData() bool

func (*HeartResponseM2B) GetQryPriorityId 

func (x *HeartResponseM2B) GetQryPriorityId() int32

func (*HeartResponseM2B) GetRemoveTopicConfInfo 

func (x *HeartResponseM2B) GetRemoveTopicConfInfo() []string

func (*HeartResponseM2B) GetSsdStoreId 

func (x *HeartResponseM2B) GetSsdStoreId() int64

func (*HeartResponseM2B) GetStopRead 

func (x *HeartResponseM2B) GetStopRead() bool

func (*HeartResponseM2B) GetStopWrite 

func (x *HeartResponseM2B) GetStopWrite() bool

func (*HeartResponseM2B) GetSuccess 

func (x *HeartResponseM2B) GetSuccess() bool

func (*HeartResponseM2B) GetTakeConfInfo 

func (x *HeartResponseM2B) GetTakeConfInfo() bool

func (*HeartResponseM2B) GetTakeRemoveTopicInfo 

func (x *HeartResponseM2B) GetTakeRemoveTopicInfo() bool

func (*HeartResponseM2B) ProtoMessage 

func (*HeartResponseM2B) ProtoMessage()

func (*HeartResponseM2B) ProtoReflect 

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

func (*HeartResponseM2B) Reset 

func (x *HeartResponseM2B) Reset()

func (*HeartResponseM2B) String 

func (x *HeartResponseM2B) String() string

type HeartResponseM2C 

type HeartResponseM2C struct {
	Success              *bool                 `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode              *int32                `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg               *string               `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	Event                *EventProto           `protobuf:"bytes,4,opt,name=event" json:"event,omitempty"`
	NotAllocated         *bool                 `protobuf:"varint,5,opt,name=notAllocated" json:"notAllocated,omitempty"`
	DefFlowCheckId       *int64                `protobuf:"varint,6,opt,name=defFlowCheckId" json:"defFlowCheckId,omitempty"`
	DefFlowControlInfo   *string               `protobuf:"bytes,7,opt,name=defFlowControlInfo" json:"defFlowControlInfo,omitempty"`
	GroupFlowCheckId     *int64                `protobuf:"varint,8,opt,name=groupFlowCheckId" json:"groupFlowCheckId,omitempty"`
	GroupFlowControlInfo *string               `protobuf:"bytes,9,opt,name=groupFlowControlInfo" json:"groupFlowControlInfo,omitempty"`
	SsdStoreId           *int64                `protobuf:"varint,10,opt,name=ssdStoreId" json:"ssdStoreId,omitempty"` // Deprecated
	QryPriorityId        *int32                `protobuf:"varint,11,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	RequireAuth          *bool                 `protobuf:"varint,12,opt,name=requireAuth" json:"requireAuth,omitempty"`
	AuthorizedInfo       *MasterAuthorizedInfo `protobuf:"bytes,13,opt,name=authorizedInfo" json:"authorizedInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartResponseM2C) Descriptor deprecated 

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

Deprecated: Use HeartResponseM2C.ProtoReflect.Descriptor instead.

func (*HeartResponseM2C) GetAuthorizedInfo 

func (x *HeartResponseM2C) GetAuthorizedInfo() *MasterAuthorizedInfo

func (*HeartResponseM2C) GetDefFlowCheckId 

func (x *HeartResponseM2C) GetDefFlowCheckId() int64

func (*HeartResponseM2C) GetDefFlowControlInfo 

func (x *HeartResponseM2C) GetDefFlowControlInfo() string

func (*HeartResponseM2C) GetErrCode 

func (x *HeartResponseM2C) GetErrCode() int32

func (*HeartResponseM2C) GetErrMsg 

func (x *HeartResponseM2C) GetErrMsg() string

func (*HeartResponseM2C) GetEvent 

func (x *HeartResponseM2C) GetEvent() *EventProto

func (*HeartResponseM2C) GetGroupFlowCheckId 

func (x *HeartResponseM2C) GetGroupFlowCheckId() int64

func (*HeartResponseM2C) GetGroupFlowControlInfo 

func (x *HeartResponseM2C) GetGroupFlowControlInfo() string

func (*HeartResponseM2C) GetNotAllocated 

func (x *HeartResponseM2C) GetNotAllocated() bool

func (*HeartResponseM2C) GetQryPriorityId 

func (x *HeartResponseM2C) GetQryPriorityId() int32

func (*HeartResponseM2C) GetRequireAuth 

func (x *HeartResponseM2C) GetRequireAuth() bool

func (*HeartResponseM2C) GetSsdStoreId 

func (x *HeartResponseM2C) GetSsdStoreId() int64

func (*HeartResponseM2C) GetSuccess 

func (x *HeartResponseM2C) GetSuccess() bool

func (*HeartResponseM2C) ProtoMessage 

func (*HeartResponseM2C) ProtoMessage()

func (*HeartResponseM2C) ProtoReflect 

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

func (*HeartResponseM2C) Reset 

func (x *HeartResponseM2C) Reset()

func (*HeartResponseM2C) String 

func (x *HeartResponseM2C) String() string

type HeartResponseM2P 

type HeartResponseM2P struct {
	Success        *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode        *int32  `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg         *string `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	BrokerCheckSum *int64  `protobuf:"varint,4,req,name=brokerCheckSum" json:"brokerCheckSum,omitempty"`
	// brokerId:host:port-topic:partitionNum
	TopicInfos     []string              `protobuf:"bytes,5,rep,name=topicInfos" json:"topicInfos,omitempty"`
	BrokerInfos    []string              `protobuf:"bytes,6,rep,name=brokerInfos" json:"brokerInfos,omitempty"`
	RequireAuth    *bool                 `protobuf:"varint,7,opt,name=requireAuth" json:"requireAuth,omitempty"`
	AuthorizedInfo *MasterAuthorizedInfo `protobuf:"bytes,8,opt,name=authorizedInfo" json:"authorizedInfo,omitempty"`
	AppdConfig     *ApprovedClientConfig `protobuf:"bytes,9,opt,name=appdConfig" json:"appdConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartResponseM2P) Descriptor deprecated 

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

Deprecated: Use HeartResponseM2P.ProtoReflect.Descriptor instead.

func (*HeartResponseM2P) GetAppdConfig 

func (x *HeartResponseM2P) GetAppdConfig() *ApprovedClientConfig

func (*HeartResponseM2P) GetAuthorizedInfo 

func (x *HeartResponseM2P) GetAuthorizedInfo() *MasterAuthorizedInfo

func (*HeartResponseM2P) GetBrokerCheckSum 

func (x *HeartResponseM2P) GetBrokerCheckSum() int64

func (*HeartResponseM2P) GetBrokerInfos 

func (x *HeartResponseM2P) GetBrokerInfos() []string

func (*HeartResponseM2P) GetErrCode 

func (x *HeartResponseM2P) GetErrCode() int32

func (*HeartResponseM2P) GetErrMsg 

func (x *HeartResponseM2P) GetErrMsg() string

func (*HeartResponseM2P) GetRequireAuth 

func (x *HeartResponseM2P) GetRequireAuth() bool

func (*HeartResponseM2P) GetSuccess 

func (x *HeartResponseM2P) GetSuccess() bool

func (*HeartResponseM2P) GetTopicInfos 

func (x *HeartResponseM2P) GetTopicInfos() []string

func (*HeartResponseM2P) ProtoMessage 

func (*HeartResponseM2P) ProtoMessage()

func (*HeartResponseM2P) ProtoReflect 

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

func (*HeartResponseM2P) Reset 

func (x *HeartResponseM2P) Reset()

func (*HeartResponseM2P) String 

func (x *HeartResponseM2P) String() string

type HeartResponse_V2_M2B 

type HeartResponse_V2_M2B struct {
	ErrCode              *int32                      `protobuf:"varint,1,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg               *string                     `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
	ConfigInfo           *BrokerConfigInfo           `protobuf:"bytes,3,opt,name=configInfo" json:"configInfo,omitempty"`
	OperateInfo          *BrokerOperateInfo          `protobuf:"bytes,4,opt,name=operateInfo" json:"operateInfo,omitempty"`
	PolicyInfo           *BrokerPolicyInfo           `protobuf:"bytes,5,opt,name=policyInfo" json:"policyInfo,omitempty"`
	BrokerAuthorizedInfo *MasterBrokerAuthorizedInfo `protobuf:"bytes,6,opt,name=brokerAuthorizedInfo" json:"brokerAuthorizedInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartResponse_V2_M2B) Descriptor deprecated 

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

Deprecated: Use HeartResponse_V2_M2B.ProtoReflect.Descriptor instead.

func (*HeartResponse_V2_M2B) GetBrokerAuthorizedInfo 

func (x *HeartResponse_V2_M2B) GetBrokerAuthorizedInfo() *MasterBrokerAuthorizedInfo

func (*HeartResponse_V2_M2B) GetConfigInfo 

func (x *HeartResponse_V2_M2B) GetConfigInfo() *BrokerConfigInfo

func (*HeartResponse_V2_M2B) GetErrCode 

func (x *HeartResponse_V2_M2B) GetErrCode() int32

func (*HeartResponse_V2_M2B) GetErrMsg 

func (x *HeartResponse_V2_M2B) GetErrMsg() string

func (*HeartResponse_V2_M2B) GetOperateInfo 

func (x *HeartResponse_V2_M2B) GetOperateInfo() *BrokerOperateInfo

func (*HeartResponse_V2_M2B) GetPolicyInfo 

func (x *HeartResponse_V2_M2B) GetPolicyInfo() *BrokerPolicyInfo

func (*HeartResponse_V2_M2B) ProtoMessage 

func (*HeartResponse_V2_M2B) ProtoMessage()

func (*HeartResponse_V2_M2B) ProtoReflect 

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

func (*HeartResponse_V2_M2B) Reset 

func (x *HeartResponse_V2_M2B) Reset()

func (*HeartResponse_V2_M2B) String 

func (x *HeartResponse_V2_M2B) String() string

type MasterAuthorizedInfo 

type MasterAuthorizedInfo struct {
	VisitAuthorizedToken *int64  `protobuf:"varint,1,req,name=visitAuthorizedToken" json:"visitAuthorizedToken,omitempty"`
	AuthAuthorizedToken  *string `protobuf:"bytes,2,opt,name=authAuthorizedToken" json:"authAuthorizedToken,omitempty"`
	// contains filtered or unexported fields
}

func (*MasterAuthorizedInfo) Descriptor deprecated 

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

Deprecated: Use MasterAuthorizedInfo.ProtoReflect.Descriptor instead.

func (*MasterAuthorizedInfo) GetAuthAuthorizedToken 

func (x *MasterAuthorizedInfo) GetAuthAuthorizedToken() string

func (*MasterAuthorizedInfo) GetVisitAuthorizedToken 

func (x *MasterAuthorizedInfo) GetVisitAuthorizedToken() int64

func (*MasterAuthorizedInfo) ProtoMessage 

func (*MasterAuthorizedInfo) ProtoMessage()

func (*MasterAuthorizedInfo) ProtoReflect 

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

func (*MasterAuthorizedInfo) Reset 

func (x *MasterAuthorizedInfo) Reset()

func (*MasterAuthorizedInfo) String 

func (x *MasterAuthorizedInfo) String() string

type MasterBrokerAuthorizedInfo 

type MasterBrokerAuthorizedInfo struct {
	VisitAuthorizedToken *string `protobuf:"bytes,1,req,name=visitAuthorizedToken" json:"visitAuthorizedToken,omitempty"`
	AuthAuthorizedToken  *string `protobuf:"bytes,2,opt,name=authAuthorizedToken" json:"authAuthorizedToken,omitempty"`
	// contains filtered or unexported fields
}

func (*MasterBrokerAuthorizedInfo) Descriptor deprecated 

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

Deprecated: Use MasterBrokerAuthorizedInfo.ProtoReflect.Descriptor instead.

func (*MasterBrokerAuthorizedInfo) GetAuthAuthorizedToken 

func (x *MasterBrokerAuthorizedInfo) GetAuthAuthorizedToken() string

func (*MasterBrokerAuthorizedInfo) GetVisitAuthorizedToken 

func (x *MasterBrokerAuthorizedInfo) GetVisitAuthorizedToken() string

func (*MasterBrokerAuthorizedInfo) ProtoMessage 

func (*MasterBrokerAuthorizedInfo) ProtoMessage()

func (*MasterBrokerAuthorizedInfo) ProtoReflect 

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

func (*MasterBrokerAuthorizedInfo) Reset 

func (x *MasterBrokerAuthorizedInfo) Reset()

func (*MasterBrokerAuthorizedInfo) String 

func (x *MasterBrokerAuthorizedInfo) String() string

type MasterCertificateInfo 

type MasterCertificateInfo struct {
	AuthInfo        *AuthenticateInfo `protobuf:"bytes,1,opt,name=authInfo" json:"authInfo,omitempty"`
	AuthorizedToken *string           `protobuf:"bytes,2,opt,name=authorizedToken" json:"authorizedToken,omitempty"`
	// contains filtered or unexported fields
}

func (*MasterCertificateInfo) Descriptor deprecated 

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

Deprecated: Use MasterCertificateInfo.ProtoReflect.Descriptor instead.

func (*MasterCertificateInfo) GetAuthInfo 

func (x *MasterCertificateInfo) GetAuthInfo() *AuthenticateInfo

func (*MasterCertificateInfo) GetAuthorizedToken 

func (x *MasterCertificateInfo) GetAuthorizedToken() string

func (*MasterCertificateInfo) ProtoMessage 

func (*MasterCertificateInfo) ProtoMessage()

func (*MasterCertificateInfo) ProtoReflect 

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

func (*MasterCertificateInfo) Reset 

func (x *MasterCertificateInfo) Reset()

func (*MasterCertificateInfo) String 

func (x *MasterCertificateInfo) String() string

type RegisterRequestB2M 

type RegisterRequestB2M struct {
	ClientId        *string `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	BrokerOnline    *bool   `protobuf:"varint,2,req,name=brokerOnline" json:"brokerOnline,omitempty"`
	EnableTls       *bool   `protobuf:"varint,3,req,name=enableTls" json:"enableTls,omitempty"`
	ReadStatusRpt   *int32  `protobuf:"varint,4,req,name=readStatusRpt" json:"readStatusRpt,omitempty"`
	WriteStatusRpt  *int32  `protobuf:"varint,5,req,name=writeStatusRpt" json:"writeStatusRpt,omitempty"`
	CurBrokerConfId *int64  `protobuf:"varint,6,req,name=curBrokerConfId" json:"curBrokerConfId,omitempty"`
	ConfCheckSumId  *int32  `protobuf:"varint,7,req,name=confCheckSumId" json:"confCheckSumId,omitempty"`
	// defaultPartNum:acceptPublish:acceptSubscribe:unflushThreshold:unflushInterval:deleteWhen:deletePolicy
	BrokerDefaultConfInfo *string `protobuf:"bytes,8,req,name=brokerDefaultConfInfo" json:"brokerDefaultConfInfo,omitempty"`
	// topic:partNum:acceptPublish:acceptSubscribe:unflushThreshold:unflushInterval:deleteWhen:deletePolicy:filterStatusId:statusId:attributes
	BrokerTopicSetConfInfo []string               `protobuf:"bytes,9,rep,name=brokerTopicSetConfInfo" json:"brokerTopicSetConfInfo,omitempty"`
	SsdStoreId             *int64                 `protobuf:"varint,10,opt,name=ssdStoreId" json:"ssdStoreId,omitempty"` // Deprecated
	FlowCheckId            *int64                 `protobuf:"varint,11,opt,name=flowCheckId" json:"flowCheckId,omitempty"`
	QryPriorityId          *int32                 `protobuf:"varint,12,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	TlsPort                *int32                 `protobuf:"varint,13,opt,name=tlsPort" json:"tlsPort,omitempty"`
	AuthInfo               *MasterCertificateInfo `protobuf:"bytes,14,opt,name=authInfo" json:"authInfo,omitempty"`
	ClsConfig              *ClusterConfig         `protobuf:"bytes,15,opt,name=clsConfig" json:"clsConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequestB2M) Descriptor deprecated 

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

Deprecated: Use RegisterRequestB2M.ProtoReflect.Descriptor instead.

func (*RegisterRequestB2M) GetAuthInfo 

func (x *RegisterRequestB2M) GetAuthInfo() *MasterCertificateInfo

func (*RegisterRequestB2M) GetBrokerDefaultConfInfo 

func (x *RegisterRequestB2M) GetBrokerDefaultConfInfo() string

func (*RegisterRequestB2M) GetBrokerOnline 

func (x *RegisterRequestB2M) GetBrokerOnline() bool

func (*RegisterRequestB2M) GetBrokerTopicSetConfInfo 

func (x *RegisterRequestB2M) GetBrokerTopicSetConfInfo() []string

func (*RegisterRequestB2M) GetClientId 

func (x *RegisterRequestB2M) GetClientId() string

func (*RegisterRequestB2M) GetClsConfig 

func (x *RegisterRequestB2M) GetClsConfig() *ClusterConfig

func (*RegisterRequestB2M) GetConfCheckSumId 

func (x *RegisterRequestB2M) GetConfCheckSumId() int32

func (*RegisterRequestB2M) GetCurBrokerConfId 

func (x *RegisterRequestB2M) GetCurBrokerConfId() int64

func (*RegisterRequestB2M) GetEnableTls 

func (x *RegisterRequestB2M) GetEnableTls() bool

func (*RegisterRequestB2M) GetFlowCheckId 

func (x *RegisterRequestB2M) GetFlowCheckId() int64

func (*RegisterRequestB2M) GetQryPriorityId 

func (x *RegisterRequestB2M) GetQryPriorityId() int32

func (*RegisterRequestB2M) GetReadStatusRpt 

func (x *RegisterRequestB2M) GetReadStatusRpt() int32

func (*RegisterRequestB2M) GetSsdStoreId 

func (x *RegisterRequestB2M) GetSsdStoreId() int64

func (*RegisterRequestB2M) GetTlsPort 

func (x *RegisterRequestB2M) GetTlsPort() int32

func (*RegisterRequestB2M) GetWriteStatusRpt 

func (x *RegisterRequestB2M) GetWriteStatusRpt() int32

func (*RegisterRequestB2M) ProtoMessage 

func (*RegisterRequestB2M) ProtoMessage()

func (*RegisterRequestB2M) ProtoReflect 

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

func (*RegisterRequestB2M) Reset 

func (x *RegisterRequestB2M) Reset()

func (*RegisterRequestB2M) String 

func (x *RegisterRequestB2M) String() string

type RegisterRequestC2B 

type RegisterRequestC2B struct {
	OpType        *int32          `protobuf:"varint,1,req,name=opType" json:"opType,omitempty"`
	ClientId      *string         `protobuf:"bytes,2,req,name=clientId" json:"clientId,omitempty"`
	GroupName     *string         `protobuf:"bytes,3,req,name=groupName" json:"groupName,omitempty"`
	TopicName     *string         `protobuf:"bytes,4,req,name=topicName" json:"topicName,omitempty"`
	PartitionId   *int32          `protobuf:"varint,5,req,name=partitionId" json:"partitionId,omitempty"`
	ReadStatus    *int32          `protobuf:"varint,6,req,name=readStatus" json:"readStatus,omitempty"`
	FilterCondStr []string        `protobuf:"bytes,7,rep,name=filterCondStr" json:"filterCondStr,omitempty"`
	CurrOffset    *int64          `protobuf:"varint,8,opt,name=currOffset" json:"currOffset,omitempty"`
	SessionKey    *string         `protobuf:"bytes,9,opt,name=sessionKey" json:"sessionKey,omitempty"`
	SessionTime   *int64          `protobuf:"varint,10,opt,name=sessionTime" json:"sessionTime,omitempty"`
	SsdStoreId    *int64          `protobuf:"varint,11,opt,name=ssdStoreId" json:"ssdStoreId,omitempty"` // Deprecated
	QryPriorityId *int32          `protobuf:"varint,12,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	AuthInfo      *AuthorizedInfo `protobuf:"bytes,13,opt,name=authInfo" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequestC2B) Descriptor deprecated 

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

Deprecated: Use RegisterRequestC2B.ProtoReflect.Descriptor instead.

func (*RegisterRequestC2B) GetAuthInfo 

func (x *RegisterRequestC2B) GetAuthInfo() *AuthorizedInfo

func (*RegisterRequestC2B) GetClientId 

func (x *RegisterRequestC2B) GetClientId() string

func (*RegisterRequestC2B) GetCurrOffset 

func (x *RegisterRequestC2B) GetCurrOffset() int64

func (*RegisterRequestC2B) GetFilterCondStr 

func (x *RegisterRequestC2B) GetFilterCondStr() []string

func (*RegisterRequestC2B) GetGroupName 

func (x *RegisterRequestC2B) GetGroupName() string

func (*RegisterRequestC2B) GetOpType 

func (x *RegisterRequestC2B) GetOpType() int32

func (*RegisterRequestC2B) GetPartitionId 

func (x *RegisterRequestC2B) GetPartitionId() int32

func (*RegisterRequestC2B) GetQryPriorityId 

func (x *RegisterRequestC2B) GetQryPriorityId() int32

func (*RegisterRequestC2B) GetReadStatus 

func (x *RegisterRequestC2B) GetReadStatus() int32

func (*RegisterRequestC2B) GetSessionKey 

func (x *RegisterRequestC2B) GetSessionKey() string

func (*RegisterRequestC2B) GetSessionTime 

func (x *RegisterRequestC2B) GetSessionTime() int64

func (*RegisterRequestC2B) GetSsdStoreId 

func (x *RegisterRequestC2B) GetSsdStoreId() int64

func (*RegisterRequestC2B) GetTopicName 

func (x *RegisterRequestC2B) GetTopicName() string

func (*RegisterRequestC2B) ProtoMessage 

func (*RegisterRequestC2B) ProtoMessage()

func (*RegisterRequestC2B) ProtoReflect 

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

func (*RegisterRequestC2B) Reset 

func (x *RegisterRequestC2B) Reset()

func (*RegisterRequestC2B) String 

func (x *RegisterRequestC2B) String() string

type RegisterRequestC2M 

type RegisterRequestC2M struct {
	ClientId  *string  `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	GroupName *string  `protobuf:"bytes,2,req,name=groupName" json:"groupName,omitempty"`
	HostName  *string  `protobuf:"bytes,3,req,name=hostName" json:"hostName,omitempty"`
	TopicList []string `protobuf:"bytes,4,rep,name=topicList" json:"topicList,omitempty"`
	// consumerId@group-brokerId:host:port-topic:partitionId
	SubscribeInfo     []string               `protobuf:"bytes,5,rep,name=subscribeInfo" json:"subscribeInfo,omitempty"`
	TopicCondition    []string               `protobuf:"bytes,6,rep,name=topicCondition" json:"topicCondition,omitempty"`
	RequireBound      *bool                  `protobuf:"varint,7,opt,name=requireBound" json:"requireBound,omitempty"`
	SessionTime       *int64                 `protobuf:"varint,8,opt,name=sessionTime" json:"sessionTime,omitempty"`
	SessionKey        *string                `protobuf:"bytes,9,opt,name=sessionKey" json:"sessionKey,omitempty"`
	TotalCount        *int32                 `protobuf:"varint,10,opt,name=totalCount" json:"totalCount,omitempty"`
	RequiredPartition *string                `protobuf:"bytes,11,opt,name=requiredPartition" json:"requiredPartition,omitempty"`
	NotAllocated      *bool                  `protobuf:"varint,12,opt,name=notAllocated" json:"notAllocated,omitempty"`
	SelectBig         *bool                  `protobuf:"varint,13,opt,name=selectBig" json:"selectBig,omitempty"`
	GroupFlowCheckId  *int64                 `protobuf:"varint,14,opt,name=groupFlowCheckId" json:"groupFlowCheckId,omitempty"`
	DefFlowCheckId    *int64                 `protobuf:"varint,15,opt,name=defFlowCheckId" json:"defFlowCheckId,omitempty"`
	SsdStoreId        *int64                 `protobuf:"varint,16,opt,name=ssdStoreId" json:"ssdStoreId,omitempty"` // Deprecated
	QryPriorityId     *int32                 `protobuf:"varint,17,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	AuthInfo          *MasterCertificateInfo `protobuf:"bytes,18,opt,name=authInfo" json:"authInfo,omitempty"`
	JdkVersion        *string                `protobuf:"bytes,19,opt,name=jdkVersion" json:"jdkVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequestC2M) Descriptor deprecated 

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

Deprecated: Use RegisterRequestC2M.ProtoReflect.Descriptor instead.

func (*RegisterRequestC2M) GetAuthInfo 

func (x *RegisterRequestC2M) GetAuthInfo() *MasterCertificateInfo

func (*RegisterRequestC2M) GetClientId 

func (x *RegisterRequestC2M) GetClientId() string

func (*RegisterRequestC2M) GetDefFlowCheckId 

func (x *RegisterRequestC2M) GetDefFlowCheckId() int64

func (*RegisterRequestC2M) GetGroupFlowCheckId 

func (x *RegisterRequestC2M) GetGroupFlowCheckId() int64

func (*RegisterRequestC2M) GetGroupName 

func (x *RegisterRequestC2M) GetGroupName() string

func (*RegisterRequestC2M) GetHostName 

func (x *RegisterRequestC2M) GetHostName() string

func (*RegisterRequestC2M) GetJdkVersion 

func (x *RegisterRequestC2M) GetJdkVersion() string

func (*RegisterRequestC2M) GetNotAllocated 

func (x *RegisterRequestC2M) GetNotAllocated() bool

func (*RegisterRequestC2M) GetQryPriorityId 

func (x *RegisterRequestC2M) GetQryPriorityId() int32

func (*RegisterRequestC2M) GetRequireBound 

func (x *RegisterRequestC2M) GetRequireBound() bool

func (*RegisterRequestC2M) GetRequiredPartition 

func (x *RegisterRequestC2M) GetRequiredPartition() string

func (*RegisterRequestC2M) GetSelectBig 

func (x *RegisterRequestC2M) GetSelectBig() bool

func (*RegisterRequestC2M) GetSessionKey 

func (x *RegisterRequestC2M) GetSessionKey() string

func (*RegisterRequestC2M) GetSessionTime 

func (x *RegisterRequestC2M) GetSessionTime() int64

func (*RegisterRequestC2M) GetSsdStoreId 

func (x *RegisterRequestC2M) GetSsdStoreId() int64

func (*RegisterRequestC2M) GetSubscribeInfo 

func (x *RegisterRequestC2M) GetSubscribeInfo() []string

func (*RegisterRequestC2M) GetTopicCondition 

func (x *RegisterRequestC2M) GetTopicCondition() []string

func (*RegisterRequestC2M) GetTopicList 

func (x *RegisterRequestC2M) GetTopicList() []string

func (*RegisterRequestC2M) GetTotalCount 

func (x *RegisterRequestC2M) GetTotalCount() int32

func (*RegisterRequestC2M) ProtoMessage 

func (*RegisterRequestC2M) ProtoMessage()

func (*RegisterRequestC2M) ProtoReflect 

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

func (*RegisterRequestC2M) Reset 

func (x *RegisterRequestC2M) Reset()

func (*RegisterRequestC2M) String 

func (x *RegisterRequestC2M) String() string

type RegisterRequestP2M 

type RegisterRequestP2M struct {
	ClientId       *string                `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	TopicList      []string               `protobuf:"bytes,2,rep,name=topicList" json:"topicList,omitempty"`
	BrokerCheckSum *int64                 `protobuf:"varint,3,req,name=brokerCheckSum" json:"brokerCheckSum,omitempty"`
	HostName       *string                `protobuf:"bytes,4,req,name=hostName" json:"hostName,omitempty"`
	AuthInfo       *MasterCertificateInfo `protobuf:"bytes,5,opt,name=authInfo" json:"authInfo,omitempty"`
	JdkVersion     *string                `protobuf:"bytes,6,opt,name=jdkVersion" json:"jdkVersion,omitempty"`
	AppdConfig     *ApprovedClientConfig  `protobuf:"bytes,7,opt,name=appdConfig" json:"appdConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequestP2M) Descriptor deprecated 

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

Deprecated: Use RegisterRequestP2M.ProtoReflect.Descriptor instead.

func (*RegisterRequestP2M) GetAppdConfig 

func (x *RegisterRequestP2M) GetAppdConfig() *ApprovedClientConfig

func (*RegisterRequestP2M) GetAuthInfo 

func (x *RegisterRequestP2M) GetAuthInfo() *MasterCertificateInfo

func (*RegisterRequestP2M) GetBrokerCheckSum 

func (x *RegisterRequestP2M) GetBrokerCheckSum() int64

func (*RegisterRequestP2M) GetClientId 

func (x *RegisterRequestP2M) GetClientId() string

func (*RegisterRequestP2M) GetHostName 

func (x *RegisterRequestP2M) GetHostName() string

func (*RegisterRequestP2M) GetJdkVersion 

func (x *RegisterRequestP2M) GetJdkVersion() string

func (*RegisterRequestP2M) GetTopicList 

func (x *RegisterRequestP2M) GetTopicList() []string

func (*RegisterRequestP2M) ProtoMessage 

func (*RegisterRequestP2M) ProtoMessage()

func (*RegisterRequestP2M) ProtoReflect 

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

func (*RegisterRequestP2M) Reset 

func (x *RegisterRequestP2M) Reset()

func (*RegisterRequestP2M) String 

func (x *RegisterRequestP2M) String() string

type RegisterRequest_V2_B2M 

type RegisterRequest_V2_B2M struct {
	ClientId      *string                `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	StatusRptInfo *BrokerStatusInfo      `protobuf:"bytes,2,req,name=statusRptInfo" json:"statusRptInfo,omitempty"`
	ConfigInfo    *BrokerConfigInfo      `protobuf:"bytes,3,req,name=configInfo" json:"configInfo,omitempty"`
	PolicyInfo    *BrokerPolicyInfo      `protobuf:"bytes,4,req,name=policyInfo" json:"policyInfo,omitempty"`
	AuthInfo      *MasterCertificateInfo `protobuf:"bytes,5,opt,name=authInfo" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest_V2_B2M) Descriptor deprecated 

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

Deprecated: Use RegisterRequest_V2_B2M.ProtoReflect.Descriptor instead.

func (*RegisterRequest_V2_B2M) GetAuthInfo 

func (x *RegisterRequest_V2_B2M) GetAuthInfo() *MasterCertificateInfo

func (*RegisterRequest_V2_B2M) GetClientId 

func (x *RegisterRequest_V2_B2M) GetClientId() string

func (*RegisterRequest_V2_B2M) GetConfigInfo 

func (x *RegisterRequest_V2_B2M) GetConfigInfo() *BrokerConfigInfo

func (*RegisterRequest_V2_B2M) GetPolicyInfo 

func (x *RegisterRequest_V2_B2M) GetPolicyInfo() *BrokerPolicyInfo

func (*RegisterRequest_V2_B2M) GetStatusRptInfo 

func (x *RegisterRequest_V2_B2M) GetStatusRptInfo() *BrokerStatusInfo

func (*RegisterRequest_V2_B2M) ProtoMessage 

func (*RegisterRequest_V2_B2M) ProtoMessage()

func (*RegisterRequest_V2_B2M) ProtoReflect 

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

func (*RegisterRequest_V2_B2M) Reset 

func (x *RegisterRequest_V2_B2M) Reset()

func (*RegisterRequest_V2_B2M) String 

func (x *RegisterRequest_V2_B2M) String() string

type RegisterResponseB2C 

type RegisterResponseB2C struct {
	Success    *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode    *int32  `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg     *string `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	CurrOffset *int64  `protobuf:"varint,4,opt,name=currOffset" json:"currOffset,omitempty"`
	MaxOffset  *int64  `protobuf:"varint,5,opt,name=maxOffset" json:"maxOffset,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponseB2C) Descriptor deprecated 

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

Deprecated: Use RegisterResponseB2C.ProtoReflect.Descriptor instead.

func (*RegisterResponseB2C) GetCurrOffset 

func (x *RegisterResponseB2C) GetCurrOffset() int64

func (*RegisterResponseB2C) GetErrCode 

func (x *RegisterResponseB2C) GetErrCode() int32

func (*RegisterResponseB2C) GetErrMsg 

func (x *RegisterResponseB2C) GetErrMsg() string

func (*RegisterResponseB2C) GetMaxOffset 

func (x *RegisterResponseB2C) GetMaxOffset() int64

func (*RegisterResponseB2C) GetSuccess 

func (x *RegisterResponseB2C) GetSuccess() bool

func (*RegisterResponseB2C) ProtoMessage 

func (*RegisterResponseB2C) ProtoMessage()

func (*RegisterResponseB2C) ProtoReflect 

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

func (*RegisterResponseB2C) Reset 

func (x *RegisterResponseB2C) Reset()

func (*RegisterResponseB2C) String 

func (x *RegisterResponseB2C) String() string

type RegisterResponseM2B 

type RegisterResponseM2B struct {
	Success          *bool                `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode          *int32               `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg           *string              `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	StopRead         *bool                `protobuf:"varint,4,req,name=stopRead" json:"stopRead,omitempty"`
	StopWrite        *bool                `protobuf:"varint,5,req,name=stopWrite" json:"stopWrite,omitempty"`
	TakeConfInfo     *bool                `protobuf:"varint,6,req,name=takeConfInfo" json:"takeConfInfo,omitempty"`
	EnableBrokerInfo *EnableBrokerFunInfo `protobuf:"bytes,7,opt,name=enableBrokerInfo" json:"enableBrokerInfo,omitempty"`
	CurBrokerConfId  *int64               `protobuf:"varint,8,opt,name=curBrokerConfId" json:"curBrokerConfId,omitempty"`
	ConfCheckSumId   *int32               `protobuf:"varint,9,opt,name=confCheckSumId" json:"confCheckSumId,omitempty"`
	// defaultPartNum:acceptPublish:acceptSubscribe:unflushThreshold:unflushInterval:deleteWhen:deletePolicy
	BrokerDefaultConfInfo *string `protobuf:"bytes,10,opt,name=brokerDefaultConfInfo" json:"brokerDefaultConfInfo,omitempty"`
	// topic:partNum:acceptPublish:acceptSubscribe:unflushThreshold:unflushInterval:deleteWhen:deletePolicy:filterStatusId:statusId:attributes
	BrokerTopicSetConfInfo []string                    `protobuf:"bytes,11,rep,name=brokerTopicSetConfInfo" json:"brokerTopicSetConfInfo,omitempty"`
	SsdStoreId             *int64                      `protobuf:"varint,12,opt,name=ssdStoreId" json:"ssdStoreId,omitempty"` // Deprecated
	FlowCheckId            *int64                      `protobuf:"varint,13,opt,name=flowCheckId" json:"flowCheckId,omitempty"`
	FlowControlInfo        *string                     `protobuf:"bytes,14,opt,name=flowControlInfo" json:"flowControlInfo,omitempty"`
	QryPriorityId          *int32                      `protobuf:"varint,15,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	AuthorizedInfo         *MasterAuthorizedInfo       `protobuf:"bytes,16,opt,name=authorizedInfo" json:"authorizedInfo,omitempty"` // Deprecated
	BrokerAuthorizedInfo   *MasterBrokerAuthorizedInfo `protobuf:"bytes,17,opt,name=brokerAuthorizedInfo" json:"brokerAuthorizedInfo,omitempty"`
	ClsConfig              *ClusterConfig              `protobuf:"bytes,18,opt,name=clsConfig" json:"clsConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponseM2B) Descriptor deprecated 

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

Deprecated: Use RegisterResponseM2B.ProtoReflect.Descriptor instead.

func (*RegisterResponseM2B) GetAuthorizedInfo 

func (x *RegisterResponseM2B) GetAuthorizedInfo() *MasterAuthorizedInfo

func (*RegisterResponseM2B) GetBrokerAuthorizedInfo 

func (x *RegisterResponseM2B) GetBrokerAuthorizedInfo() *MasterBrokerAuthorizedInfo

func (*RegisterResponseM2B) GetBrokerDefaultConfInfo 

func (x *RegisterResponseM2B) GetBrokerDefaultConfInfo() string

func (*RegisterResponseM2B) GetBrokerTopicSetConfInfo 

func (x *RegisterResponseM2B) GetBrokerTopicSetConfInfo() []string

func (*RegisterResponseM2B) GetClsConfig 

func (x *RegisterResponseM2B) GetClsConfig() *ClusterConfig

func (*RegisterResponseM2B) GetConfCheckSumId 

func (x *RegisterResponseM2B) GetConfCheckSumId() int32

func (*RegisterResponseM2B) GetCurBrokerConfId 

func (x *RegisterResponseM2B) GetCurBrokerConfId() int64

func (*RegisterResponseM2B) GetEnableBrokerInfo 

func (x *RegisterResponseM2B) GetEnableBrokerInfo() *EnableBrokerFunInfo

func (*RegisterResponseM2B) GetErrCode 

func (x *RegisterResponseM2B) GetErrCode() int32

func (*RegisterResponseM2B) GetErrMsg 

func (x *RegisterResponseM2B) GetErrMsg() string

func (*RegisterResponseM2B) GetFlowCheckId 

func (x *RegisterResponseM2B) GetFlowCheckId() int64

func (*RegisterResponseM2B) GetFlowControlInfo 

func (x *RegisterResponseM2B) GetFlowControlInfo() string

func (*RegisterResponseM2B) GetQryPriorityId 

func (x *RegisterResponseM2B) GetQryPriorityId() int32

func (*RegisterResponseM2B) GetSsdStoreId 

func (x *RegisterResponseM2B) GetSsdStoreId() int64

func (*RegisterResponseM2B) GetStopRead 

func (x *RegisterResponseM2B) GetStopRead() bool

func (*RegisterResponseM2B) GetStopWrite 

func (x *RegisterResponseM2B) GetStopWrite() bool

func (*RegisterResponseM2B) GetSuccess 

func (x *RegisterResponseM2B) GetSuccess() bool

func (*RegisterResponseM2B) GetTakeConfInfo 

func (x *RegisterResponseM2B) GetTakeConfInfo() bool

func (*RegisterResponseM2B) ProtoMessage 

func (*RegisterResponseM2B) ProtoMessage()

func (*RegisterResponseM2B) ProtoReflect 

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

func (*RegisterResponseM2B) Reset 

func (x *RegisterResponseM2B) Reset()

func (*RegisterResponseM2B) String 

func (x *RegisterResponseM2B) String() string

type RegisterResponseM2C 

type RegisterResponseM2C struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode *int32  `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg  *string `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	// brokerId:host:port-topic:partitionNum
	TopicInfo            []string              `protobuf:"bytes,4,rep,name=topicInfo" json:"topicInfo,omitempty"`
	NotAllocated         *bool                 `protobuf:"varint,5,opt,name=notAllocated" json:"notAllocated,omitempty"`
	DefFlowCheckId       *int64                `protobuf:"varint,6,opt,name=defFlowCheckId" json:"defFlowCheckId,omitempty"`
	DefFlowControlInfo   *string               `protobuf:"bytes,7,opt,name=defFlowControlInfo" json:"defFlowControlInfo,omitempty"`
	GroupFlowCheckId     *int64                `protobuf:"varint,8,opt,name=groupFlowCheckId" json:"groupFlowCheckId,omitempty"`
	GroupFlowControlInfo *string               `protobuf:"bytes,9,opt,name=groupFlowControlInfo" json:"groupFlowControlInfo,omitempty"`
	SsdStoreId           *int64                `protobuf:"varint,10,opt,name=ssdStoreId" json:"ssdStoreId,omitempty"` // Deprecated
	QryPriorityId        *int32                `protobuf:"varint,11,opt,name=qryPriorityId" json:"qryPriorityId,omitempty"`
	AuthorizedInfo       *MasterAuthorizedInfo `protobuf:"bytes,12,opt,name=authorizedInfo" json:"authorizedInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponseM2C) Descriptor deprecated 

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

Deprecated: Use RegisterResponseM2C.ProtoReflect.Descriptor instead.

func (*RegisterResponseM2C) GetAuthorizedInfo 

func (x *RegisterResponseM2C) GetAuthorizedInfo() *MasterAuthorizedInfo

func (*RegisterResponseM2C) GetDefFlowCheckId 

func (x *RegisterResponseM2C) GetDefFlowCheckId() int64

func (*RegisterResponseM2C) GetDefFlowControlInfo 

func (x *RegisterResponseM2C) GetDefFlowControlInfo() string

func (*RegisterResponseM2C) GetErrCode 

func (x *RegisterResponseM2C) GetErrCode() int32

func (*RegisterResponseM2C) GetErrMsg 

func (x *RegisterResponseM2C) GetErrMsg() string

func (*RegisterResponseM2C) GetGroupFlowCheckId 

func (x *RegisterResponseM2C) GetGroupFlowCheckId() int64

func (*RegisterResponseM2C) GetGroupFlowControlInfo 

func (x *RegisterResponseM2C) GetGroupFlowControlInfo() string

func (*RegisterResponseM2C) GetNotAllocated 

func (x *RegisterResponseM2C) GetNotAllocated() bool

func (*RegisterResponseM2C) GetQryPriorityId 

func (x *RegisterResponseM2C) GetQryPriorityId() int32

func (*RegisterResponseM2C) GetSsdStoreId 

func (x *RegisterResponseM2C) GetSsdStoreId() int64

func (*RegisterResponseM2C) GetSuccess 

func (x *RegisterResponseM2C) GetSuccess() bool

func (*RegisterResponseM2C) GetTopicInfo 

func (x *RegisterResponseM2C) GetTopicInfo() []string

func (*RegisterResponseM2C) ProtoMessage 

func (*RegisterResponseM2C) ProtoMessage()

func (*RegisterResponseM2C) ProtoReflect 

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

func (*RegisterResponseM2C) Reset 

func (x *RegisterResponseM2C) Reset()

func (*RegisterResponseM2C) String 

func (x *RegisterResponseM2C) String() string

type RegisterResponseM2P 

type RegisterResponseM2P struct {
	Success        *bool                 `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode        *int32                `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg         *string               `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	BrokerCheckSum *int64                `protobuf:"varint,4,req,name=brokerCheckSum" json:"brokerCheckSum,omitempty"`
	BrokerInfos    []string              `protobuf:"bytes,5,rep,name=brokerInfos" json:"brokerInfos,omitempty"`
	AuthorizedInfo *MasterAuthorizedInfo `protobuf:"bytes,6,opt,name=authorizedInfo" json:"authorizedInfo,omitempty"`
	AppdConfig     *ApprovedClientConfig `protobuf:"bytes,7,opt,name=appdConfig" json:"appdConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponseM2P) Descriptor deprecated 

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

Deprecated: Use RegisterResponseM2P.ProtoReflect.Descriptor instead.

func (*RegisterResponseM2P) GetAppdConfig 

func (x *RegisterResponseM2P) GetAppdConfig() *ApprovedClientConfig

func (*RegisterResponseM2P) GetAuthorizedInfo 

func (x *RegisterResponseM2P) GetAuthorizedInfo() *MasterAuthorizedInfo

func (*RegisterResponseM2P) GetBrokerCheckSum 

func (x *RegisterResponseM2P) GetBrokerCheckSum() int64

func (*RegisterResponseM2P) GetBrokerInfos 

func (x *RegisterResponseM2P) GetBrokerInfos() []string

func (*RegisterResponseM2P) GetErrCode 

func (x *RegisterResponseM2P) GetErrCode() int32

func (*RegisterResponseM2P) GetErrMsg 

func (x *RegisterResponseM2P) GetErrMsg() string

func (*RegisterResponseM2P) GetSuccess 

func (x *RegisterResponseM2P) GetSuccess() bool

func (*RegisterResponseM2P) ProtoMessage 

func (*RegisterResponseM2P) ProtoMessage()

func (*RegisterResponseM2P) ProtoReflect 

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

func (*RegisterResponseM2P) Reset 

func (x *RegisterResponseM2P) Reset()

func (*RegisterResponseM2P) String 

func (x *RegisterResponseM2P) String() string

type RegisterResponse_V2_M2B 

type RegisterResponse_V2_M2B struct {
	ErrCode        *int32                      `protobuf:"varint,1,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg         *string                     `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
	ConfigInfo     *BrokerConfigInfo           `protobuf:"bytes,3,opt,name=configInfo" json:"configInfo,omitempty"`
	OperateInfo    *BrokerOperateInfo          `protobuf:"bytes,4,opt,name=operateInfo" json:"operateInfo,omitempty"`
	PolicyInfo     *BrokerPolicyInfo           `protobuf:"bytes,5,opt,name=policyInfo" json:"policyInfo,omitempty"`
	AuthorizedInfo *MasterBrokerAuthorizedInfo `protobuf:"bytes,6,opt,name=authorizedInfo" json:"authorizedInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponse_V2_M2B) Descriptor deprecated 

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

Deprecated: Use RegisterResponse_V2_M2B.ProtoReflect.Descriptor instead.

func (*RegisterResponse_V2_M2B) GetAuthorizedInfo 

func (x *RegisterResponse_V2_M2B) GetAuthorizedInfo() *MasterBrokerAuthorizedInfo

func (*RegisterResponse_V2_M2B) GetConfigInfo 

func (x *RegisterResponse_V2_M2B) GetConfigInfo() *BrokerConfigInfo

func (*RegisterResponse_V2_M2B) GetErrCode 

func (x *RegisterResponse_V2_M2B) GetErrCode() int32

func (*RegisterResponse_V2_M2B) GetErrMsg 

func (x *RegisterResponse_V2_M2B) GetErrMsg() string

func (*RegisterResponse_V2_M2B) GetOperateInfo 

func (x *RegisterResponse_V2_M2B) GetOperateInfo() *BrokerOperateInfo

func (*RegisterResponse_V2_M2B) GetPolicyInfo 

func (x *RegisterResponse_V2_M2B) GetPolicyInfo() *BrokerPolicyInfo

func (*RegisterResponse_V2_M2B) ProtoMessage 

func (*RegisterResponse_V2_M2B) ProtoMessage()

func (*RegisterResponse_V2_M2B) ProtoReflect 

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

func (*RegisterResponse_V2_M2B) Reset 

func (x *RegisterResponse_V2_M2B) Reset()

func (*RegisterResponse_V2_M2B) String 

func (x *RegisterResponse_V2_M2B) String() string

type RequestBody 

type RequestBody struct {
	Method  *int32 `protobuf:"varint,1,req,name=method" json:"method,omitempty"`
	Timeout *int64 `protobuf:"varint,2,opt,name=timeout" json:"timeout,omitempty"`
	Request []byte `protobuf:"bytes,3,opt,name=request" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestBody) Descriptor deprecated 

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

Deprecated: Use RequestBody.ProtoReflect.Descriptor instead.

func (*RequestBody) GetMethod 

func (x *RequestBody) GetMethod() int32

func (*RequestBody) GetRequest 

func (x *RequestBody) GetRequest() []byte

func (*RequestBody) GetTimeout 

func (x *RequestBody) GetTimeout() int64

func (*RequestBody) ProtoMessage 

func (*RequestBody) ProtoMessage()

func (*RequestBody) ProtoReflect 

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

func (*RequestBody) Reset 

func (x *RequestBody) Reset()

func (*RequestBody) String 

func (x *RequestBody) String() string

type RequestHeader 

type RequestHeader struct {
	ServiceType *int32 `protobuf:"varint,1,opt,name=serviceType" json:"serviceType,omitempty"`
	ProtocolVer *int32 `protobuf:"varint,2,opt,name=protocolVer" json:"protocolVer,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestHeader) Descriptor deprecated 

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

Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead.

func (*RequestHeader) GetProtocolVer 

func (x *RequestHeader) GetProtocolVer() int32

func (*RequestHeader) GetServiceType 

func (x *RequestHeader) GetServiceType() int32

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) ProtoReflect 

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

func (*RequestHeader) Reset 

func (x *RequestHeader) Reset()

func (*RequestHeader) String 

func (x *RequestHeader) String() string

type ResponseHeader 

type ResponseHeader struct {
	Status      *ResponseHeader_Status `protobuf:"varint,1,req,name=status,enum=ResponseHeader_Status" json:"status,omitempty"`
	ServiceType *int32                 `protobuf:"varint,2,opt,name=serviceType" json:"serviceType,omitempty"`
	ProtocolVer *int32                 `protobuf:"varint,3,opt,name=protocolVer" json:"protocolVer,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseHeader) Descriptor deprecated 

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

Deprecated: Use ResponseHeader.ProtoReflect.Descriptor instead.

func (*ResponseHeader) GetProtocolVer 

func (x *ResponseHeader) GetProtocolVer() int32

func (*ResponseHeader) GetServiceType 

func (x *ResponseHeader) GetServiceType() int32

func (*ResponseHeader) GetStatus 

func (x *ResponseHeader) GetStatus() ResponseHeader_Status

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) ProtoReflect 

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

func (*ResponseHeader) Reset 

func (x *ResponseHeader) Reset()

func (*ResponseHeader) String 

func (x *ResponseHeader) String() string

type ResponseHeader_Status 

type ResponseHeader_Status int32
const (
	ResponseHeader_SUCCESS ResponseHeader_Status = 0
	ResponseHeader_ERROR   ResponseHeader_Status = 1
	ResponseHeader_FATAL   ResponseHeader_Status = 2
)

func (ResponseHeader_Status) Descriptor 

func (ResponseHeader_Status) Descriptor() protoreflect.EnumDescriptor

func (ResponseHeader_Status) Enum 

func (x ResponseHeader_Status) Enum() *ResponseHeader_Status

func (ResponseHeader_Status) EnumDescriptor deprecated 

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

Deprecated: Use ResponseHeader_Status.Descriptor instead.

func (ResponseHeader_Status) Number 

func (x ResponseHeader_Status) Number() protoreflect.EnumNumber

func (ResponseHeader_Status) String 

func (x ResponseHeader_Status) String() string

func (ResponseHeader_Status) Type 

func (ResponseHeader_Status) Type() protoreflect.EnumType

func (*ResponseHeader_Status) UnmarshalJSON deprecated 

func (x *ResponseHeader_Status) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type RpcConnHeader 

type RpcConnHeader struct {
	Flag     *int32 `protobuf:"varint,1,req,name=flag" json:"flag,omitempty"`
	TraceId  *int64 `protobuf:"varint,2,opt,name=traceId" json:"traceId,omitempty"`
	SpanId   *int64 `protobuf:"varint,3,opt,name=spanId" json:"spanId,omitempty"`
	ParentId *int64 `protobuf:"varint,4,opt,name=parentId" json:"parentId,omitempty"`
	// contains filtered or unexported fields
}

func (*RpcConnHeader) Descriptor deprecated 

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

Deprecated: Use RpcConnHeader.ProtoReflect.Descriptor instead.

func (*RpcConnHeader) GetFlag 

func (x *RpcConnHeader) GetFlag() int32

func (*RpcConnHeader) GetParentId 

func (x *RpcConnHeader) GetParentId() int64

func (*RpcConnHeader) GetSpanId 

func (x *RpcConnHeader) GetSpanId() int64

func (*RpcConnHeader) GetTraceId 

func (x *RpcConnHeader) GetTraceId() int64

func (*RpcConnHeader) ProtoMessage 

func (*RpcConnHeader) ProtoMessage()

func (*RpcConnHeader) ProtoReflect 

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

func (*RpcConnHeader) Reset 

func (x *RpcConnHeader) Reset()

func (*RpcConnHeader) String 

func (x *RpcConnHeader) String() string

type RspExceptionBody 

type RspExceptionBody struct {
	ExceptionName *string `protobuf:"bytes,1,req,name=exceptionName" json:"exceptionName,omitempty"`
	StackTrace    *string `protobuf:"bytes,2,opt,name=stackTrace" json:"stackTrace,omitempty"`
	// contains filtered or unexported fields
}

func (*RspExceptionBody) Descriptor deprecated 

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

Deprecated: Use RspExceptionBody.ProtoReflect.Descriptor instead.

func (*RspExceptionBody) GetExceptionName 

func (x *RspExceptionBody) GetExceptionName() string

func (*RspExceptionBody) GetStackTrace 

func (x *RspExceptionBody) GetStackTrace() string

func (*RspExceptionBody) ProtoMessage 

func (*RspExceptionBody) ProtoMessage()

func (*RspExceptionBody) ProtoReflect 

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

func (*RspExceptionBody) Reset 

func (x *RspExceptionBody) Reset()

func (*RspExceptionBody) String 

func (x *RspExceptionBody) String() string

type RspResponseBody 

type RspResponseBody struct {
	Method *int32 `protobuf:"varint,1,req,name=method" json:"method,omitempty"`
	Data   []byte `protobuf:"bytes,2,req,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RspResponseBody) Descriptor deprecated 

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

Deprecated: Use RspResponseBody.ProtoReflect.Descriptor instead.

func (*RspResponseBody) GetData 

func (x *RspResponseBody) GetData() []byte

func (*RspResponseBody) GetMethod 

func (x *RspResponseBody) GetMethod() int32

func (*RspResponseBody) ProtoMessage 

func (*RspResponseBody) ProtoMessage()

func (*RspResponseBody) ProtoReflect 

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

func (*RspResponseBody) Reset 

func (x *RspResponseBody) Reset()

func (*RspResponseBody) String 

func (x *RspResponseBody) String() string

type SendMessageRequestP2B 

type SendMessageRequestP2B struct {
	ClientId    *string         `protobuf:"bytes,1,req,name=clientId" json:"clientId,omitempty"`
	TopicName   *string         `protobuf:"bytes,2,req,name=topicName" json:"topicName,omitempty"`
	PartitionId *int32          `protobuf:"varint,3,req,name=partitionId" json:"partitionId,omitempty"`
	Data        []byte          `protobuf:"bytes,4,req,name=data" json:"data,omitempty"`
	Flag        *int32          `protobuf:"varint,5,req,name=flag" json:"flag,omitempty"`
	CheckSum    *int32          `protobuf:"varint,6,req,name=checkSum" json:"checkSum,omitempty"`
	SentAddr    *int32          `protobuf:"varint,7,req,name=sentAddr" json:"sentAddr,omitempty"`
	MsgType     *string         `protobuf:"bytes,8,opt,name=msgType" json:"msgType,omitempty"`
	MsgTime     *string         `protobuf:"bytes,9,opt,name=msgTime" json:"msgTime,omitempty"`
	AuthInfo    *AuthorizedInfo `protobuf:"bytes,10,opt,name=authInfo" json:"authInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMessageRequestP2B) Descriptor deprecated 

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

Deprecated: Use SendMessageRequestP2B.ProtoReflect.Descriptor instead.

func (*SendMessageRequestP2B) GetAuthInfo 

func (x *SendMessageRequestP2B) GetAuthInfo() *AuthorizedInfo

func (*SendMessageRequestP2B) GetCheckSum 

func (x *SendMessageRequestP2B) GetCheckSum() int32

func (*SendMessageRequestP2B) GetClientId 

func (x *SendMessageRequestP2B) GetClientId() string

func (*SendMessageRequestP2B) GetData 

func (x *SendMessageRequestP2B) GetData() []byte

func (*SendMessageRequestP2B) GetFlag 

func (x *SendMessageRequestP2B) GetFlag() int32

func (*SendMessageRequestP2B) GetMsgTime 

func (x *SendMessageRequestP2B) GetMsgTime() string

func (*SendMessageRequestP2B) GetMsgType 

func (x *SendMessageRequestP2B) GetMsgType() string

func (*SendMessageRequestP2B) GetPartitionId 

func (x *SendMessageRequestP2B) GetPartitionId() int32

func (*SendMessageRequestP2B) GetSentAddr 

func (x *SendMessageRequestP2B) GetSentAddr() int32

func (*SendMessageRequestP2B) GetTopicName 

func (x *SendMessageRequestP2B) GetTopicName() string

func (*SendMessageRequestP2B) ProtoMessage 

func (*SendMessageRequestP2B) ProtoMessage()

func (*SendMessageRequestP2B) ProtoReflect 

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

func (*SendMessageRequestP2B) Reset 

func (x *SendMessageRequestP2B) Reset()

func (*SendMessageRequestP2B) String 

func (x *SendMessageRequestP2B) String() string

type SendMessageResponseB2P 

type SendMessageResponseB2P struct {
	Success      *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	ErrCode      *int32  `protobuf:"varint,2,req,name=errCode" json:"errCode,omitempty"`
	ErrMsg       *string `protobuf:"bytes,3,req,name=errMsg" json:"errMsg,omitempty"`
	RequireAuth  *bool   `protobuf:"varint,4,opt,name=requireAuth" json:"requireAuth,omitempty"`
	MessageId    *int64  `protobuf:"varint,5,opt,name=messageId" json:"messageId,omitempty"`
	AppendTime   *int64  `protobuf:"varint,6,opt,name=appendTime" json:"appendTime,omitempty"`
	AppendOffset *int64  `protobuf:"varint,7,opt,name=appendOffset" json:"appendOffset,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMessageResponseB2P) Descriptor deprecated 

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

Deprecated: Use SendMessageResponseB2P.ProtoReflect.Descriptor instead.

func (*SendMessageResponseB2P) GetAppendOffset 

func (x *SendMessageResponseB2P) GetAppendOffset() int64

func (*SendMessageResponseB2P) GetAppendTime 

func (x *SendMessageResponseB2P) GetAppendTime() int64

func (*SendMessageResponseB2P) GetErrCode 

func (x *SendMessageResponseB2P) GetErrCode() int32

func (*SendMessageResponseB2P) GetErrMsg 

func (x *SendMessageResponseB2P) GetErrMsg() string

func (*SendMessageResponseB2P) GetMessageId 

func (x *SendMessageResponseB2P) GetMessageId() int64

func (*SendMessageResponseB2P) GetRequireAuth 

func (x *SendMessageResponseB2P) GetRequireAuth() bool

func (*SendMessageResponseB2P) GetSuccess 

func (x *SendMessageResponseB2P) GetSuccess() bool

func (*SendMessageResponseB2P) ProtoMessage 

func (*SendMessageResponseB2P) ProtoMessage()

func (*SendMessageResponseB2P) ProtoReflect 

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

func (*SendMessageResponseB2P) Reset 

func (x *SendMessageResponseB2P) Reset()

func (*SendMessageResponseB2P) String 

func (x *SendMessageResponseB2P) String() string

type TopicConfigInfo 

type TopicConfigInfo struct {
	TopicName         *string          `protobuf:"bytes,1,req,name=topicName" json:"topicName,omitempty"`
	StatusId          *int32           `protobuf:"varint,2,opt,name=statusId" json:"statusId,omitempty"`
	NumTopicStores    *int32           `protobuf:"varint,3,opt,name=numTopicStores" json:"numTopicStores,omitempty"`
	NumPartitions     *int32           `protobuf:"varint,4,opt,name=numPartitions" json:"numPartitions,omitempty"`
	UnflushMsgCnt     *int32           `protobuf:"varint,5,opt,name=unflushMsgCnt" json:"unflushMsgCnt,omitempty"`
	UnflushInterval   *int32           `protobuf:"varint,6,opt,name=unflushInterval" json:"unflushInterval,omitempty"`
	UnflushDataSize   *int32           `protobuf:"varint,7,opt,name=unflushDataSize" json:"unflushDataSize,omitempty"`
	MemCacheBlockSize *int32           `protobuf:"varint,8,opt,name=memCacheBlockSize" json:"memCacheBlockSize,omitempty"`
	NumMemCacheBlock  *int32           `protobuf:"varint,9,opt,name=numMemCacheBlock" json:"numMemCacheBlock,omitempty"`
	AcceptPublish     *bool            `protobuf:"varint,10,opt,name=acceptPublish" json:"acceptPublish,omitempty"`
	AcceptSubscribe   *bool            `protobuf:"varint,11,opt,name=acceptSubscribe" json:"acceptSubscribe,omitempty"`
	DeletePolicy      *string          `protobuf:"bytes,12,opt,name=deletePolicy" json:"deletePolicy,omitempty"`
	DataPath          []*DataStorePath `protobuf:"bytes,13,rep,name=dataPath" json:"dataPath,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicConfigInfo) Descriptor deprecated 

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

Deprecated: Use TopicConfigInfo.ProtoReflect.Descriptor instead.

func (*TopicConfigInfo) GetAcceptPublish 

func (x *TopicConfigInfo) GetAcceptPublish() bool

func (*TopicConfigInfo) GetAcceptSubscribe 

func (x *TopicConfigInfo) GetAcceptSubscribe() bool

func (*TopicConfigInfo) GetDataPath 

func (x *TopicConfigInfo) GetDataPath() []*DataStorePath

func (*TopicConfigInfo) GetDeletePolicy 

func (x *TopicConfigInfo) GetDeletePolicy() string

func (*TopicConfigInfo) GetMemCacheBlockSize 

func (x *TopicConfigInfo) GetMemCacheBlockSize() int32

func (*TopicConfigInfo) GetNumMemCacheBlock 

func (x *TopicConfigInfo) GetNumMemCacheBlock() int32

func (*TopicConfigInfo) GetNumPartitions 

func (x *TopicConfigInfo) GetNumPartitions() int32

func (*TopicConfigInfo) GetNumTopicStores 

func (x *TopicConfigInfo) GetNumTopicStores() int32

func (*TopicConfigInfo) GetStatusId 

func (x *TopicConfigInfo) GetStatusId() int32

func (*TopicConfigInfo) GetTopicName 

func (x *TopicConfigInfo) GetTopicName() string

func (*TopicConfigInfo) GetUnflushDataSize 

func (x *TopicConfigInfo) GetUnflushDataSize() int32

func (*TopicConfigInfo) GetUnflushInterval 

func (x *TopicConfigInfo) GetUnflushInterval() int32

func (*TopicConfigInfo) GetUnflushMsgCnt 

func (x *TopicConfigInfo) GetUnflushMsgCnt() int32

func (*TopicConfigInfo) ProtoMessage 

func (*TopicConfigInfo) ProtoMessage()

func (*TopicConfigInfo) ProtoReflect 

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

func (*TopicConfigInfo) Reset 

func (x *TopicConfigInfo) Reset()

func (*TopicConfigInfo) String 

func (x *TopicConfigInfo) String() string

type TopicRmvInfo 

type TopicRmvInfo struct {
	TopicName *string `protobuf:"bytes,1,req,name=topicName" json:"topicName,omitempty"`
	StatusId  *int32  `protobuf:"varint,2,req,name=statusId" json:"statusId,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicRmvInfo) Descriptor deprecated 

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

Deprecated: Use TopicRmvInfo.ProtoReflect.Descriptor instead.

func (*TopicRmvInfo) GetStatusId 

func (x *TopicRmvInfo) GetStatusId() int32

func (*TopicRmvInfo) GetTopicName 

func (x *TopicRmvInfo) GetTopicName() string

func (*TopicRmvInfo) ProtoMessage 

func (*TopicRmvInfo) ProtoMessage()

func (*TopicRmvInfo) ProtoReflect 

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

func (*TopicRmvInfo) Reset 

func (x *TopicRmvInfo) Reset()

func (*TopicRmvInfo) String 

func (x *TopicRmvInfo) String() string

type TransferedMessage 

type TransferedMessage struct {
	MessageId   *int64 `protobuf:"varint,1,req,name=messageId" json:"messageId,omitempty"`
	CheckSum    *int32 `protobuf:"varint,2,req,name=checkSum" json:"checkSum,omitempty"`
	PayLoadData []byte `protobuf:"bytes,3,req,name=payLoadData" json:"payLoadData,omitempty"`
	Flag        *int32 `protobuf:"varint,4,req,name=flag" json:"flag,omitempty"`
	// contains filtered or unexported fields
}

func (*TransferedMessage) Descriptor deprecated 

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

Deprecated: Use TransferedMessage.ProtoReflect.Descriptor instead.

func (*TransferedMessage) GetCheckSum 

func (x *TransferedMessage) GetCheckSum() int32

func (*TransferedMessage) GetFlag 

func (x *TransferedMessage) GetFlag() int32

func (*TransferedMessage) GetMessageId 

func (x *TransferedMessage) GetMessageId() int64

func (*TransferedMessage) GetPayLoadData 

func (x *TransferedMessage) GetPayLoadData() []byte

func (*TransferedMessage) ProtoMessage 

func (*TransferedMessage) ProtoMessage()

func (*TransferedMessage) ProtoReflect 

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

func (*TransferedMessage) Reset 

func (x *TransferedMessage) Reset()

func (*TransferedMessage) String 

func (x *TransferedMessage) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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