gfs

Documentation

Overview

Package gfs helps with Google FireStore

Index

• func DeleteCollection(ctx context.Context, client *firestore.Client, ref *firestore.CollectionRef, ...) error
• func GetDocWithRetry(ctx context.Context, firestoreClient *firestore.Client, documentPath string, ...) (*firestore.DocumentSnapshot, bool)
• func RecordExportWithRetry(ctx context.Context, firestoreClient *firestore.Client, ...) (err error)
• type ExportRecord

Functions

func DeleteCollection

func DeleteCollection(ctx context.Context, client *firestore.Client,
	ref *firestore.CollectionRef, batchSize int) error

DeleteCollection is used to delete test document collection in firestore

func GetDocWithRetry

func GetDocWithRetry(ctx context.Context,
	firestoreClient *firestore.Client,
	documentPath string,
	maxRetry int,
	retryOnNotFound bool,
	ev glo.EntryValues) (*firestore.DocumentSnapshot, bool)

GetDocWithRetry check if a document exist with retries

func RecordExportWithRetry

func RecordExportWithRetry(ctx context.Context,
	firestoreClient *firestore.Client,
	exportCollectionName string,
	exportName string,
	processed bool,
	maxRetry int,
	ev glo.EntryValues) (err error)

RecordExportWithRetry record and export doc to firestore

Types

type ExportRecord

type ExportRecord struct {
	Processed bool      `firestore:"processed"`
	StepStack glo.Steps `firestore:"stepStack"`
	Timestamp time.Time `firestore:"timestamp"`
}

ExportRecord define export documents in firestore