package xcontext

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/xcontext"

Index ¶

• func ExtractLocalDC(ctx context.Context) string
• func IsIdempotent(ctx context.Context) bool
• func IsNestedCall(ctx context.Context) bool
• func MarkRetryCall(ctx context.Context) context.Context
• func ValueOnly(ctx context.Context) context.Context
• func WithCancel(ctx context.Context) (context.Context, context.CancelFunc)
• func WithDone(parent context.Context, done <-chan struct{}) (context.Context, context.CancelFunc)
• func WithIdempotent(ctx context.Context, idempotent bool) context.Context
• func WithLocalDC(ctx context.Context, dc string) context.Context
• func WithTimeout(ctx context.Context, t time.Duration) (context.Context, context.CancelFunc)
• type CancelsGuard
• func NewCancelsGuard() *CancelsGuard
• func (g *CancelsGuard) Cancel()
• func (g *CancelsGuard) WithCancel(ctx context.Context) (context.Context, context.CancelFunc)

Functions ¶

func ExtractLocalDC ¶

func ExtractLocalDC(ctx context.Context) string

func IsIdempotent ¶

func IsIdempotent(ctx context.Context) bool

func IsNestedCall ¶

func IsNestedCall(ctx context.Context) bool

func MarkRetryCall ¶

func MarkRetryCall(ctx context.Context) context.Context

func ValueOnly ¶

func ValueOnly(ctx context.Context) context.Context

ValueOnly helps to clear parent context from deadlines/cancels

func WithCancel ¶

func WithCancel(ctx context.Context) (context.Context, context.CancelFunc)

func WithDone ¶

func WithDone(parent context.Context, done <-chan struct{}) (context.Context, context.CancelFunc)

func WithIdempotent ¶

func WithIdempotent(ctx context.Context, idempotent bool) context.Context

func WithLocalDC ¶

func WithLocalDC(ctx context.Context, dc string) context.Context

func WithTimeout ¶

func WithTimeout(ctx context.Context, t time.Duration) (context.Context, context.CancelFunc)

Types ¶

type CancelsGuard ¶

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

func NewCancelsGuard ¶

func NewCancelsGuard() *CancelsGuard

func (*CancelsGuard) Cancel ¶

func (g *CancelsGuard) Cancel()

func (*CancelsGuard) WithCancel ¶

func (g *CancelsGuard) WithCancel(ctx context.Context) (context.Context, context.CancelFunc)

Source Files ¶

cancels_quard.go context_error.go context_with_cancel.go context_with_timeout.go done.go idempotent.go local_dc.go retry_call.go value_only.go