background

package

v3.40.0-rc0 Latest Latest Go to latest Published: Nov 18, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrAlreadyClosed = xerrors.Wrap(errors.New("ydb: background worker already closed"))
)

This section is empty.

type CallbackFunc func(ctx context.Context)

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

A Worker must not be copied after first use

func NewWorker(parent context.Context) *Worker

func (b *Worker) Close(ctx context.Context, err error) error

func (b *Worker) CloseReason() error

func (b *Worker) Context() context.Context

func (b *Worker) Done() <-chan struct{}

func (b *Worker) Start(name string, f CallbackFunc)