statushooks

Documentation

Index

• Variables
• func AddMessageRendererToContext(ctx context.Context, messageRenderer MessageRenderer) context.Context
• func AddSnapshotProgressToContext(ctx context.Context, snapshotProgress SnapshotProgress) context.Context
• func AddStatusHooksToContext(ctx context.Context, statusHooks StatusHooks) context.Context
• func DisableStatusHooks(ctx context.Context) context.Context
• func Done(ctx context.Context)
• func Message(ctx context.Context, msgs ...string)
• func SetStatus(ctx context.Context, msg string)
• func SnapshotError(ctx context.Context)
• func UpdateSnapshotProgress(ctx context.Context, completedRows int)
• type MessageRenderer
  • func MessageRendererFromContext(ctx context.Context) MessageRenderer
• type NullSnapshotProgress
  • func (*NullSnapshotProgress) UpdateErrorCount(context.Context, int)
  • func (*NullSnapshotProgress) UpdateRowCount(context.Context, int)
• type NullStatusHook
  • func (*NullStatusHook) Done()
  • func (*NullStatusHook) Message(...string)
  • func (*NullStatusHook) SetStatus(string)
• type SnapshotProgress
  • func SnapshotProgressFromContext(ctx context.Context) SnapshotProgress
• type SnapshotProgressReporter
  • func NewSnapshotProgressReporter(target string) *SnapshotProgressReporter
  • func (r *SnapshotProgressReporter) UpdateErrorCount(ctx context.Context, errors int)
  • func (r *SnapshotProgressReporter) UpdateRowCount(ctx context.Context, rows int)
• type StatusHooks
  • func StatusHooksFromContext(ctx context.Context) StatusHooks

Variables

var NullHooks = &NullStatusHook{}

var NullProgress = &NullSnapshotProgress{}

NullProgress is an empty implementation of SnapshotProgress

Functions

func AddMessageRendererToContext

func AddMessageRendererToContext(ctx context.Context, messageRenderer MessageRenderer) context.Context

func AddSnapshotProgressToContext

func AddSnapshotProgressToContext(ctx context.Context, snapshotProgress SnapshotProgress) context.Context

func AddStatusHooksToContext

func AddStatusHooksToContext(ctx context.Context, statusHooks StatusHooks) context.Context

func DisableStatusHooks

func DisableStatusHooks(ctx context.Context) context.Context

func Done

func Done(ctx context.Context)

func Message

func Message(ctx context.Context, msgs ...string)

func SetStatus

func SetStatus(ctx context.Context, msg string)

func SnapshotError

func SnapshotError(ctx context.Context)

func UpdateSnapshotProgress

func UpdateSnapshotProgress(ctx context.Context, completedRows int)

Types

type MessageRenderer

type MessageRenderer func(format string, a ...any)

func MessageRendererFromContext

func MessageRendererFromContext(ctx context.Context) MessageRenderer

type NullSnapshotProgress

type NullSnapshotProgress struct{}

func (*NullSnapshotProgress) UpdateErrorCount

func (*NullSnapshotProgress) UpdateErrorCount(context.Context, int)

func (*NullSnapshotProgress) UpdateRowCount

func (*NullSnapshotProgress) UpdateRowCount(context.Context, int)

type NullStatusHook

type NullStatusHook struct{}

func (*NullStatusHook) Done

func (*NullStatusHook) Done()

func (*NullStatusHook) Message

func (*NullStatusHook) Message(...string)

func (*NullStatusHook) SetStatus

func (*NullStatusHook) SetStatus(string)

type SnapshotProgress

type SnapshotProgress interface {
	UpdateRowCount(context.Context, int)
	UpdateErrorCount(context.Context, int)
}

func SnapshotProgressFromContext

func SnapshotProgressFromContext(ctx context.Context) SnapshotProgress

type SnapshotProgressReporter

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

SnapshotProgressReporter is an implementation of SnapshotProgress

func NewSnapshotProgressReporter

func NewSnapshotProgressReporter(target string) *SnapshotProgressReporter

func (*SnapshotProgressReporter) UpdateErrorCount

func (r *SnapshotProgressReporter) UpdateErrorCount(ctx context.Context, errors int)

func (*SnapshotProgressReporter) UpdateRowCount

func (r *SnapshotProgressReporter) UpdateRowCount(ctx context.Context, rows int)

type StatusHooks

type StatusHooks interface {
	SetStatus(string)
	Done()
	Message(...string)
}

func StatusHooksFromContext

func StatusHooksFromContext(ctx context.Context) StatusHooks