sync

Documentation

Index

• type StatusRepository
  • func NewStatusSyncRepository(pool *pgxpool.Pool) *StatusRepository
  • func (s StatusRepository) GetLastUpdate(ctx context.Context, projectName tenant.ProjectName, ...) (map[string]*resource.SourceVersioningInfo, error)
  • func (s StatusRepository) Touch(ctx context.Context, projectName tenant.ProjectName, entityType string, ...) error
  • func (s StatusRepository) Upsert(ctx context.Context, projectName tenant.ProjectName, ...) error
  • func (s StatusRepository) UpsertRevision(ctx context.Context, projectName tenant.ProjectName, ...) error

Types

type StatusRepository

type StatusRepository struct {
	// contains filtered or unexported fields
}

func NewStatusSyncRepository

func NewStatusSyncRepository(pool *pgxpool.Pool) *StatusRepository

func (StatusRepository) GetLastUpdate

func (s StatusRepository) GetLastUpdate(ctx context.Context, projectName tenant.ProjectName, resources []*resource.Resource) (map[string]*resource.SourceVersioningInfo, error)

func (StatusRepository) Touch

func (s StatusRepository) Touch(ctx context.Context, projectName tenant.ProjectName, entityType string, identifiers []string) error

func (StatusRepository) Upsert

func (s StatusRepository) Upsert(ctx context.Context, projectName tenant.ProjectName, entityType, identifier string, remarks map[string]string, success bool) error

func (StatusRepository) UpsertRevision

func (s StatusRepository) UpsertRevision(ctx context.Context, projectName tenant.ProjectName, entityType, identifier string, remarks map[string]string, revision int, success bool) error