firestore

Documentation

Index

• type BackupProcessor
  • func NewBackupProcessor(firestoreReader FirestoreInterface, storage output.DatabaseBackupStorage) BackupProcessor
• type FirestoreDocument
• type FirestoreInterface
• type FirestoreReaderBuilder
  • func NewFirestoreReaderBuilder(client *firestore.Client) FirestoreReaderBuilder
• type MarshallingError
  • func (s MarshallingError) Error() string
• type ServerError
  • func (s ServerError) Error() string

Types

type BackupProcessor

type BackupProcessor interface {
	Backup() error
	Restore() error
}

func NewBackupProcessor

func NewBackupProcessor(firestoreReader FirestoreInterface, storage output.DatabaseBackupStorage) BackupProcessor

type FirestoreDocument

type FirestoreDocument struct {
	Path string
	Id   string
	Data map[string]interface{}
}

type FirestoreInterface

type FirestoreInterface interface {
	io.Closer
	Process(documentsChan chan *FirestoreDocument) error
	Insert(document []*FirestoreDocument) error
}

type FirestoreReaderBuilder

type FirestoreReaderBuilder interface {
	//WithCollections collections to be extracted default: all
	WithCollections([]string) FirestoreReaderBuilder
	WithStartingTime(time time.Time) FirestoreReaderBuilder
	WithEndingTime(time time.Time) FirestoreReaderBuilder
	WithTimeField(string) FirestoreReaderBuilder
	// WithDatabaseName (default)
	WithDatabaseName(string) FirestoreReaderBuilder
	Build() (FirestoreInterface, error)
}

func NewFirestoreReaderBuilder

func NewFirestoreReaderBuilder(client *firestore.Client) FirestoreReaderBuilder

type MarshallingError

type MarshallingError struct {
	Message string
}

func (MarshallingError) Error

func (s MarshallingError) Error() string

type ServerError

type ServerError struct {
	Message string
}

func (ServerError) Error

func (s ServerError) Error() string