semaphore

package

v4.9.0 Latest Latest Go to latest Published: Dec 12, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Package semaphore is a generated GoMock package.

This section is empty.

This section is empty.

This section is empty.

type ISemaphore interface {
	AcquireMemoryWeight(ctx context.Context, weight int64) error
	ReleaseMemoryWeight(weight int64)
}

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

MockISemaphore is a mock of ISemaphore interface.

func NewMockISemaphore(ctrl *gomock.Controller) *MockISemaphore

NewMockISemaphore creates a new mock instance.

func (m *MockISemaphore) AcquireMemoryWeight(ctx context.Context, weight int64) error

AcquireMemoryWeight mocks base method.

func (m *MockISemaphore) EXPECT() *MockISemaphoreMockRecorder

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

func (m *MockISemaphore) ReleaseMemoryWeight(weight int64)

ReleaseMemoryWeight mocks base method.

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

MockISemaphoreMockRecorder is the mock recorder for MockISemaphore.

func (mr *MockISemaphoreMockRecorder) AcquireMemoryWeight(ctx, weight any) *gomock.Call

AcquireMemoryWeight indicates an expected call of AcquireMemoryWeight.

func (mr *MockISemaphoreMockRecorder) ReleaseMemoryWeight(weight any) *gomock.Call

ReleaseMemoryWeight indicates an expected call of ReleaseMemoryWeight.

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

func NewSemaphore() *Semaphore

func NewSemaphoreWithBudget(b int64) *Semaphore

func (s *Semaphore) AcquireMemoryWeight(ctx context.Context, weight int64) error

AcquireMemoryWeight acquires semaphore with a specified weight

func (s *Semaphore) ReleaseMemoryWeight(weight int64)

ReleaseMemoryWeight releases semaphore with a specified weight