Documentation
¶
Index ¶
- type BadgerStorage
- func (b *BadgerStorage) LoadState(name string) (migrations.State, error)
- func (b *BadgerStorage) LoadStatus(name string) (migrations.Status, error)
- func (b *BadgerStorage) SaveState(name string, state migrations.State) error
- func (b *BadgerStorage) SaveStatus(name string, status migrations.Status) error
- type CommandDeleteGoSsbRepositoryInOldFormatAdapter
- type CommandImportDataFromGoSSBHandlerAdapter
- type GoSSBRepoReader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BadgerStorage ¶
type BadgerStorage struct {
// contains filtered or unexported fields
}
func NewBadgerStorage ¶
func NewBadgerStorage(db *badger.DB) *BadgerStorage
func (*BadgerStorage) LoadState ¶
func (b *BadgerStorage) LoadState(name string) (migrations.State, error)
func (*BadgerStorage) LoadStatus ¶
func (b *BadgerStorage) LoadStatus(name string) (migrations.Status, error)
func (*BadgerStorage) SaveState ¶
func (b *BadgerStorage) SaveState(name string, state migrations.State) error
func (*BadgerStorage) SaveStatus ¶
func (b *BadgerStorage) SaveStatus(name string, status migrations.Status) error
type CommandDeleteGoSsbRepositoryInOldFormatAdapter ¶
type CommandDeleteGoSsbRepositoryInOldFormatAdapter struct {
// contains filtered or unexported fields
}
func NewCommandDeleteGoSsbRepositoryInOldFormatAdapter ¶
func NewCommandDeleteGoSsbRepositoryInOldFormatAdapter( directory string, m commands.Migrations, ) *CommandDeleteGoSsbRepositoryInOldFormatAdapter
func (*CommandDeleteGoSsbRepositoryInOldFormatAdapter) Fn ¶
func (a *CommandDeleteGoSsbRepositoryInOldFormatAdapter) Fn(ctx context.Context, _ migrations.State, _ migrations.SaveStateFunc) error
type CommandImportDataFromGoSSBHandlerAdapter ¶
type CommandImportDataFromGoSSBHandlerAdapter struct {
// contains filtered or unexported fields
}
func NewCommandImportDataFromGoSSBHandlerAdapter ¶
func NewCommandImportDataFromGoSSBHandlerAdapter( directory string, m commands.Migrations, ) *CommandImportDataFromGoSSBHandlerAdapter
func (*CommandImportDataFromGoSSBHandlerAdapter) Fn ¶
func (a *CommandImportDataFromGoSSBHandlerAdapter) Fn(ctx context.Context, state migrations.State, saveStateFunc migrations.SaveStateFunc) error
type GoSSBRepoReader ¶
type GoSSBRepoReader struct {
// contains filtered or unexported fields
}
func NewGoSSBRepoReader ¶
func NewGoSSBRepoReader( logger logging.Logger, ) *GoSSBRepoReader
func (GoSSBRepoReader) GetMessages ¶
func (m GoSSBRepoReader) GetMessages(ctx context.Context, directory string, resumeFromSequence *common.ReceiveLogSequence) (<-chan commands.GoSSBMessageOrError, error)
Source Files
Click to show internal directories.
Click to hide internal directories.