Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cancellable ¶
type Cancellable interface {
// IsCancelled determines whether the object is cancelled.
IsCancelled() bool
// Cancel cancels the object.
Cancel()
// Reset resets the object.
Reset()
}
Cancellable is an object that can be cancelled.
func NewCancellable ¶
func NewCancellable() Cancellable
NewCancellable creates a new cancellable object
func NewNoOpCanncellable ¶
func NewNoOpCanncellable() Cancellable
NewNoOpCanncellable returns a no-op cancellable
type Context ¶
type Context interface {
// IsClosed returns whether the context is closed.
IsClosed() bool
// RegisterFinalizer will register a resource finalizer.
RegisterFinalizer(resource.Finalizer)
// RegisterCloser will register a resource closer.
RegisterCloser(resource.Closer)
// DependsOn will register a blocking context that
// must complete first before finalizers can be called.
DependsOn(Context)
// Close will close the context.
Close()
// BlockingClose will close the context and call the
// registered finalizers in a blocking manner after waiting
// for any dependent contexts to close. After calling
// the context becomes safe to reset and reuse again.
BlockingClose()
// Reset will reset the context for reuse.
Reset()
// GoContext returns the Go std context.
GoContext() (stdctx.Context, bool)
// SetGoContext sets the Go std context.
SetGoContext(stdctx.Context)
// StartTraceSpan starts a new span and returns a child ctx.
StartTraceSpan(string) (Context, opentracing.Span)
// StartSampledTraceSpan starts a new span and returns a child ctx
// and a bool if the span is being sampled. This is used over StartTraceSpan()
// for hot paths where performance is crucial.
StartSampledTraceSpan(string) (Context, opentracing.Span, bool)
}
Context provides context to an operation.
type Options ¶
type Options interface {
// SetContextPoolOptions sets the context pool options.
SetContextPoolOptions(pool.ObjectPoolOptions) Options
// ContextPoolOptions returns the context pool options.
ContextPoolOptions() pool.ObjectPoolOptions
// SetFinalizerPoolOptions sets the finalizer pool options.
SetFinalizerPoolOptions(pool.ObjectPoolOptions) Options
// FinalizerPoolOptions returns the finalizer pool options.
FinalizerPoolOptions() pool.ObjectPoolOptions
// SetMaxPooledFinalizerCapacity sets the maximum capacity allowed
// for a finalizer to be pooled.
SetMaxPooledFinalizerCapacity(int) Options
// MaxPooledFinalizerCapacity returns the maximum capacity allowed
// for a finalizer to be pooled.
MaxPooledFinalizerCapacity() int
// SetInitPooledFinalizerCapacity sets the capacity finalizers are
// initialized to.
SetInitPooledFinalizerCapacity(int) Options
// InitPooledFinalizerCapacity return the capacity finalizers are
// initialized to.
InitPooledFinalizerCapacity() int
}
Options controls knobs for context pooling.
Click to show internal directories.
Click to hide internal directories.