package operation

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

Index ¶

• func Params( ctx context.Context, timeout time.Duration, cancelAfter time.Duration, mode Mode, ) *Ydb_Operations.OperationParams
• func WithCancelAfter(ctx context.Context, operationCancelAfter time.Duration) context.Context
• func WithTimeout(ctx context.Context, operationTimeout time.Duration) context.Context
• type Mode
• func (m Mode) String() string
• type Response
• type Status

Functions ¶

func Params ¶

func Params(
	ctx context.Context,
	timeout time.Duration,
	cancelAfter time.Duration,
	mode Mode,
) *Ydb_Operations.OperationParams

func WithCancelAfter ¶

func WithCancelAfter(ctx context.Context, operationCancelAfter time.Duration) context.Context

WithCancelAfter returns a copy of parent context in which YDB operation cancel after parameter is set to d. If parent context cancellation timeout is smaller than d, parent context is returned.

func WithTimeout ¶

func WithTimeout(ctx context.Context, operationTimeout time.Duration) context.Context

WithTimeout returns a copy of parent context in which YDB operation timeout parameter is set to d. If parent context timeout is smaller than d, parent context is returned.

Types ¶

type Mode ¶

type Mode uint

const (
	ModeUnknown Mode = iota
	ModeSync
	ModeAsync
)

func (Mode) String ¶

func (m Mode) String() string

type Response ¶

type Response interface {
	GetOperation() *Ydb_Operations.Operation
}

type Status ¶

type Status interface {
	GetStatus() Ydb.StatusIds_StatusCode
	GetIssues() []*Ydb_Issue.IssueMessage
}

Source Files ¶

context.go mode.go params.go response.go status.go timeout.go

Directories ¶