internal

Documentation

Overview

Package internal is a generated GoMock package.

Index

• type Factory
  • func NewAggregatorFactory[V any](aggregateFunc func(a, b V) V) Factory[V]
  • func NewBufferFactory[V any]() Factory[V]
  • func NewFlipFlopFactory[V any, C comparable](base Factory[V], criteria func(V) C) Factory[V]
  • func NewLimitedFactory[V any](base Factory[V], limit int) Factory[V]
  • func NewMultiplexorFactory[V any, C comparable](base Factory[V], separator func(V) C, capacity int) Factory[V]
  • func NewTimerFactory[V any](base Factory[V], duration time.Duration) Factory[V]
• type MockFactory
  • func NewMockFactory[V any](ctrl *gomock.Controller) *MockFactory[V]
  • func (m *MockFactory[V]) Create(ctx context.Context, inputCh chan V, flushCh chan func(), ...) <-chan []V
  • func (m *MockFactory[V]) EXPECT() *MockFactoryMockRecorder[V]
• type MockFactoryCreateCall
  • func (c *MockFactoryCreateCall[V]) Do(...) *MockFactoryCreateCall[V]
  • func (c *MockFactoryCreateCall[V]) DoAndReturn(...) *MockFactoryCreateCall[V]
  • func (c *MockFactoryCreateCall[V]) Return(arg0 <-chan []V) *MockFactoryCreateCall[V]
• type MockFactoryMockRecorder
  • func (mr *MockFactoryMockRecorder[V]) Create(ctx, inputCh, flushCh, beforeSend, afterSend, beforeFlush, afterFlush, ... any) *MockFactoryCreateCall[V]

Types

type Factory

type Factory[V any] interface {
	Create(
		ctx context.Context,
		inputCh chan V,
		flushCh chan func(),
		beforeSend func(V, func()),
		afterSend func(V, func()),
		beforeFlush func(),
		afterFlush func(int),
		capacity int,
		cancel context.CancelFunc,
	) <-chan []V
}

func NewAggregatorFactory

func NewAggregatorFactory[V any](
	aggregateFunc func(a, b V) V,
) Factory[V]

func NewBufferFactory

func NewBufferFactory[V any]() Factory[V]

func NewFlipFlopFactory

func NewFlipFlopFactory[V any, C comparable](base Factory[V], criteria func(V) C) Factory[V]

func NewLimitedFactory

func NewLimitedFactory[V any](base Factory[V], limit int) Factory[V]

func NewMultiplexorFactory

func NewMultiplexorFactory[V any, C comparable](
	base Factory[V],
	separator func(V) C,
	capacity int,
) Factory[V]

func NewTimerFactory

func NewTimerFactory[V any](base Factory[V], duration time.Duration) Factory[V]

type MockFactory

type MockFactory[V any] struct {
	// contains filtered or unexported fields
}

MockFactory is a mock of Factory interface.

func NewMockFactory

func NewMockFactory[V any](ctrl *gomock.Controller) *MockFactory[V]

NewMockFactory creates a new mock instance.

func (*MockFactory[V]) Create

func (m *MockFactory[V]) Create(ctx context.Context, inputCh chan V, flushCh chan func(), beforeSend, afterSend func(V, func()), beforeFlush func(), afterFlush func(int), capacity int, cancel context.CancelFunc) <-chan []V

Create mocks base method.

func (*MockFactory[V]) EXPECT

func (m *MockFactory[V]) EXPECT() *MockFactoryMockRecorder[V]

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

type MockFactoryCreateCall

type MockFactoryCreateCall[V any] struct {
	*gomock.Call
}

MockFactoryCreateCall wrap *gomock.Call

func (*MockFactoryCreateCall[V]) Do

func (c *MockFactoryCreateCall[V]) Do(f func(context.Context, chan V, chan func(), func(V, func()), func(V, func()), func(), func(int), int, context.CancelFunc) <-chan []V) *MockFactoryCreateCall[V]

Do rewrite *gomock.Call.Do

func (*MockFactoryCreateCall[V]) DoAndReturn

func (c *MockFactoryCreateCall[V]) DoAndReturn(f func(context.Context, chan V, chan func(), func(V, func()), func(V, func()), func(), func(int), int, context.CancelFunc) <-chan []V) *MockFactoryCreateCall[V]

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockFactoryCreateCall[V]) Return

func (c *MockFactoryCreateCall[V]) Return(arg0 <-chan []V) *MockFactoryCreateCall[V]

Return rewrite *gomock.Call.Return

type MockFactoryMockRecorder

type MockFactoryMockRecorder[V any] struct {
	// contains filtered or unexported fields
}

MockFactoryMockRecorder is the mock recorder for MockFactory.

func (*MockFactoryMockRecorder[V]) Create

func (mr *MockFactoryMockRecorder[V]) Create(ctx, inputCh, flushCh, beforeSend, afterSend, beforeFlush, afterFlush, capacity, cancel any) *MockFactoryCreateCall[V]

Create indicates an expected call of Create.