operation

Documentation

Index

• func Params(ctx context.Context, timeout time.Duration, cancelAfter time.Duration, ...) *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
}