storagedocuments

Documentation

Index

• func WithEndedAt(endedAt time.Time) withEndedAt
• func WithLimitCount(count int32) withLimit
• func WithStartedAt(startedAt time.Time) withStartedAt
• type DocumentCURD
  • func NewDocumentCURD(db *storagepostgres.PostgresDb) *DocumentCURD
  • func (c *DocumentCURD) AutoMigrate() error
  • func (c *DocumentCURD) BatchWrite(ctx context.Context, tableName string, ...) error
  • func (c *DocumentCURD) Get(ctx context.Context, tableName string, pid appmodelprojects.ProjectID, ...) (*appmodeldocuments.ModelDocument, error)
  • func (c *DocumentCURD) Query(ctx context.Context, tableName string, pid appmodelprojects.ProjectID, ...) ([]*appmodeldocuments.ModelDocument, error)
  • func (c *DocumentCURD) Update(ctx context.Context, tableName string, record *appmodeldocuments.ModelDocument) error
  • func (c *DocumentCURD) Write(ctx context.Context, tableName string, record *appmodeldocuments.ModelDocument) error
• type QueryConditioner

Functions

func WithEndedAt

func WithEndedAt(endedAt time.Time) withEndedAt

func WithLimitCount

func WithLimitCount(count int32) withLimit

func WithStartedAt

func WithStartedAt(startedAt time.Time) withStartedAt

Types

type DocumentCURD

type DocumentCURD struct {
	*storagepostgres.PostgresDb
}

func NewDocumentCURD

func NewDocumentCURD(db *storagepostgres.PostgresDb) *DocumentCURD

func (*DocumentCURD) AutoMigrate

func (c *DocumentCURD) AutoMigrate() error

func (*DocumentCURD) BatchWrite

func (c *DocumentCURD) BatchWrite(ctx context.Context, tableName string, records []*appmodeldocuments.ModelDocument) error

func (*DocumentCURD) Get

func (c *DocumentCURD) Get(ctx context.Context, tableName string, pid appmodelprojects.ProjectID, cid appmodelcollections.CollectionID, did appmodeldocuments.DocumentID) (*appmodeldocuments.ModelDocument, error)

func (*DocumentCURD) Query

func (c *DocumentCURD) Query(ctx context.Context,
	tableName string,
	pid appmodelprojects.ProjectID,
	cid appmodelcollections.CollectionID,
	cnds ...QueryConditioner,
) ([]*appmodeldocuments.ModelDocument, error)

func (*DocumentCURD) Update

func (c *DocumentCURD) Update(ctx context.Context, tableName string, record *appmodeldocuments.ModelDocument) error

func (*DocumentCURD) Write

func (c *DocumentCURD) Write(ctx context.Context, tableName string, record *appmodeldocuments.ModelDocument) error

type QueryConditioner

type QueryConditioner interface {
	// contains filtered or unexported methods
}