internal

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2020 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package internal is a generated GoMock package.

Index

Constants

View Source 
const (
	RetryGroupTopicPrefix    = "%RETRY%"
	DefaultConsumerGroup     = "DEFAULT_CONSUMER"
	ClientInnerProducerGroup = "CLIENT_INNER_PRODUCER"
)
View Source 
const (
	ReqSendMessage              = int16(10)
	ReqPullMessage              = int16(11)
	ReqQueryConsumerOffset      = int16(14)
	ReqUpdateConsumerOffset     = int16(15)
	ReqSearchOffsetByTimestamp  = int16(30)
	ReqGetMaxOffset             = int16(30)
	ReqHeartBeat                = int16(34)
	ReqConsumerSendMsgBack      = int16(36)
	ReqGetConsumerListByGroup   = int16(38)
	ReqLockBatchMQ              = int16(41)
	ReqUnlockBatchMQ            = int16(42)
	ReqGetRouteInfoByTopic      = int16(105)
	ReqSendBatchMessage         = int16(320)
	ReqCheckTransactionState    = int16(39)
	ReqNotifyConsumerIdsChanged = int16(40)
	ReqResetConsuemrOffset      = int16(220)
	ReqGetConsumerRunningInfo   = int16(307)
	ReqConsumeMessageDirectly   = int16(309)
)
View Source 
const (
	ResSuccess              = int16(0)
	ResFlushDiskTimeout     = int16(10)
	ResSlaveNotAvailable    = int16(11)
	ResFlushSlaveTimeout    = int16(12)
	ResTopicNotExist        = int16(17)
	ResPullNotFound         = int16(19)
	ResPullRetryImmediately = int16(20)
	ResPullOffsetMoved      = int16(21)
)
View Source 
const (
	EnvNameServerAddr = "NAMESRV_ADDR"

	MasterId = int64(0)
)
View Source 
const (
	V4_1_0 = 0
)

Variables

View Source 
var (
	ErrNoNameserver = errors.New("nameServerAddrs can't be empty.")
	ErrMultiIP      = errors.New("multiple IP addr does not support")
	ErrIllegalIP    = errors.New("IP addr error")
)
View Source 
var (
	ErrServiceState = errors.New("service close is not running, please check")
)
View Source 
var (
	ErrTopicNotExist = errors.New("topic not exist")
)

Functions

func AddBroker 

func AddBroker(routeData *TopicRouteData)

just for test

func FetchPublishMessageQueues 

func FetchPublishMessageQueues(topic string) ([]*primitive.MessageQueue, error)

func FetchSubscribeMessageQueues 

func FetchSubscribeMessageQueues(topic string) ([]*primitive.MessageQueue, error)

func FindBrokerAddrByName 

func FindBrokerAddrByName(brokerName string) string

func FindBrokerAddrByTopic 

func FindBrokerAddrByTopic(topic string) string

func FindMQByTopic 

func FindMQByTopic(topic string) *primitive.MessageQueue

func GetOrNewRocketMQClient 

func GetOrNewRocketMQClient(option ClientOptions) *rmqClient

func GetRetryTopic 

func GetRetryTopic(group string) string

func RegisterNamsrv 

func RegisterNamsrv(s *Namesrvs)

func ValidateGroup 

func ValidateGroup(group string)

Types

type BrokerData 

type BrokerData struct {
	Cluster         string           `json:"cluster"`
	BrokerName      string           `json:"brokerName"`
	BrokerAddresses map[int64]string `json:"brokerAddrs"`
	// contains filtered or unexported fields
}

BrokerData BrokerData

func (*BrokerData) Equals 

func (b *BrokerData) Equals(bd *BrokerData) bool

type ClientOptions 

type ClientOptions struct {
	GroupName         string
	NameServerAddrs   []string
	ClientIP          string
	InstanceName      string
	UnitMode          bool
	UnitName          string
	VIPChannelEnabled bool
	ACLEnabled        bool
	RetryTimes        int
	Interceptors      []primitive.Interceptor
	Credentials       primitive.Credentials
}

func DefaultClientOptions 

func DefaultClientOptions() ClientOptions

func (*ClientOptions) ChangeInstanceNameToPID 

func (opt *ClientOptions) ChangeInstanceNameToPID()

func (*ClientOptions) String 

func (opt *ClientOptions) String() string

type ConsumerSendMsgBackRequest 

type ConsumerSendMsgBackRequest struct {
	Group             string `json:"group"`
	Offset            int64  `json:"offset"`
	DelayLevel        int    `json:"delayLevel"`
	OriginMsgId       string `json:"originMsgId"`
	OriginTopic       string `json:"originTopic"`
	UnitMode          bool   `json:"unitMode"`
	MaxReconsumeTimes int32  `json:"maxReconsumeTimes"`
}

func (*ConsumerSendMsgBackRequest) Encode 

func (request *ConsumerSendMsgBackRequest) Encode() map[string]string

type FindBrokerResult 

type FindBrokerResult struct {
	BrokerAddr    string
	Slave         bool
	BrokerVersion int32
}

func FindBrokerAddressInSubscribe 

func FindBrokerAddressInSubscribe(brokerName string, brokerId int64, onlyThisBroker bool) *FindBrokerResult

type GetConsumerList 

type GetConsumerList struct {
	ConsumerGroup string `json:"consumerGroup"`
}

func (*GetConsumerList) Encode 

func (request *GetConsumerList) Encode() map[string]string

type GetMaxOffsetRequest 

type GetMaxOffsetRequest struct {
	Topic   string `json:"topic"`
	QueueId int    `json:"queueId"`
}

func (*GetMaxOffsetRequest) Encode 

func (request *GetMaxOffsetRequest) Encode() map[string]string

type GetRouteInfoRequest 

type GetRouteInfoRequest struct {
	Topic string `json:"topic"`
}

func (*GetRouteInfoRequest) Decode 

func (request *GetRouteInfoRequest) Decode(properties map[string]string) error

func (*GetRouteInfoRequest) Encode 

func (request *GetRouteInfoRequest) Encode() map[string]string

type InnerConsumer 

type InnerConsumer interface {
	PersistConsumerOffset() error
	UpdateTopicSubscribeInfo(topic string, mqs []*primitive.MessageQueue)
	IsSubscribeTopicNeedUpdate(topic string) bool
	SubscriptionDataList() []*SubscriptionData
	Rebalance()
	IsUnitMode() bool
}

type InnerProducer 

type InnerProducer interface {
	PublishTopicList() []string
	UpdateTopicPublishInfo(topic string, info *TopicPublishInfo)
	IsPublishTopicNeedUpdate(topic string) bool
	IsUnitMode() bool
}

type MockInnerConsumer 

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

MockInnerConsumer is a mock of InnerConsumer interface

func NewMockInnerConsumer 

func NewMockInnerConsumer(ctrl *gomock.Controller) *MockInnerConsumer

NewMockInnerConsumer creates a new mock instance

func (*MockInnerConsumer) EXPECT 

func (m *MockInnerConsumer) EXPECT() *MockInnerConsumerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockInnerConsumer) IsSubscribeTopicNeedUpdate 

func (m *MockInnerConsumer) IsSubscribeTopicNeedUpdate(topic string) bool

IsSubscribeTopicNeedUpdate mocks base method

func (*MockInnerConsumer) IsUnitMode 

func (m *MockInnerConsumer) IsUnitMode() bool

IsUnitMode mocks base method

func (*MockInnerConsumer) PersistConsumerOffset 

func (m *MockInnerConsumer) PersistConsumerOffset()

PersistConsumerOffset mocks base method

func (*MockInnerConsumer) Rebalance 

func (m *MockInnerConsumer) Rebalance()

Rebalance mocks base method

func (*MockInnerConsumer) SubscriptionDataList 

func (m *MockInnerConsumer) SubscriptionDataList() []*SubscriptionData

SubscriptionDataList mocks base method

func (*MockInnerConsumer) UpdateTopicSubscribeInfo 

func (m *MockInnerConsumer) UpdateTopicSubscribeInfo(topic string, mqs []*primitive.MessageQueue)

UpdateTopicSubscribeInfo mocks base method

type MockInnerConsumerMockRecorder 

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

MockInnerConsumerMockRecorder is the mock recorder for MockInnerConsumer

func (*MockInnerConsumerMockRecorder) IsSubscribeTopicNeedUpdate 

func (mr *MockInnerConsumerMockRecorder) IsSubscribeTopicNeedUpdate(topic interface{}) *gomock.Call

IsSubscribeTopicNeedUpdate indicates an expected call of IsSubscribeTopicNeedUpdate

func (*MockInnerConsumerMockRecorder) IsUnitMode 

func (mr *MockInnerConsumerMockRecorder) IsUnitMode() *gomock.Call

IsUnitMode indicates an expected call of IsUnitMode

func (*MockInnerConsumerMockRecorder) PersistConsumerOffset 

func (mr *MockInnerConsumerMockRecorder) PersistConsumerOffset() *gomock.Call

PersistConsumerOffset indicates an expected call of PersistConsumerOffset

func (*MockInnerConsumerMockRecorder) Rebalance 

func (mr *MockInnerConsumerMockRecorder) Rebalance() *gomock.Call

Rebalance indicates an expected call of Rebalance

func (*MockInnerConsumerMockRecorder) SubscriptionDataList 

func (mr *MockInnerConsumerMockRecorder) SubscriptionDataList() *gomock.Call

SubscriptionDataList indicates an expected call of SubscriptionDataList

func (*MockInnerConsumerMockRecorder) UpdateTopicSubscribeInfo 

func (mr *MockInnerConsumerMockRecorder) UpdateTopicSubscribeInfo(topic, mqs interface{}) *gomock.Call

UpdateTopicSubscribeInfo indicates an expected call of UpdateTopicSubscribeInfo

type MockInnerProducer 

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

MockInnerProducer is a mock of InnerProducer interface

func NewMockInnerProducer 

func NewMockInnerProducer(ctrl *gomock.Controller) *MockInnerProducer

NewMockInnerProducer creates a new mock instance

func (*MockInnerProducer) EXPECT 

func (m *MockInnerProducer) EXPECT() *MockInnerProducerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockInnerProducer) IsPublishTopicNeedUpdate 

func (m *MockInnerProducer) IsPublishTopicNeedUpdate(topic string) bool

IsPublishTopicNeedUpdate mocks base method

func (*MockInnerProducer) IsUnitMode 

func (m *MockInnerProducer) IsUnitMode() bool

IsUnitMode mocks base method

func (*MockInnerProducer) PublishTopicList 

func (m *MockInnerProducer) PublishTopicList() []string

PublishTopicList mocks base method

func (*MockInnerProducer) UpdateTopicPublishInfo 

func (m *MockInnerProducer) UpdateTopicPublishInfo(topic string, info *TopicPublishInfo)

UpdateTopicPublishInfo mocks base method

type MockInnerProducerMockRecorder 

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

MockInnerProducerMockRecorder is the mock recorder for MockInnerProducer

func (*MockInnerProducerMockRecorder) IsPublishTopicNeedUpdate 

func (mr *MockInnerProducerMockRecorder) IsPublishTopicNeedUpdate(topic interface{}) *gomock.Call

IsPublishTopicNeedUpdate indicates an expected call of IsPublishTopicNeedUpdate

func (*MockInnerProducerMockRecorder) IsUnitMode 

func (mr *MockInnerProducerMockRecorder) IsUnitMode() *gomock.Call

IsUnitMode indicates an expected call of IsUnitMode

func (*MockInnerProducerMockRecorder) PublishTopicList 

func (mr *MockInnerProducerMockRecorder) PublishTopicList() *gomock.Call

PublishTopicList indicates an expected call of PublishTopicList

func (*MockInnerProducerMockRecorder) UpdateTopicPublishInfo 

func (mr *MockInnerProducerMockRecorder) UpdateTopicPublishInfo(topic, info interface{}) *gomock.Call

UpdateTopicPublishInfo indicates an expected call of UpdateTopicPublishInfo

type MockRMQClient 

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

MockRMQClient is a mock of RMQClient interface

func NewMockRMQClient 

func NewMockRMQClient(ctrl *gomock.Controller) *MockRMQClient

NewMockRMQClient creates a new mock instance

func (*MockRMQClient) CheckClientInBroker 

func (m *MockRMQClient) CheckClientInBroker()

CheckClientInBroker mocks base method

func (*MockRMQClient) ClientID 

func (m *MockRMQClient) ClientID() string

ClientID mocks base method

func (*MockRMQClient) EXPECT 

func (m *MockRMQClient) EXPECT() *MockRMQClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockRMQClient) InvokeAsync 

func (m *MockRMQClient) InvokeAsync(addr string, request *remote.RemotingCommand, timeoutMillis time.Duration, f func(*remote.RemotingCommand, error)) error

InvokeAsync mocks base method

func (*MockRMQClient) InvokeOneWay 

func (m *MockRMQClient) InvokeOneWay(addr string, request *remote.RemotingCommand, timeoutMillis time.Duration) error

InvokeOneWay mocks base method

func (*MockRMQClient) InvokeSync 

func (m *MockRMQClient) InvokeSync(addr string, request *remote.RemotingCommand, timeoutMillis time.Duration) (*remote.RemotingCommand, error)

InvokeSync mocks base method

func (*MockRMQClient) ProcessSendResponse 

func (m *MockRMQClient) ProcessSendResponse(brokerName string, cmd *remote.RemotingCommand, resp *primitive.SendResult, msgs ...*primitive.Message)

ProcessSendResponse mocks base method

func (*MockRMQClient) PullMessage 

func (m *MockRMQClient) PullMessage(ctx context.Context, brokerAddrs string, request *PullMessageRequest) (*primitive.PullResult, error)

PullMessage mocks base method

func (*MockRMQClient) PullMessageAsync 

func (m *MockRMQClient) PullMessageAsync(ctx context.Context, brokerAddrs string, request *PullMessageRequest, f func(*primitive.PullResult)) error

PullMessageAsync mocks base method

func (*MockRMQClient) RebalanceImmediately 

func (m *MockRMQClient) RebalanceImmediately()

RebalanceImmediately mocks base method

func (*MockRMQClient) RegisterConsumer 

func (m *MockRMQClient) RegisterConsumer(group string, consumer InnerConsumer) error

RegisterConsumer mocks base method

func (*MockRMQClient) RegisterProducer 

func (m *MockRMQClient) RegisterProducer(group string, producer InnerProducer)

RegisterProducer mocks base method

func (*MockRMQClient) SendHeartbeatToAllBrokerWithLock 

func (m *MockRMQClient) SendHeartbeatToAllBrokerWithLock()

SendHeartbeatToAllBrokerWithLock mocks base method

func (*MockRMQClient) SendMessageAsync 

func (m *MockRMQClient) SendMessageAsync(ctx context.Context, brokerAddrs, brokerName string, request *SendMessageRequest, msgs []*primitive.Message, f func(*primitive.SendResult)) error

SendMessageAsync mocks base method

func (*MockRMQClient) SendMessageOneWay 

func (m *MockRMQClient) SendMessageOneWay(ctx context.Context, brokerAddrs string, request *SendMessageRequest, msgs []*primitive.Message) (*primitive.SendResult, error)

SendMessageOneWay mocks base method

func (*MockRMQClient) Shutdown 

func (m *MockRMQClient) Shutdown()

Shutdown mocks base method

func (*MockRMQClient) Start 

func (m *MockRMQClient) Start()

Start mocks base method

func (*MockRMQClient) UnregisterConsumer 

func (m *MockRMQClient) UnregisterConsumer(group string)

UnregisterConsumer mocks base method

func (*MockRMQClient) UpdatePublishInfo 

func (m *MockRMQClient) UpdatePublishInfo(topic string, data *TopicRouteData)

UpdatePublishInfo mocks base method

func (*MockRMQClient) UpdateTopicRouteInfo 

func (m *MockRMQClient) UpdateTopicRouteInfo()

UpdateTopicRouteInfo mocks base method

type MockRMQClientMockRecorder 

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

MockRMQClientMockRecorder is the mock recorder for MockRMQClient

func (*MockRMQClientMockRecorder) CheckClientInBroker 

func (mr *MockRMQClientMockRecorder) CheckClientInBroker() *gomock.Call

CheckClientInBroker indicates an expected call of CheckClientInBroker

func (*MockRMQClientMockRecorder) ClientID 

func (mr *MockRMQClientMockRecorder) ClientID() *gomock.Call

ClientID indicates an expected call of ClientID

func (*MockRMQClientMockRecorder) InvokeAsync 

func (mr *MockRMQClientMockRecorder) InvokeAsync(addr, request, timeoutMillis, f interface{}) *gomock.Call

InvokeAsync indicates an expected call of InvokeAsync

func (*MockRMQClientMockRecorder) InvokeOneWay 

func (mr *MockRMQClientMockRecorder) InvokeOneWay(addr, request, timeoutMillis interface{}) *gomock.Call

InvokeOneWay indicates an expected call of InvokeOneWay

func (*MockRMQClientMockRecorder) InvokeSync 

func (mr *MockRMQClientMockRecorder) InvokeSync(addr, request, timeoutMillis interface{}) *gomock.Call

InvokeSync indicates an expected call of InvokeSync

func (*MockRMQClientMockRecorder) ProcessSendResponse 

func (mr *MockRMQClientMockRecorder) ProcessSendResponse(brokerName, cmd, resp interface{}, msgs ...interface{}) *gomock.Call

ProcessSendResponse indicates an expected call of ProcessSendResponse

func (*MockRMQClientMockRecorder) PullMessage 

func (mr *MockRMQClientMockRecorder) PullMessage(ctx, brokerAddrs, request interface{}) *gomock.Call

PullMessage indicates an expected call of PullMessage

func (*MockRMQClientMockRecorder) PullMessageAsync 

func (mr *MockRMQClientMockRecorder) PullMessageAsync(ctx, brokerAddrs, request, f interface{}) *gomock.Call

PullMessageAsync indicates an expected call of PullMessageAsync

func (*MockRMQClientMockRecorder) RebalanceImmediately 

func (mr *MockRMQClientMockRecorder) RebalanceImmediately() *gomock.Call

RebalanceImmediately indicates an expected call of RebalanceImmediately

func (*MockRMQClientMockRecorder) RegisterConsumer 

func (mr *MockRMQClientMockRecorder) RegisterConsumer(group, consumer interface{}) *gomock.Call

RegisterConsumer indicates an expected call of RegisterConsumer

func (*MockRMQClientMockRecorder) RegisterProducer 

func (mr *MockRMQClientMockRecorder) RegisterProducer(group, producer interface{}) *gomock.Call

RegisterProducer indicates an expected call of RegisterProducer

func (*MockRMQClientMockRecorder) SendHeartbeatToAllBrokerWithLock 

func (mr *MockRMQClientMockRecorder) SendHeartbeatToAllBrokerWithLock() *gomock.Call

SendHeartbeatToAllBrokerWithLock indicates an expected call of SendHeartbeatToAllBrokerWithLock

func (*MockRMQClientMockRecorder) SendMessageAsync 

func (mr *MockRMQClientMockRecorder) SendMessageAsync(ctx, brokerAddrs, brokerName, request, msgs, f interface{}) *gomock.Call

SendMessageAsync indicates an expected call of SendMessageAsync

func (*MockRMQClientMockRecorder) SendMessageOneWay 

func (mr *MockRMQClientMockRecorder) SendMessageOneWay(ctx, brokerAddrs, request, msgs interface{}) *gomock.Call

SendMessageOneWay indicates an expected call of SendMessageOneWay

func (*MockRMQClientMockRecorder) Shutdown 

func (mr *MockRMQClientMockRecorder) Shutdown() *gomock.Call

Shutdown indicates an expected call of Shutdown

func (*MockRMQClientMockRecorder) Start 

func (mr *MockRMQClientMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockRMQClientMockRecorder) UnregisterConsumer 

func (mr *MockRMQClientMockRecorder) UnregisterConsumer(group interface{}) *gomock.Call

UnregisterConsumer indicates an expected call of UnregisterConsumer

func (*MockRMQClientMockRecorder) UpdatePublishInfo 

func (mr *MockRMQClientMockRecorder) UpdatePublishInfo(topic, data interface{}) *gomock.Call

UpdatePublishInfo indicates an expected call of UpdatePublishInfo

func (*MockRMQClientMockRecorder) UpdateTopicRouteInfo 

func (mr *MockRMQClientMockRecorder) UpdateTopicRouteInfo() *gomock.Call

UpdateTopicRouteInfo indicates an expected call of UpdateTopicRouteInfo

type Namesrvs 

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

Namesrvs rocketmq namesrv instance.

func NewNamesrv 

func NewNamesrv(s ...string) (*Namesrvs, error)

NewNamesrv init Namesrv from namesrv addr string.

func (*Namesrvs) GetNamesrv 

func (s *Namesrvs) GetNamesrv() string

GetNamesrv return namesrv using round-robin strategy.

func (*Namesrvs) Size 

func (s *Namesrvs) Size() int

func (*Namesrvs) String 

func (s *Namesrvs) String() string

type PullMessageRequest 

type PullMessageRequest struct {
	ConsumerGroup        string        `json:"consumerGroup"`
	Topic                string        `json:"topic"`
	QueueId              int32         `json:"queueId"`
	QueueOffset          int64         `json:"queueOffset"`
	MaxMsgNums           int32         `json:"maxMsgNums"`
	SysFlag              int32         `json:"sysFlag"`
	CommitOffset         int64         `json:"commitOffset"`
	SuspendTimeoutMillis time.Duration `json:"suspendTimeoutMillis"`
	SubExpression        string        `json:"subscription"`
	SubVersion           int64         `json:"subVersion"`
	ExpressionType       string        `json:"expressionType"`
}

func (*PullMessageRequest) Encode 

func (request *PullMessageRequest) Encode() map[string]string

type PullMessageResponse 

type PullMessageResponse struct {
	SuggestWhichBrokerId int64
	NextBeginOffset      int64
	MinOffset            int64
	MaxOffset            int64
}

type QueryConsumerOffsetRequest 

type QueryConsumerOffsetRequest struct {
	ConsumerGroup string `json:"consumerGroup"`
	Topic         string `json:"topic"`
	QueueId       int    `json:"queueId"`
}

func (*QueryConsumerOffsetRequest) Encode 

func (request *QueryConsumerOffsetRequest) Encode() map[string]string

type QueueData 

type QueueData struct {
	BrokerName     string `json:"brokerName"`
	ReadQueueNums  int    `json:"readQueueNums"`
	WriteQueueNums int    `json:"writeQueueNums"`
	Perm           int    `json:"perm"`
	TopicSynFlag   int    `json:"topicSynFlag"`
}

QueueData QueueData

func (*QueueData) Equals 

func (q *QueueData) Equals(qd *QueueData) bool

type RMQClient 

type RMQClient interface {
	Start()
	Shutdown()

	ClientID() string

	RegisterProducer(group string, producer InnerProducer)
	InvokeSync(addr string, request *remote.RemotingCommand,
		timeoutMillis time.Duration) (*remote.RemotingCommand, error)
	InvokeAsync(addr string, request *remote.RemotingCommand,
		timeoutMillis time.Duration, f func(*remote.RemotingCommand, error)) error
	InvokeOneWay(addr string, request *remote.RemotingCommand,
		timeoutMillis time.Duration) error
	CheckClientInBroker()
	SendHeartbeatToAllBrokerWithLock()
	UpdateTopicRouteInfo()

	ProcessSendResponse(brokerName string, cmd *remote.RemotingCommand, resp *primitive.SendResult, msgs ...*primitive.Message) error

	RegisterConsumer(group string, consumer InnerConsumer) error
	UnregisterConsumer(group string)
	PullMessage(ctx context.Context, brokerAddrs string, request *PullMessageRequest) (*primitive.PullResult, error)
	PullMessageAsync(ctx context.Context, brokerAddrs string, request *PullMessageRequest, f func(result *primitive.PullResult)) error
	RebalanceImmediately()
	UpdatePublishInfo(topic string, data *TopicRouteData)
}

type SearchOffsetRequest 

type SearchOffsetRequest struct {
	Topic     string `json:"topic"`
	QueueId   int    `json:"queueId"`
	Timestamp int64  `json:"timestamp"`
}

func (*SearchOffsetRequest) Encode 

func (request *SearchOffsetRequest) Encode() map[string]string

type SendMessageRequest 

type SendMessageRequest struct {
	ProducerGroup     string `json:"producerGroup"`
	Topic             string `json:"topic"`
	QueueId           int    `json:"queueId"`
	SysFlag           int    `json:"sysFlag"`
	BornTimestamp     int64  `json:"bornTimestamp"`
	Flag              int32  `json:"flag"`
	Properties        string `json:"properties"`
	ReconsumeTimes    int    `json:"reconsumeTimes"`
	UnitMode          bool   `json:"unitMode"`
	MaxReconsumeTimes int    `json:"maxReconsumeTimes"`
	Batch             bool
}

func (*SendMessageRequest) Decode 

func (request *SendMessageRequest) Decode(properties map[string]string) error

func (*SendMessageRequest) Encode 

func (request *SendMessageRequest) Encode() map[string]string

type SendMessageResponse 

type SendMessageResponse struct {
	MsgId         string
	QueueId       int32
	QueueOffset   int64
	TransactionId string
	MsgRegion     string
}

func (*SendMessageResponse) Decode 

func (response *SendMessageResponse) Decode(properties map[string]string)

type ServiceState 

type ServiceState int
const (
	StateCreateJust ServiceState = iota
	StateStartFailed
	StateRunning
	StateShutdown
)

type SubscriptionData 

type SubscriptionData struct {
	ClassFilterMode bool
	Topic           string
	SubString       string
	Tags            map[string]bool
	Codes           map[int32]bool
	SubVersion      int64
	ExpType         string
}

type TopicPublishInfo 

type TopicPublishInfo struct {
	OrderTopic          bool
	HaveTopicRouterInfo bool
	MqList              []*primitive.MessageQueue
	RouteData           *TopicRouteData
	TopicQueueIndex     int32
}

key is topic, value is TopicPublishInfo

type TopicRouteData 

type TopicRouteData struct {
	OrderTopicConf string
	QueueDataList  []*QueueData  `json:"queueDatas"`
	BrokerDataList []*BrokerData `json:"brokerDatas"`
}

TopicRouteData TopicRouteData

func UpdateTopicRouteInfo 

func UpdateTopicRouteInfo(topic string) *TopicRouteData

func (*TopicRouteData) String 

func (routeData *TopicRouteData) String() string

type TransactionListener 

type TransactionListener interface {
}

type UpdateConsumerOffsetRequest 

type UpdateConsumerOffsetRequest struct {
	ConsumerGroup string `json:"consumerGroup"`
	Topic         string `json:"topic"`
	QueueId       int    `json:"queueId"`
	CommitOffset  int64  `json:"commitOffset"`
}

func (*UpdateConsumerOffsetRequest) Encode 

func (request *UpdateConsumerOffsetRequest) Encode() map[string]string

Source Files

View all Source files

Directories

Path Synopsis
* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements.
 * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements.

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.