flusher

Documentation

Index

• type Flush
  • func New(ctx context.Context, policy policy.BackupPolicy, s store.Storer) *Flush
  • func (f *Flush) Queue(rev store.Revision)
  • func (f *Flush) Stop()
• type Flusher

Types

type Flush

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

func New

func New(ctx context.Context, policy policy.BackupPolicy, s store.Storer) *Flush

func (*Flush) Queue

func (f *Flush) Queue(rev store.Revision)

func (*Flush) Stop

func (f *Flush) Stop()

type Flusher

type Flusher interface {
	Queue(item store.Revision)
	Stop()
}