internal

Documentation

Index

• Variables
• func ConnectorIDFromContext(ctx context.Context) string
• func ContextWithConnectorID(ctx context.Context, connectorID string) context.Context
• func ContextWithLogLevel(ctx context.Context, logLevel string) context.Context
• func Enrich(ctx context.Context, cfg pconnector.PluginConfig) context.Context
• func InitStandaloneConnectorUtilities(target string) error
• func LogLevelFromContext(ctx context.Context) string
• 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, size int) 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
• type StandaloneConnectorUtility

Variables

var StandaloneConnectorUtilities []StandaloneConnectorUtility

Functions

func ConnectorIDFromContext

func ConnectorIDFromContext(ctx context.Context) string

ConnectorIDFromContext fetches the connector ID from the context. If the context does not contain a connector ID it returns an empty string.

func ContextWithConnectorID

func ContextWithConnectorID(ctx context.Context, connectorID string) context.Context

ContextWithConnectorID wraps ctx and returns a context that contains the connector ID.

func ContextWithLogLevel

func ContextWithLogLevel(ctx context.Context, logLevel string) context.Context

ContextWithLogLevel wraps ctx and returns a context that contains the connector LogLevel.

func Enrich

func Enrich(ctx context.Context, cfg pconnector.PluginConfig) context.Context

func InitStandaloneConnectorUtilities

func InitStandaloneConnectorUtilities(target string) error

func LogLevelFromContext

func LogLevelFromContext(ctx context.Context) string

LogLevelFromContext fetches the connector LogLevel from the context. If the context does not contain a connector LogLevel it returns an empty string.

Types

type BatchFn

type BatchFn[T any] func([]T, int) 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, size int) 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
)

type StandaloneConnectorUtility

type StandaloneConnectorUtility interface {
	Init(conn *grpc.ClientConn) error
}