backup

package

v0.0.1 Latest Latest Go to latest Published: Jul 26, 2023 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

FileBackup saves the events on the file system

func NewFileBackup(
	backupInterval time.Duration,
	directory string,
) *FileBackup

NewFileBackup creates file system backup service

func (b *FileBackup) Flush()

Flush is called before shutdown to force process of the last batch

func (b *FileBackup) SaveAsync(event *types.Event)

SaveAsync saves an event asynchronously

type IBackup interface {
	SaveAsync(event *types.Event)
	Flush()
}

IBackup interface for backup service

func New(
	enabled bool,
	backupInterval time.Duration,
	directory string,
) IBackup

New is factory for backup service nolint: revive

type NullBackup struct {
}

NullBackup is disabled backup implementation

func NewNullBackup() *NullBackup

NewNullBackup creates disabled backup implementation

func (*NullBackup) Flush()

Flush disabled implementation

func (*NullBackup) SaveAsync(_ *types.Event)

SaveAsync disabled implementation