internal

Documentation

Index

• func DetachContext(ctx context.Context) context.Context
• type BatchFn
• type BatchResult
• type Batcher
  • func NewBatcher[T any](sizeThreshold int, delayThreshold time.Duration, fn BatchFn[T]) *Batcher[T]
  • func (b *Batcher[T]) Enqueue(item T) EnqueueStatus
  • func (b *Batcher[T]) Flush() bool
  • func (b *Batcher[T]) Results() <-chan BatchResult
• type ConnectorState
  • func (i ConnectorState) String() string
• type ConnectorStateWatcher
  • func (w *ConnectorStateWatcher) DoWithLock(ctx context.Context, opts DoWithLockOptions, ...) error
  • func (w *ConnectorStateWatcher) Set(newState ConnectorState) bool
• type DoWithLockOptions
• type EnqueueStatus

Functions

func DetachContext

func DetachContext(ctx context.Context) context.Context

DetachContext returns a context that keeps all the values of its parent context but detaches from the cancellation and error handling.

Types

type BatchFn

type BatchFn[T any] func([]T) error

type BatchResult

type BatchResult struct {
	At   time.Time
	Size int
	Err  error
}

type Batcher

type Batcher[T any] struct {
	// contains filtered or unexported fields
}

func NewBatcher

func NewBatcher[T any](sizeThreshold int, delayThreshold time.Duration, fn BatchFn[T]) *Batcher[T]

func (*Batcher[T]) Enqueue

func (b *Batcher[T]) Enqueue(item T) EnqueueStatus

func (*Batcher[T]) Flush

func (b *Batcher[T]) Flush() bool

func (*Batcher[T]) Results

func (b *Batcher[T]) Results() <-chan BatchResult

type ConnectorState

type ConnectorState int

const (
	StateInitial ConnectorState = iota
	StateConfiguring
	StateConfigured
	StateStarting
	StateStarted
	StateInitiatingRun
	StateRunning
	StateInitiatingStop
	StateStopping
	StateStopped
	StateTearingDown
	StateTornDown

	StateErrored ConnectorState = 500
)

func (ConnectorState) String

func (i ConnectorState) String() string

type ConnectorStateWatcher

type ConnectorStateWatcher csync.ValueWatcher[ConnectorState]

func (*ConnectorStateWatcher) DoWithLock

func (w *ConnectorStateWatcher) DoWithLock(
	ctx context.Context,
	opts DoWithLockOptions,
	f func(currentState ConnectorState) error,
) error

func (*ConnectorStateWatcher) Set

func (w *ConnectorStateWatcher) Set(newState ConnectorState) bool

type DoWithLockOptions

type DoWithLockOptions struct {
	ExpectedStates       []ConnectorState
	StateBefore          ConnectorState
	StateAfter           ConnectorState
	WaitForExpectedState bool
}

type EnqueueStatus

type EnqueueStatus int

const (
	Scheduled EnqueueStatus = iota + 1
	Flushed
)