worker

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package worker is a generated GoMock package.

Package worker is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var ErrTriggerWorkerNotFound = fmt.Errorf("trigger worker not found")

Functions

This section is empty.

Types

type Config 

type Config struct {
	CheckInterval       time.Duration
	LostHeartbeatTime   time.Duration
	HeartbeatTimeout    time.Duration
	DisconnectCleanTime time.Duration
	WaitRunningTimeout  time.Duration

	StartWorkerDuration       time.Duration
	StartSubscriptionDuration time.Duration
}

type Manager 

type Manager interface {
	AddTriggerWorker(ctx context.Context, addr string) error
	GetTriggerWorker(addr string) TriggerWorker
	RemoveTriggerWorker(ctx context.Context, addr string)
	UpdateTriggerWorkerInfo(ctx context.Context, addr string) error
	GetActiveRunningTriggerWorker() []metadata.TriggerWorkerInfo
	Init(ctx context.Context) error
	Start()
	Stop()
}

func NewTriggerWorkerManager 

func NewTriggerWorkerManager(config Config,
	storage storage.TriggerWorkerStorage,
	subscriptionManager subscription.Manager,
	handler OnTriggerWorkerRemoveSubscription,
) Manager

type MockManager 

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

MockManager is a mock of Manager interface.

func NewMockManager 

func NewMockManager(ctrl *gomock.Controller) *MockManager

NewMockManager creates a new mock instance.

func (*MockManager) AddTriggerWorker 

func (m *MockManager) AddTriggerWorker(ctx context.Context, addr string) error

AddTriggerWorker mocks base method.

func (*MockManager) EXPECT 

func (m *MockManager) EXPECT() *MockManagerMockRecorder

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

func (*MockManager) GetActiveRunningTriggerWorker 

func (m *MockManager) GetActiveRunningTriggerWorker() []metadata.TriggerWorkerInfo

GetActiveRunningTriggerWorker mocks base method.

func (*MockManager) GetTriggerWorker 

func (m *MockManager) GetTriggerWorker(addr string) TriggerWorker

GetTriggerWorker mocks base method.

func (*MockManager) Init 

func (m *MockManager) Init(ctx context.Context) error

Init mocks base method.

func (*MockManager) RemoveTriggerWorker 

func (m *MockManager) RemoveTriggerWorker(ctx context.Context, addr string)

RemoveTriggerWorker mocks base method.

func (*MockManager) Start 

func (m *MockManager) Start()

Start mocks base method.

func (*MockManager) Stop 

func (m *MockManager) Stop()

Stop mocks base method.

func (*MockManager) UpdateTriggerWorkerInfo 

func (m *MockManager) UpdateTriggerWorkerInfo(ctx context.Context, addr string) error

UpdateTriggerWorkerInfo mocks base method.

type MockManagerMockRecorder 

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

MockManagerMockRecorder is the mock recorder for MockManager.

func (*MockManagerMockRecorder) AddTriggerWorker 

func (mr *MockManagerMockRecorder) AddTriggerWorker(ctx, addr interface{}) *gomock.Call

AddTriggerWorker indicates an expected call of AddTriggerWorker.

func (*MockManagerMockRecorder) GetActiveRunningTriggerWorker 

func (mr *MockManagerMockRecorder) GetActiveRunningTriggerWorker() *gomock.Call

GetActiveRunningTriggerWorker indicates an expected call of GetActiveRunningTriggerWorker.

func (*MockManagerMockRecorder) GetTriggerWorker 

func (mr *MockManagerMockRecorder) GetTriggerWorker(addr interface{}) *gomock.Call

GetTriggerWorker indicates an expected call of GetTriggerWorker.

func (*MockManagerMockRecorder) Init 

func (mr *MockManagerMockRecorder) Init(ctx interface{}) *gomock.Call

Init indicates an expected call of Init.

func (*MockManagerMockRecorder) RemoveTriggerWorker 

func (mr *MockManagerMockRecorder) RemoveTriggerWorker(ctx, addr interface{}) *gomock.Call

RemoveTriggerWorker indicates an expected call of RemoveTriggerWorker.

func (*MockManagerMockRecorder) Start 

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

Start indicates an expected call of Start.

func (*MockManagerMockRecorder) Stop 

func (mr *MockManagerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockManagerMockRecorder) UpdateTriggerWorkerInfo 

func (mr *MockManagerMockRecorder) UpdateTriggerWorkerInfo(ctx, addr interface{}) *gomock.Call

UpdateTriggerWorkerInfo indicates an expected call of UpdateTriggerWorkerInfo.

type MockTriggerWorker 

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

MockTriggerWorker is a mock of TriggerWorker interface.

func NewMockTriggerWorker 

func NewMockTriggerWorker(ctrl *gomock.Controller) *MockTriggerWorker

NewMockTriggerWorker creates a new mock instance.

func (*MockTriggerWorker) AssignSubscription 

func (m *MockTriggerWorker) AssignSubscription(id vanus.ID)

AssignSubscription mocks base method.

func (*MockTriggerWorker) Close 

func (m *MockTriggerWorker) Close() error

Close mocks base method.

func (*MockTriggerWorker) EXPECT 

func (m *MockTriggerWorker) EXPECT() *MockTriggerWorkerMockRecorder

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

func (*MockTriggerWorker) GetAddr 

func (m *MockTriggerWorker) GetAddr() string

GetAddr mocks base method.

func (*MockTriggerWorker) GetAssignedSubscriptions 

func (m *MockTriggerWorker) GetAssignedSubscriptions() []vanus.ID

GetAssignedSubscriptions mocks base method.

func (*MockTriggerWorker) GetHeartbeatTime 

func (m *MockTriggerWorker) GetHeartbeatTime() time.Time

GetHeartbeatTime mocks base method.

func (*MockTriggerWorker) GetInfo 

func (m *MockTriggerWorker) GetInfo() metadata.TriggerWorkerInfo

GetInfo mocks base method.

func (*MockTriggerWorker) GetPendingTime 

func (m *MockTriggerWorker) GetPendingTime() time.Time

GetPendingTime mocks base method.

func (*MockTriggerWorker) GetPhase 

func (m *MockTriggerWorker) GetPhase() metadata.TriggerWorkerPhase

GetPhase mocks base method.

func (*MockTriggerWorker) IsActive 

func (m *MockTriggerWorker) IsActive() bool

IsActive mocks base method.

func (*MockTriggerWorker) Polish 

func (m *MockTriggerWorker) Polish()

Polish mocks base method.

func (*MockTriggerWorker) RemoteStart 

func (m *MockTriggerWorker) RemoteStart(ctx context.Context) error

RemoteStart mocks base method.

func (*MockTriggerWorker) RemoteStop 

func (m *MockTriggerWorker) RemoteStop(ctx context.Context) error

RemoteStop mocks base method.

func (*MockTriggerWorker) Reset 

func (m *MockTriggerWorker) Reset()

Reset mocks base method.

func (*MockTriggerWorker) SetPhase 

func (m *MockTriggerWorker) SetPhase(arg0 metadata.TriggerWorkerPhase)

SetPhase mocks base method.

func (*MockTriggerWorker) Start 

func (m *MockTriggerWorker) Start(ctx context.Context) error

Start mocks base method.

func (*MockTriggerWorker) UnAssignSubscription 

func (m *MockTriggerWorker) UnAssignSubscription(id vanus.ID) error

UnAssignSubscription mocks base method.

type MockTriggerWorkerMockRecorder 

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

MockTriggerWorkerMockRecorder is the mock recorder for MockTriggerWorker.

func (*MockTriggerWorkerMockRecorder) AssignSubscription 

func (mr *MockTriggerWorkerMockRecorder) AssignSubscription(id interface{}) *gomock.Call

AssignSubscription indicates an expected call of AssignSubscription.

func (*MockTriggerWorkerMockRecorder) Close 

func (mr *MockTriggerWorkerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockTriggerWorkerMockRecorder) GetAddr 

func (mr *MockTriggerWorkerMockRecorder) GetAddr() *gomock.Call

GetAddr indicates an expected call of GetAddr.

func (*MockTriggerWorkerMockRecorder) GetAssignedSubscriptions 

func (mr *MockTriggerWorkerMockRecorder) GetAssignedSubscriptions() *gomock.Call

GetAssignedSubscriptions indicates an expected call of GetAssignedSubscriptions.

func (*MockTriggerWorkerMockRecorder) GetHeartbeatTime 

func (mr *MockTriggerWorkerMockRecorder) GetHeartbeatTime() *gomock.Call

GetHeartbeatTime indicates an expected call of GetHeartbeatTime.

func (*MockTriggerWorkerMockRecorder) GetInfo 

func (mr *MockTriggerWorkerMockRecorder) GetInfo() *gomock.Call

GetInfo indicates an expected call of GetInfo.

func (*MockTriggerWorkerMockRecorder) GetPendingTime 

func (mr *MockTriggerWorkerMockRecorder) GetPendingTime() *gomock.Call

GetPendingTime indicates an expected call of GetPendingTime.

func (*MockTriggerWorkerMockRecorder) GetPhase 

func (mr *MockTriggerWorkerMockRecorder) GetPhase() *gomock.Call

GetPhase indicates an expected call of GetPhase.

func (*MockTriggerWorkerMockRecorder) IsActive 

func (mr *MockTriggerWorkerMockRecorder) IsActive() *gomock.Call

IsActive indicates an expected call of IsActive.

func (*MockTriggerWorkerMockRecorder) Polish 

func (mr *MockTriggerWorkerMockRecorder) Polish() *gomock.Call

Polish indicates an expected call of Polish.

func (*MockTriggerWorkerMockRecorder) RemoteStart 

func (mr *MockTriggerWorkerMockRecorder) RemoteStart(ctx interface{}) *gomock.Call

RemoteStart indicates an expected call of RemoteStart.

func (*MockTriggerWorkerMockRecorder) RemoteStop 

func (mr *MockTriggerWorkerMockRecorder) RemoteStop(ctx interface{}) *gomock.Call

RemoteStop indicates an expected call of RemoteStop.

func (*MockTriggerWorkerMockRecorder) Reset 

func (mr *MockTriggerWorkerMockRecorder) Reset() *gomock.Call

Reset indicates an expected call of Reset.

func (*MockTriggerWorkerMockRecorder) SetPhase 

func (mr *MockTriggerWorkerMockRecorder) SetPhase(arg0 interface{}) *gomock.Call

SetPhase indicates an expected call of SetPhase.

func (*MockTriggerWorkerMockRecorder) Start 

func (mr *MockTriggerWorkerMockRecorder) Start(ctx interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockTriggerWorkerMockRecorder) UnAssignSubscription 

func (mr *MockTriggerWorkerMockRecorder) UnAssignSubscription(id interface{}) *gomock.Call

UnAssignSubscription indicates an expected call of UnAssignSubscription.

type OnTriggerWorkerRemoveSubscription 

type OnTriggerWorkerRemoveSubscription func(ctx context.Context, subId vanus.ID, addr string) error

type RandomPolicy 

type RandomPolicy struct {
}

func (*RandomPolicy) Acquire 

func (r *RandomPolicy) Acquire(_ context.Context, workers []metadata.TriggerWorkerInfo) metadata.TriggerWorkerInfo

type RoundRobinPolicy 

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

func (*RoundRobinPolicy) Acquire 

func (rr *RoundRobinPolicy) Acquire(_ context.Context,
	workers []metadata.TriggerWorkerInfo) metadata.TriggerWorkerInfo

type SubscriptionScheduler 

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

func NewSubscriptionScheduler 

func NewSubscriptionScheduler(workerManager Manager,
	subscriptionManager subscription.Manager,
) *SubscriptionScheduler

func (*SubscriptionScheduler) EnqueueNormalSubscription 

func (s *SubscriptionScheduler) EnqueueNormalSubscription(id vanus.ID)

func (*SubscriptionScheduler) EnqueueSubscription 

func (s *SubscriptionScheduler) EnqueueSubscription(id vanus.ID)

func (*SubscriptionScheduler) Run 

func (s *SubscriptionScheduler) Run()

func (*SubscriptionScheduler) Stop 

func (s *SubscriptionScheduler) Stop()

type TriggerWorker 

type TriggerWorker interface {
	Start(ctx context.Context) error
	RemoteStart(ctx context.Context) error
	RemoteStop(ctx context.Context) error
	Close() error
	IsActive() bool
	Reset()
	GetInfo() metadata.TriggerWorkerInfo
	GetAddr() string
	SetPhase(metadata.TriggerWorkerPhase)
	GetPhase() metadata.TriggerWorkerPhase
	GetPendingTime() time.Time
	GetHeartbeatTime() time.Time
	Polish()
	AssignSubscription(id vanus.ID)
	UnAssignSubscription(id vanus.ID) error
	GetAssignedSubscriptions() []vanus.ID
}

func NewTriggerWorker 

func NewTriggerWorker(twInfo *metadata.TriggerWorkerInfo, subscriptionManager subscription.Manager) TriggerWorker

func NewTriggerWorkerByAddr 

func NewTriggerWorkerByAddr(addr string, subscriptionManager subscription.Manager) TriggerWorker

type TriggerWorkerPolicy 

type TriggerWorkerPolicy interface {
	Acquire(context.Context, []metadata.TriggerWorkerInfo) metadata.TriggerWorkerInfo
}

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.