storage

Jan 22, 2022

Changes in this version

+ var ErrAlreadyExists = errors.New("already exists")

+ var ErrInvalidModelEmptyID = errors.New("invalid model: empty ID")

+ var ErrNotFound = errors.New("not found")

+ var ErrStorageModelMustBeEmpty = errors.New("storage: model must be empty")

+ func DocRef(db *firestore.Client, model Model) *firestore.DocumentRef

+ func LoadDocAndPopulate(ctx context.Context, docRef *firestore.DocumentRef, model Model) error

+ func PopulateModelFrom(model Model, doc *firestore.DocumentSnapshot) error

+ type CustomModelID interface

+ ModelID func() string

+ SetModelID func(in string)

+ type DocumentRef = firestore.DocumentRef

+ type Model interface

+ CollectionName func() string

+ Exists func() bool

+ ModelCreatedAt func() time.Time

+ ModelID func() string

+ ModelUpdatedAt func() time.Time

+ NewModel func() Model

+ SetModelID func(in string)

+ func IterateAllDocsAndStop(iter *firestore.DocumentIterator, kind Model) ([]Model, error)

+ func NewWithID(kind Model, id string) Model

+ type ModelCustomID struct

+ type ModelImpl interface

+ CollectionName func() string

+ NewModel func() Model

+ type PrimaryData struct

+ ID string

+ func (m *PrimaryData) ModelID() string

+ func (m *PrimaryData) SetModelID(in string)

+ type ServiceData struct

+ Doc *firestore.DocumentSnapshot

+ func (m *ServiceData) Exists() bool

+ func (m *ServiceData) ModelCreatedAt() time.Time

+ func (m *ServiceData) ModelUpdatedAt() time.Time

+ type StdModel struct

+ type Storage struct

+ func NewStorage(db *firestore.Client) *Storage

+ func (s *Storage) DeleteModel(ctx context.Context, model Model) error

+ func (s *Storage) DocRef(model Model) *DocumentRef

+ func (s *Storage) FirestoreClient() *firestore.Client

+ func (s *Storage) GetModel(ctx context.Context, model Model) error

+ func (s *Storage) Iterate(iter *firestore.DocumentIterator, factory Model) []Model

+ func (s *Storage) LoadToModel(ctx context.Context, docRef *firestore.DocumentRef, model Model) error

+ func (s *Storage) UpsertIfNotExists(ctx context.Context, model Model) error

+ func (s *Storage) UpsertModel(ctx context.Context, model Model) error

+ type Timestamp = timestamp.Timestamp