msgdispatcher

Documentation

Index

• Variables
• type Client
  • func NewClient(factory msgstream.Factory, role string, nodeID int64) Client
• type Dispatcher
  • func NewDispatcher(factory msgstream.Factory, isMain bool, pchannel string, position *Pos, ...) (*Dispatcher, error)
  • func (d *Dispatcher) AddTarget(t *target)
  • func (d *Dispatcher) CloseTarget(vchannel string)
  • func (d *Dispatcher) CurTs() typeutil.Timestamp
  • func (d *Dispatcher) GetTarget(vchannel string) (*target, error)
  • func (d *Dispatcher) Handle(signal signal)
  • func (d *Dispatcher) TargetNum() int
• type DispatcherManager
  • func NewDispatcherManager(pchannel string, role string, nodeID int64, factory msgstream.Factory) DispatcherManager
• type MockClient
  • func NewMockClient(t mockConstructorTestingTNewMockClient) *MockClient
  • func (_m *MockClient) Close()
  • func (_m *MockClient) Deregister(vchannel string)
  • func (_m *MockClient) EXPECT() *MockClient_Expecter
  • func (_m *MockClient) Register(vchannel string, pos *msgpb.MsgPosition, ...) (<-chan *msgstream.MsgPack, error)
• type MockClient_Close_Call
  • func (_c *MockClient_Close_Call) Return() *MockClient_Close_Call
  • func (_c *MockClient_Close_Call) Run(run func()) *MockClient_Close_Call
• type MockClient_Deregister_Call
  • func (_c *MockClient_Deregister_Call) Return() *MockClient_Deregister_Call
  • func (_c *MockClient_Deregister_Call) Run(run func(vchannel string)) *MockClient_Deregister_Call
• type MockClient_Expecter
  • func (_e *MockClient_Expecter) Close() *MockClient_Close_Call
  • func (_e *MockClient_Expecter) Deregister(vchannel interface{}) *MockClient_Deregister_Call
  • func (_e *MockClient_Expecter) Register(vchannel interface{}, pos interface{}, subPos interface{}) *MockClient_Register_Call
• type MockClient_Register_Call
  • func (_c *MockClient_Register_Call) Return(_a0 <-chan *msgstream.MsgPack, _a1 error) *MockClient_Register_Call
  • func (_c *MockClient_Register_Call) Run(run func(vchannel string, pos *msgpb.MsgPosition, ...)) *MockClient_Register_Call
• type MsgPack
• type Pos
• type SubPos

Variables

var (
	MaxTolerantLag        = 3 * time.Second
	DefaultTargetChanSize = 1024
)

TODO: dyh, move to config

var (
	CheckPeriod = 1 * time.Second // TODO: dyh, move to config
)

Types

type Client

type Client interface {
	Register(vchannel string, pos *Pos, subPos SubPos) (<-chan *MsgPack, error)
	Deregister(vchannel string)
	Close()
}

func NewClient

func NewClient(factory msgstream.Factory, role string, nodeID int64) Client

type Dispatcher

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

func NewDispatcher

func NewDispatcher(factory msgstream.Factory,
	isMain bool,
	pchannel string,
	position *Pos,
	subName string,
	subPos SubPos,
	lagNotifyChan chan struct{},
	lagTargets *sync.Map,
) (*Dispatcher, error)

func (*Dispatcher) AddTarget

func (d *Dispatcher) AddTarget(t *target)

func (*Dispatcher) CloseTarget

func (d *Dispatcher) CloseTarget(vchannel string)

func (*Dispatcher) CurTs

func (d *Dispatcher) CurTs() typeutil.Timestamp

func (*Dispatcher) GetTarget

func (d *Dispatcher) GetTarget(vchannel string) (*target, error)

func (*Dispatcher) Handle

func (d *Dispatcher) Handle(signal signal)

func (*Dispatcher) TargetNum

func (d *Dispatcher) TargetNum() int

type DispatcherManager

type DispatcherManager interface {
	Add(vchannel string, pos *Pos, subPos SubPos) (<-chan *MsgPack, error)
	Remove(vchannel string)
	Num() int
	Run()
	Close()
}

func NewDispatcherManager

func NewDispatcherManager(pchannel string, role string, nodeID int64, factory msgstream.Factory) DispatcherManager

type MockClient

type MockClient struct {
	mock.Mock
}

MockClient is an autogenerated mock type for the Client type

func NewMockClient

func NewMockClient(t mockConstructorTestingTNewMockClient) *MockClient

NewMockClient creates a new instance of MockClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockClient) Close

func (_m *MockClient) Close()

Close provides a mock function with given fields:

func (*MockClient) Deregister

func (_m *MockClient) Deregister(vchannel string)

Deregister provides a mock function with given fields: vchannel

func (*MockClient) EXPECT

func (_m *MockClient) EXPECT() *MockClient_Expecter

func (*MockClient) Register

func (_m *MockClient) Register(vchannel string, pos *msgpb.MsgPosition, subPos mqwrapper.SubscriptionInitialPosition) (<-chan *msgstream.MsgPack, error)

Register provides a mock function with given fields: vchannel, pos, subPos

type MockClient_Close_Call

type MockClient_Close_Call struct {
	*mock.Call
}

MockClient_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*MockClient_Close_Call) Return

func (_c *MockClient_Close_Call) Return() *MockClient_Close_Call

func (*MockClient_Close_Call) Run

func (_c *MockClient_Close_Call) Run(run func()) *MockClient_Close_Call

type MockClient_Deregister_Call

type MockClient_Deregister_Call struct {
	*mock.Call
}

MockClient_Deregister_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Deregister'

func (*MockClient_Deregister_Call) Return

func (_c *MockClient_Deregister_Call) Return() *MockClient_Deregister_Call

func (*MockClient_Deregister_Call) Run

func (_c *MockClient_Deregister_Call) Run(run func(vchannel string)) *MockClient_Deregister_Call

type MockClient_Expecter

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

func (*MockClient_Expecter) Close

func (_e *MockClient_Expecter) Close() *MockClient_Close_Call

Close is a helper method to define mock.On call

func (*MockClient_Expecter) Deregister

func (_e *MockClient_Expecter) Deregister(vchannel interface{}) *MockClient_Deregister_Call

Deregister is a helper method to define mock.On call

• vchannel string

func (*MockClient_Expecter) Register

func (_e *MockClient_Expecter) Register(vchannel interface{}, pos interface{}, subPos interface{}) *MockClient_Register_Call

Register is a helper method to define mock.On call

• vchannel string
• pos *msgpb.MsgPosition
• subPos mqwrapper.SubscriptionInitialPosition

type MockClient_Register_Call

type MockClient_Register_Call struct {
	*mock.Call
}

MockClient_Register_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Register'

func (*MockClient_Register_Call) Return

func (_c *MockClient_Register_Call) Return(_a0 <-chan *msgstream.MsgPack, _a1 error) *MockClient_Register_Call

func (*MockClient_Register_Call) Run

func (_c *MockClient_Register_Call) Run(run func(vchannel string, pos *msgpb.MsgPosition, subPos mqwrapper.SubscriptionInitialPosition)) *MockClient_Register_Call

type MsgPack

type MsgPack = msgstream.MsgPack

type Pos

type Pos = msgpb.MsgPosition

type SubPos

type SubPos = mqwrapper.SubscriptionInitialPosition