queuev2

package
v1.3.4-prerelease01 Latest Latest
Warning

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

 Go to latest Published: Jul 29, 2025 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Overview

Package queuev2 is a generated GoMock package.

Package queuev2 is a generated GoMock package.

Package queuev2 is a generated GoMock package.

Package queuev2 is a generated GoMock package.

Package queuev2 is a generated GoMock package.

Package queuev2 is a generated GoMock package.

Package queuev2 is a generated GoMock package.

Package queuev2 is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromPersistenceTaskKey 

func FromPersistenceTaskKey(key *types.TaskKey) persistence.HistoryTaskKey

func NewTimerQueueFactory added in v1.3.2 

func NewTimerQueueFactory(
	taskProcessor task.Processor,
	archivalClient archiver.Client,
) queue.Factory

func NewTransferQueueFactory added in v1.3.2 

func NewTransferQueueFactory(
	taskProcessor task.Processor,
	archivalClient archiver.Client,
	wfIDCache workflowcache.WFCache,
) queue.Factory

func ToPersistencePredicate added in v1.3.4 

func ToPersistencePredicate(predicate Predicate) *types.Predicate

func ToPersistenceQueueState 

func ToPersistenceQueueState(state *QueueState) *types.QueueState

func ToPersistenceTaskKey 

func ToPersistenceTaskKey(key persistence.HistoryTaskKey) *types.TaskKey

func ToPersistenceTaskRange 

func ToPersistenceTaskRange(r Range) *types.TaskRange

func ToPersistenceVirtualQueueState 

func ToPersistenceVirtualQueueState(state []VirtualSliceState) *types.VirtualQueueState

func ToPersistenceVirtualSliceState 

func ToPersistenceVirtualSliceState(state VirtualSliceState) *types.VirtualSliceState

Types

type GetTaskProgress added in v1.3.2 

type GetTaskProgress struct {
	Range
	NextPageToken []byte
	NextTaskKey   persistence.HistoryTaskKey
}

GetTaskProgress contains the range of the slice to read, the next page token, and the next task key

type GetTaskRequest added in v1.3.2 

type GetTaskRequest struct {
	Progress  *GetTaskProgress
	Predicate Predicate
	PageSize  int
}

type GetTaskResponse added in v1.3.2 

type GetTaskResponse struct {
	Tasks    []persistence.Task
	Progress *GetTaskProgress
}

type MockMonitor added in v1.3.3 

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

MockMonitor is a mock of Monitor interface.

func NewMockMonitor added in v1.3.3 

func NewMockMonitor(ctrl *gomock.Controller) *MockMonitor

NewMockMonitor creates a new mock instance.

func (*MockMonitor) EXPECT added in v1.3.3 

func (m *MockMonitor) EXPECT() *MockMonitorMockRecorder

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

func (*MockMonitor) GetSlicePendingTaskCount added in v1.3.3 

func (m *MockMonitor) GetSlicePendingTaskCount(arg0 VirtualSlice) int

GetSlicePendingTaskCount mocks base method.

func (*MockMonitor) GetTotalPendingTaskCount added in v1.3.3 

func (m *MockMonitor) GetTotalPendingTaskCount() int

GetTotalPendingTaskCount mocks base method.

func (*MockMonitor) RemoveSlice added in v1.3.3 

func (m *MockMonitor) RemoveSlice(arg0 VirtualSlice)

RemoveSlice mocks base method.

func (*MockMonitor) SetSlicePendingTaskCount added in v1.3.3 

func (m *MockMonitor) SetSlicePendingTaskCount(arg0 VirtualSlice, arg1 int)

SetSlicePendingTaskCount mocks base method.

type MockMonitorMockRecorder added in v1.3.3 

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

MockMonitorMockRecorder is the mock recorder for MockMonitor.

func (*MockMonitorMockRecorder) GetSlicePendingTaskCount added in v1.3.3 

func (mr *MockMonitorMockRecorder) GetSlicePendingTaskCount(arg0 any) *gomock.Call

GetSlicePendingTaskCount indicates an expected call of GetSlicePendingTaskCount.

func (*MockMonitorMockRecorder) GetTotalPendingTaskCount added in v1.3.3 

func (mr *MockMonitorMockRecorder) GetTotalPendingTaskCount() *gomock.Call

GetTotalPendingTaskCount indicates an expected call of GetTotalPendingTaskCount.

func (*MockMonitorMockRecorder) RemoveSlice added in v1.3.3 

func (mr *MockMonitorMockRecorder) RemoveSlice(arg0 any) *gomock.Call

RemoveSlice indicates an expected call of RemoveSlice.

func (*MockMonitorMockRecorder) SetSlicePendingTaskCount added in v1.3.3 

func (mr *MockMonitorMockRecorder) SetSlicePendingTaskCount(arg0, arg1 any) *gomock.Call

SetSlicePendingTaskCount indicates an expected call of SetSlicePendingTaskCount.

type MockPauseController added in v1.3.3 

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

MockPauseController is a mock of PauseController interface.

func NewMockPauseController added in v1.3.3 

func NewMockPauseController(ctrl *gomock.Controller) *MockPauseController

NewMockPauseController creates a new mock instance.

func (*MockPauseController) EXPECT added in v1.3.3 

func (m *MockPauseController) EXPECT() *MockPauseControllerMockRecorder

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

func (*MockPauseController) IsPaused added in v1.3.3 

func (m *MockPauseController) IsPaused() bool

IsPaused mocks base method.

func (*MockPauseController) Pause added in v1.3.3 

func (m *MockPauseController) Pause(arg0 time.Duration)

Pause mocks base method.

func (*MockPauseController) Resume added in v1.3.3 

func (m *MockPauseController) Resume()

Resume mocks base method.

func (*MockPauseController) Stop added in v1.3.3 

func (m *MockPauseController) Stop()

Stop mocks base method.

func (*MockPauseController) Subscribe added in v1.3.3 

func (m *MockPauseController) Subscribe(arg0 string, arg1 chan<- struct{})

Subscribe mocks base method.

func (*MockPauseController) Unsubscribe added in v1.3.3 

func (m *MockPauseController) Unsubscribe(arg0 string)

Unsubscribe mocks base method.

type MockPauseControllerMockRecorder added in v1.3.3 

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

MockPauseControllerMockRecorder is the mock recorder for MockPauseController.

func (*MockPauseControllerMockRecorder) IsPaused added in v1.3.3 

func (mr *MockPauseControllerMockRecorder) IsPaused() *gomock.Call

IsPaused indicates an expected call of IsPaused.

func (*MockPauseControllerMockRecorder) Pause added in v1.3.3 

func (mr *MockPauseControllerMockRecorder) Pause(arg0 any) *gomock.Call

Pause indicates an expected call of Pause.

func (*MockPauseControllerMockRecorder) Resume added in v1.3.3 

func (mr *MockPauseControllerMockRecorder) Resume() *gomock.Call

Resume indicates an expected call of Resume.

func (*MockPauseControllerMockRecorder) Stop added in v1.3.3 

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

Stop indicates an expected call of Stop.

func (*MockPauseControllerMockRecorder) Subscribe added in v1.3.3 

func (mr *MockPauseControllerMockRecorder) Subscribe(arg0, arg1 any) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockPauseControllerMockRecorder) Unsubscribe added in v1.3.3 

func (mr *MockPauseControllerMockRecorder) Unsubscribe(arg0 any) *gomock.Call

Unsubscribe indicates an expected call of Unsubscribe.

type MockPendingTaskTracker added in v1.3.2 

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

MockPendingTaskTracker is a mock of PendingTaskTracker interface.

func NewMockPendingTaskTracker added in v1.3.2 

func NewMockPendingTaskTracker(ctrl *gomock.Controller) *MockPendingTaskTracker

NewMockPendingTaskTracker creates a new mock instance.

func (*MockPendingTaskTracker) AddTask added in v1.3.2 

func (m *MockPendingTaskTracker) AddTask(arg0 task.Task)

AddTask mocks base method.

func (*MockPendingTaskTracker) Clear added in v1.3.3 

func (m *MockPendingTaskTracker) Clear()

Clear mocks base method.

func (*MockPendingTaskTracker) EXPECT added in v1.3.2 

func (m *MockPendingTaskTracker) EXPECT() *MockPendingTaskTrackerMockRecorder

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

func (*MockPendingTaskTracker) GetMinimumTaskKey added in v1.3.2 

func (m *MockPendingTaskTracker) GetMinimumTaskKey() (persistence.HistoryTaskKey, bool)

GetMinimumTaskKey mocks base method.

func (*MockPendingTaskTracker) GetPendingTaskCount added in v1.3.3 

func (m *MockPendingTaskTracker) GetPendingTaskCount() int

GetPendingTaskCount mocks base method.

func (*MockPendingTaskTracker) GetTasks added in v1.3.2 

func (m *MockPendingTaskTracker) GetTasks() map[persistence.HistoryTaskKey]task.Task

GetTasks mocks base method.

func (*MockPendingTaskTracker) PruneAckedTasks added in v1.3.2 

func (m *MockPendingTaskTracker) PruneAckedTasks()

PruneAckedTasks mocks base method.

type MockPendingTaskTrackerMockRecorder added in v1.3.2 

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

MockPendingTaskTrackerMockRecorder is the mock recorder for MockPendingTaskTracker.

func (*MockPendingTaskTrackerMockRecorder) AddTask added in v1.3.2 

func (mr *MockPendingTaskTrackerMockRecorder) AddTask(arg0 any) *gomock.Call

AddTask indicates an expected call of AddTask.

func (*MockPendingTaskTrackerMockRecorder) Clear added in v1.3.3 

func (mr *MockPendingTaskTrackerMockRecorder) Clear() *gomock.Call

Clear indicates an expected call of Clear.

func (*MockPendingTaskTrackerMockRecorder) GetMinimumTaskKey added in v1.3.2 

func (mr *MockPendingTaskTrackerMockRecorder) GetMinimumTaskKey() *gomock.Call

GetMinimumTaskKey indicates an expected call of GetMinimumTaskKey.

func (*MockPendingTaskTrackerMockRecorder) GetPendingTaskCount added in v1.3.3 

func (mr *MockPendingTaskTrackerMockRecorder) GetPendingTaskCount() *gomock.Call

GetPendingTaskCount indicates an expected call of GetPendingTaskCount.

func (*MockPendingTaskTrackerMockRecorder) GetTasks added in v1.3.2 

func (mr *MockPendingTaskTrackerMockRecorder) GetTasks() *gomock.Call

GetTasks indicates an expected call of GetTasks.

func (*MockPendingTaskTrackerMockRecorder) PruneAckedTasks added in v1.3.2 

func (mr *MockPendingTaskTrackerMockRecorder) PruneAckedTasks() *gomock.Call

PruneAckedTasks indicates an expected call of PruneAckedTasks.

type MockPredicate 

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

MockPredicate is a mock of Predicate interface.

func NewMockPredicate 

func NewMockPredicate(ctrl *gomock.Controller) *MockPredicate

NewMockPredicate creates a new mock instance.

func (*MockPredicate) Check 

func (m *MockPredicate) Check(task persistence.Task) bool

Check mocks base method.

func (*MockPredicate) EXPECT 

func (m *MockPredicate) EXPECT() *MockPredicateMockRecorder

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

func (*MockPredicate) Equals added in v1.3.2 

func (m *MockPredicate) Equals(other Predicate) bool

Equals mocks base method.

func (*MockPredicate) IsEmpty 

func (m *MockPredicate) IsEmpty() bool

IsEmpty mocks base method.

type MockPredicateMockRecorder 

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

MockPredicateMockRecorder is the mock recorder for MockPredicate.

func (*MockPredicateMockRecorder) Check 

func (mr *MockPredicateMockRecorder) Check(task any) *gomock.Call

Check indicates an expected call of Check.

func (*MockPredicateMockRecorder) Equals added in v1.3.2 

func (mr *MockPredicateMockRecorder) Equals(other any) *gomock.Call

Equals indicates an expected call of Equals.

func (*MockPredicateMockRecorder) IsEmpty 

func (mr *MockPredicateMockRecorder) IsEmpty() *gomock.Call

IsEmpty indicates an expected call of IsEmpty.

type MockQueueReader added in v1.3.2 

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

MockQueueReader is a mock of QueueReader interface.

func NewMockQueueReader added in v1.3.2 

func NewMockQueueReader(ctrl *gomock.Controller) *MockQueueReader

NewMockQueueReader creates a new mock instance.

func (*MockQueueReader) EXPECT added in v1.3.2 

func (m *MockQueueReader) EXPECT() *MockQueueReaderMockRecorder

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

func (*MockQueueReader) GetTask added in v1.3.2 

func (m *MockQueueReader) GetTask(arg0 context.Context, arg1 *GetTaskRequest) (*GetTaskResponse, error)

GetTask mocks base method.

type MockQueueReaderMockRecorder added in v1.3.2 

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

MockQueueReaderMockRecorder is the mock recorder for MockQueueReader.

func (*MockQueueReaderMockRecorder) GetTask added in v1.3.2 

func (mr *MockQueueReaderMockRecorder) GetTask(arg0, arg1 any) *gomock.Call

GetTask indicates an expected call of GetTask.

type MockVirtualQueue added in v1.3.2 

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

MockVirtualQueue is a mock of VirtualQueue interface.

func NewMockVirtualQueue added in v1.3.2 

func NewMockVirtualQueue(ctrl *gomock.Controller) *MockVirtualQueue

NewMockVirtualQueue creates a new mock instance.

func (*MockVirtualQueue) EXPECT added in v1.3.2 

func (m *MockVirtualQueue) EXPECT() *MockVirtualQueueMockRecorder

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

func (*MockVirtualQueue) GetState added in v1.3.2 

func (m *MockVirtualQueue) GetState() []VirtualSliceState

GetState mocks base method.

func (*MockVirtualQueue) MergeSlices added in v1.3.2 

func (m *MockVirtualQueue) MergeSlices(arg0 ...VirtualSlice)

MergeSlices mocks base method.

func (*MockVirtualQueue) Start added in v1.3.2 

func (m *MockVirtualQueue) Start()

Start mocks base method.

func (*MockVirtualQueue) Stop added in v1.3.2 

func (m *MockVirtualQueue) Stop()

Stop mocks base method.

func (*MockVirtualQueue) UpdateAndGetState added in v1.3.2 

func (m *MockVirtualQueue) UpdateAndGetState() []VirtualSliceState

UpdateAndGetState mocks base method.

type MockVirtualQueueManager added in v1.3.2 

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

MockVirtualQueueManager is a mock of VirtualQueueManager interface.

func NewMockVirtualQueueManager added in v1.3.2 

func NewMockVirtualQueueManager(ctrl *gomock.Controller) *MockVirtualQueueManager

NewMockVirtualQueueManager creates a new mock instance.

func (*MockVirtualQueueManager) AddNewVirtualSliceToRootQueue added in v1.3.2 

func (m *MockVirtualQueueManager) AddNewVirtualSliceToRootQueue(arg0 VirtualSlice)

AddNewVirtualSliceToRootQueue mocks base method.

func (*MockVirtualQueueManager) EXPECT added in v1.3.2 

func (m *MockVirtualQueueManager) EXPECT() *MockVirtualQueueManagerMockRecorder

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

func (*MockVirtualQueueManager) GetState added in v1.3.2 

func (m *MockVirtualQueueManager) GetState() map[int64][]VirtualSliceState

GetState mocks base method.

func (*MockVirtualQueueManager) Start added in v1.3.2 

func (m *MockVirtualQueueManager) Start()

Start mocks base method.

func (*MockVirtualQueueManager) Stop added in v1.3.2 

func (m *MockVirtualQueueManager) Stop()

Stop mocks base method.

func (*MockVirtualQueueManager) UpdateAndGetState added in v1.3.2 

func (m *MockVirtualQueueManager) UpdateAndGetState() map[int64][]VirtualSliceState

UpdateAndGetState mocks base method.

type MockVirtualQueueManagerMockRecorder added in v1.3.2 

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

MockVirtualQueueManagerMockRecorder is the mock recorder for MockVirtualQueueManager.

func (*MockVirtualQueueManagerMockRecorder) AddNewVirtualSliceToRootQueue added in v1.3.2 

func (mr *MockVirtualQueueManagerMockRecorder) AddNewVirtualSliceToRootQueue(arg0 any) *gomock.Call

AddNewVirtualSliceToRootQueue indicates an expected call of AddNewVirtualSliceToRootQueue.

func (*MockVirtualQueueManagerMockRecorder) GetState added in v1.3.2 

func (mr *MockVirtualQueueManagerMockRecorder) GetState() *gomock.Call

GetState indicates an expected call of GetState.

func (*MockVirtualQueueManagerMockRecorder) Start added in v1.3.2 

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

Start indicates an expected call of Start.

func (*MockVirtualQueueManagerMockRecorder) Stop added in v1.3.2 

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

Stop indicates an expected call of Stop.

func (*MockVirtualQueueManagerMockRecorder) UpdateAndGetState added in v1.3.2 

func (mr *MockVirtualQueueManagerMockRecorder) UpdateAndGetState() *gomock.Call

UpdateAndGetState indicates an expected call of UpdateAndGetState.

type MockVirtualQueueMockRecorder added in v1.3.2 

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

MockVirtualQueueMockRecorder is the mock recorder for MockVirtualQueue.

func (*MockVirtualQueueMockRecorder) GetState added in v1.3.2 

func (mr *MockVirtualQueueMockRecorder) GetState() *gomock.Call

GetState indicates an expected call of GetState.

func (*MockVirtualQueueMockRecorder) MergeSlices added in v1.3.2 

func (mr *MockVirtualQueueMockRecorder) MergeSlices(arg0 ...any) *gomock.Call

MergeSlices indicates an expected call of MergeSlices.

func (*MockVirtualQueueMockRecorder) Start added in v1.3.2 

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

Start indicates an expected call of Start.

func (*MockVirtualQueueMockRecorder) Stop added in v1.3.2 

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

Stop indicates an expected call of Stop.

func (*MockVirtualQueueMockRecorder) UpdateAndGetState added in v1.3.2 

func (mr *MockVirtualQueueMockRecorder) UpdateAndGetState() *gomock.Call

UpdateAndGetState indicates an expected call of UpdateAndGetState.

type MockVirtualSlice added in v1.3.2 

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

MockVirtualSlice is a mock of VirtualSlice interface.

func NewMockVirtualSlice added in v1.3.2 

func NewMockVirtualSlice(ctrl *gomock.Controller) *MockVirtualSlice

NewMockVirtualSlice creates a new mock instance.

func (*MockVirtualSlice) Clear added in v1.3.3 

func (m *MockVirtualSlice) Clear()

Clear mocks base method.

func (*MockVirtualSlice) EXPECT added in v1.3.2 

func (m *MockVirtualSlice) EXPECT() *MockVirtualSliceMockRecorder

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

func (*MockVirtualSlice) GetPendingTaskCount added in v1.3.3 

func (m *MockVirtualSlice) GetPendingTaskCount() int

GetPendingTaskCount mocks base method.

func (*MockVirtualSlice) GetState added in v1.3.2 

func (m *MockVirtualSlice) GetState() VirtualSliceState

GetState mocks base method.

func (*MockVirtualSlice) GetTasks added in v1.3.2 

func (m *MockVirtualSlice) GetTasks(arg0 context.Context, arg1 int) ([]task.Task, error)

GetTasks mocks base method.

func (*MockVirtualSlice) HasMoreTasks added in v1.3.2 

func (m *MockVirtualSlice) HasMoreTasks() bool

HasMoreTasks mocks base method.

func (*MockVirtualSlice) TryMergeWithVirtualSlice added in v1.3.2 

func (m *MockVirtualSlice) TryMergeWithVirtualSlice(arg0 VirtualSlice) ([]VirtualSlice, bool)

TryMergeWithVirtualSlice mocks base method.

func (*MockVirtualSlice) TrySplitByTaskKey added in v1.3.2 

func (m *MockVirtualSlice) TrySplitByTaskKey(arg0 persistence.HistoryTaskKey) (VirtualSlice, VirtualSlice, bool)

TrySplitByTaskKey mocks base method.

func (*MockVirtualSlice) UpdateAndGetState added in v1.3.2 

func (m *MockVirtualSlice) UpdateAndGetState() VirtualSliceState

UpdateAndGetState mocks base method.

type MockVirtualSliceMockRecorder added in v1.3.2 

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

MockVirtualSliceMockRecorder is the mock recorder for MockVirtualSlice.

func (*MockVirtualSliceMockRecorder) Clear added in v1.3.3 

func (mr *MockVirtualSliceMockRecorder) Clear() *gomock.Call

Clear indicates an expected call of Clear.

func (*MockVirtualSliceMockRecorder) GetPendingTaskCount added in v1.3.3 

func (mr *MockVirtualSliceMockRecorder) GetPendingTaskCount() *gomock.Call

GetPendingTaskCount indicates an expected call of GetPendingTaskCount.

func (*MockVirtualSliceMockRecorder) GetState added in v1.3.2 

func (mr *MockVirtualSliceMockRecorder) GetState() *gomock.Call

GetState indicates an expected call of GetState.

func (*MockVirtualSliceMockRecorder) GetTasks added in v1.3.2 

func (mr *MockVirtualSliceMockRecorder) GetTasks(arg0, arg1 any) *gomock.Call

GetTasks indicates an expected call of GetTasks.

func (*MockVirtualSliceMockRecorder) HasMoreTasks added in v1.3.2 

func (mr *MockVirtualSliceMockRecorder) HasMoreTasks() *gomock.Call

HasMoreTasks indicates an expected call of HasMoreTasks.

func (*MockVirtualSliceMockRecorder) TryMergeWithVirtualSlice added in v1.3.2 

func (mr *MockVirtualSliceMockRecorder) TryMergeWithVirtualSlice(arg0 any) *gomock.Call

TryMergeWithVirtualSlice indicates an expected call of TryMergeWithVirtualSlice.

func (*MockVirtualSliceMockRecorder) TrySplitByTaskKey added in v1.3.2 

func (mr *MockVirtualSliceMockRecorder) TrySplitByTaskKey(arg0 any) *gomock.Call

TrySplitByTaskKey indicates an expected call of TrySplitByTaskKey.

func (*MockVirtualSliceMockRecorder) UpdateAndGetState added in v1.3.2 

func (mr *MockVirtualSliceMockRecorder) UpdateAndGetState() *gomock.Call

UpdateAndGetState indicates an expected call of UpdateAndGetState.

type Monitor added in v1.3.3 

type Monitor interface {
	GetTotalPendingTaskCount() int
	GetSlicePendingTaskCount(VirtualSlice) int
	SetSlicePendingTaskCount(VirtualSlice, int)
	RemoveSlice(VirtualSlice)
}

func NewMonitor added in v1.3.3 

func NewMonitor(category persistence.HistoryTaskCategory) Monitor

type Options added in v1.3.2 

type Options struct {
	PageSize                             dynamicproperties.IntPropertyFn
	DeleteBatchSize                      dynamicproperties.IntPropertyFn
	MaxPollRPS                           dynamicproperties.IntPropertyFn
	MaxPollInterval                      dynamicproperties.DurationPropertyFn
	MaxPollIntervalJitterCoefficient     dynamicproperties.FloatPropertyFn
	UpdateAckInterval                    dynamicproperties.DurationPropertyFn
	UpdateAckIntervalJitterCoefficient   dynamicproperties.FloatPropertyFn
	RedispatchInterval                   dynamicproperties.DurationPropertyFn
	MaxPendingTasksCount                 dynamicproperties.IntPropertyFn
	PollBackoffInterval                  dynamicproperties.DurationPropertyFn
	PollBackoffIntervalJitterCoefficient dynamicproperties.FloatPropertyFn

	EnableValidator        dynamicproperties.BoolPropertyFn
	ValidationInterval     dynamicproperties.DurationPropertyFn
	MaxStartJitterInterval dynamicproperties.DurationPropertyFn
}

type PauseController added in v1.3.3 

type PauseController interface {
	// Stop the pause controller but don't send notification to the subscribers. no-op if it's not paused.
	Stop()
	// Pause the job for the given duration. Zero and negative durations are ignored.
	// If it's already paused, the pause duration can only be updated to a longer duration.
	Pause(time.Duration)
	// Resume the job immediately. If it's not paused, this is a no-op.
	Resume()
	// Check if the job is paused.
	IsPaused() bool
	// Subscribe to the pause controller.
	Subscribe(string, chan<- struct{})
	// Unsubscribe from the pause controller.
	Unsubscribe(string)
}

PauseController is a controller that allows to pause and resume a background job. For example, if you have a background job like this: 

func run(ctx context.Context, wg *sync.WaitGroup, ...) {
  defer wg.Done()
  for {
    select {
    case <-ctx.Done():
      return
    case <-notifyCh:
      doSomething(...)
    }
  }
}

you can integrate the pause controller into the run function like this: 

func run(ctx context.Context, wg *sync.WaitGroup, pauseController PauseController, ...) {
  defer wg.Done()
  pauseController.Subscribe("run", notifyCh)
  for {
    select {
    case <-ctx.Done():
      return
    case <-notifyCh:
      doSomething(pauseController, ...)
    }
  }
}

func doSomething(pauseController PauseController, ...) {
  if someCondition {
    pauseController.Pause(10 * time.Second)
  }
  if pauseController.IsPaused() {
    return
  }
  // do the actual work
}

func NewPauseController added in v1.3.3 

func NewPauseController(timeSource clock.TimeSource) PauseController

type PendingTaskTracker added in v1.3.2 

type PendingTaskTracker interface {
	// AddTask adds a task to the pending task tracker.
	AddTask(task.Task)
	// PruneAckedTasks prunes the acked tasks from the pending task tracker.
	PruneAckedTasks()
	// GetMinimumTaskKey returns the minimum task key in the pending task tracker, if there are no pending tasks, it returns MaximumHistoryTaskKey.
	GetMinimumTaskKey() (persistence.HistoryTaskKey, bool)
	// GetTasks returns all the tasks in the pending task tracker, the result should be read-only.
	GetTasks() map[persistence.HistoryTaskKey]task.Task
	// GetPendingTaskCount returns the number of pending tasks in the pending task tracker.
	GetPendingTaskCount() int
	// Clear clears the pending task tracker.
	Clear()
}

PendingTaskTracker tracks the pending tasks in a virtual slice.

func NewPendingTaskTracker added in v1.3.2 

func NewPendingTaskTracker() PendingTaskTracker

type Predicate 

type Predicate interface {
	// IsEmpty returns true if no task satisfies the predicate
	IsEmpty() bool
	// Check returns true if the task satisfies the predicate
	Check(task persistence.Task) bool
	// Equals returns true if the predicate is the same as the other predicate
	Equals(other Predicate) bool
}

Predicate defines a predicate that can be used to filter tasks

func And added in v1.3.4 

func And(p1, p2 Predicate) Predicate

func FromPersistencePredicate added in v1.3.4 

func FromPersistencePredicate(predicate *types.Predicate) Predicate

func NewDomainIDPredicate added in v1.3.4 

func NewDomainIDPredicate(domainIDs []string, isExclusive bool) Predicate

func NewEmptyPredicate added in v1.3.4 

func NewEmptyPredicate() Predicate

func NewUniversalPredicate 

func NewUniversalPredicate() Predicate

func Not added in v1.3.4 

func Not(predicate Predicate) Predicate

type Queue added in v1.3.2 

type Queue interface {
	common.Daemon
	Category() persistence.HistoryTaskCategory
	NotifyNewTask(string, *hcommon.NotifyTaskInfo)

	FailoverDomain(map[string]struct{})
	HandleAction(context.Context, string, *queue.Action) (*queue.ActionResult, error)
	LockTaskProcessing()
	UnlockTaskProcessing()
}

func NewImmediateQueue added in v1.3.2 

func NewImmediateQueue(
	shard shard.Context,
	category persistence.HistoryTaskCategory,
	taskProcessor task.Processor,
	taskExecutor task.Executor,
	logger log.Logger,
	metricsClient metrics.Client,
	metricsScope metrics.Scope,
	options *Options,
) Queue

func NewScheduledQueue added in v1.3.2 

func NewScheduledQueue(
	shard shard.Context,
	category persistence.HistoryTaskCategory,
	taskProcessor task.Processor,
	taskExecutor task.Executor,
	logger log.Logger,
	metricsClient metrics.Client,
	metricsScope metrics.Scope,
	options *Options,
) Queue

type QueueReader added in v1.3.2 

type QueueReader interface {
	GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)
}

func NewQueueReader added in v1.3.2 

func NewQueueReader(
	shard shard.Context,
	category persistence.HistoryTaskCategory,
) QueueReader

type QueueState 

type QueueState struct {
	VirtualQueueStates    map[int64][]VirtualSliceState
	ExclusiveMaxReadLevel persistence.HistoryTaskKey
}

func FromPersistenceQueueState 

func FromPersistenceQueueState(state *types.QueueState) *QueueState

type Range 

type Range struct {
	InclusiveMinTaskKey persistence.HistoryTaskKey
	ExclusiveMaxTaskKey persistence.HistoryTaskKey
}

func FromPersistenceTaskRange 

func FromPersistenceTaskRange(state *types.TaskRange) Range

func (*Range) CanMerge 

func (r *Range) CanMerge(other Range) bool

func (*Range) CanSplitByTaskKey 

func (r *Range) CanSplitByTaskKey(taskKey persistence.HistoryTaskKey) bool

func (*Range) Contains 

func (r *Range) Contains(taskKey persistence.HistoryTaskKey) bool

func (*Range) ContainsRange 

func (r *Range) ContainsRange(other Range) bool

func (*Range) IsEmpty 

func (r *Range) IsEmpty() bool

type VirtualQueue added in v1.3.2 

type VirtualQueue interface {
	common.Daemon
	GetState() []VirtualSliceState
	UpdateAndGetState() []VirtualSliceState
	MergeSlices(...VirtualSlice)
}

func NewVirtualQueue added in v1.3.2 

func NewVirtualQueue(
	processor task.Processor,
	redispatcher task.Redispatcher,
	logger log.Logger,
	metricsScope metrics.Scope,
	timeSource clock.TimeSource,
	taskLoadRateLimiter quotas.Limiter,
	monitor Monitor,
	virtualSlices []VirtualSlice,
	options *VirtualQueueOptions,
) VirtualQueue

type VirtualQueueManager added in v1.3.2 

type VirtualQueueManager interface {
	common.Daemon
	GetState() map[int64][]VirtualSliceState
	UpdateAndGetState() map[int64][]VirtualSliceState
	// Add a new virtual slice to the root queue. This is used when new tasks are generated and max read level is updated.
	// By default, all new tasks belong to the root queue, so we need to add a new virtual slice to the root queue.
	AddNewVirtualSliceToRootQueue(VirtualSlice)
}

func NewVirtualQueueManager added in v1.3.2 

func NewVirtualQueueManager(
	processor task.Processor,
	redispatcher task.Redispatcher,
	taskInitializer task.Initializer,
	queueReader QueueReader,
	logger log.Logger,
	metricsScope metrics.Scope,
	timeSource clock.TimeSource,
	taskLoadRateLimiter quotas.Limiter,
	monitor Monitor,
	options *VirtualQueueOptions,
	virtualQueueStates map[int64][]VirtualSliceState,
) VirtualQueueManager

type VirtualQueueOptions added in v1.3.2 

type VirtualQueueOptions struct {
	PageSize                             dynamicproperties.IntPropertyFn
	MaxPendingTasksCount                 dynamicproperties.IntPropertyFn
	PollBackoffInterval                  dynamicproperties.DurationPropertyFn
	PollBackoffIntervalJitterCoefficient dynamicproperties.FloatPropertyFn
}

type VirtualSlice added in v1.3.2 

type VirtualSlice interface {
	GetState() VirtualSliceState
	GetTasks(context.Context, int) ([]task.Task, error)
	HasMoreTasks() bool
	UpdateAndGetState() VirtualSliceState
	GetPendingTaskCount() int
	Clear()

	TrySplitByTaskKey(persistence.HistoryTaskKey) (VirtualSlice, VirtualSlice, bool)
	TryMergeWithVirtualSlice(VirtualSlice) ([]VirtualSlice, bool)
}

func NewVirtualSlice added in v1.3.2 

func NewVirtualSlice(
	state VirtualSliceState,
	taskInitializer task.Initializer,
	queueReader QueueReader,
	pendingTaskTracker PendingTaskTracker,
) VirtualSlice

type VirtualSliceState 

type VirtualSliceState struct {
	Range     Range
	Predicate Predicate
}

func FromPersistenceVirtualQueueState 

func FromPersistenceVirtualQueueState(state *types.VirtualQueueState) []VirtualSliceState

func FromPersistenceVirtualSliceState 

func FromPersistenceVirtualSliceState(state *types.VirtualSliceState) VirtualSliceState

func (*VirtualSliceState) Contains 

func (s *VirtualSliceState) Contains(task persistence.Task) bool

func (*VirtualSliceState) IsEmpty 

func (s *VirtualSliceState) IsEmpty() bool

func (*VirtualSliceState) TrySplitByPredicate added in v1.3.4 

func (s *VirtualSliceState) TrySplitByPredicate(predicate Predicate) (VirtualSliceState, VirtualSliceState, bool)

func (*VirtualSliceState) TrySplitByTaskKey 

func (s *VirtualSliceState) TrySplitByTaskKey(taskKey persistence.HistoryTaskKey) (VirtualSliceState, VirtualSliceState, bool)

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.