Documentation
¶
Index ¶
- type StatusRepository
- func (s StatusRepository) GetLastUpdateTime(ctx context.Context, projectName tenant.ProjectName, entityType string, ...) (map[string]time.Time, error)
- func (s StatusRepository) Touch(ctx context.Context, projectName tenant.ProjectName, entityType string, ...) error
- func (s StatusRepository) UpdateBatch(ctx context.Context, projectName tenant.ProjectName, entityType string, ...) error
- func (s StatusRepository) UpdateBulk(ctx context.Context, projectName tenant.ProjectName, entityType string, ...) error
- func (s StatusRepository) Upsert(ctx context.Context, projectName tenant.ProjectName, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StatusRepository ¶
type StatusRepository struct {
// contains filtered or unexported fields
}
func NewStatusSyncRepository ¶
func NewStatusSyncRepository(pool *pgxpool.Pool) *StatusRepository
func (StatusRepository) GetLastUpdateTime ¶
func (StatusRepository) Touch ¶
func (s StatusRepository) Touch(ctx context.Context, projectName tenant.ProjectName, entityType string, resources []*resource.Resource) error
func (StatusRepository) UpdateBatch ¶
func (s StatusRepository) UpdateBatch(ctx context.Context, projectName tenant.ProjectName, entityType string, identifiers []string) error
func (StatusRepository) UpdateBulk ¶
func (s StatusRepository) UpdateBulk(ctx context.Context, projectName tenant.ProjectName, entityType string, syncStatus []resource.SyncStatus) error
Click to show internal directories.
Click to hide internal directories.