datastore

Documentation

Index

• type AlreadyAssigned
  • func (err AlreadyAssigned) Error() string
• type AlreadyHasSettings
  • func (err AlreadyHasSettings) Error() string
• type AlreadyResponded
  • func (err AlreadyResponded) Error() string
• type AssignmentNotFound
  • func (err AssignmentNotFound) Error() string
• type DbQueryExecutor
• type NoAssignmentsAvailable
  • func (err NoAssignmentsAvailable) Error() string
• type NoRowErr
  • func (err NoRowErr) Error() string
• type Storage
• type VerificationStore
  • func NewDatastore(db *sqlx.DB) *VerificationStore
  • func (vs *VerificationStore) Assign(a *verification.NewAssignment) (*verification.Assignment, error)
  • func (vs *VerificationStore) CreateAssignment(a *verification.EmptyAssignment) (*verification.Assignment, error)
  • func (vs *VerificationStore) CreateResponse(r verification.VerificationResponse) (*verification.VerificationResponse, error)
  • func (vs *VerificationStore) CreateResponses(rs verification.VerificationResponses) (verification.VerificationResponses, error)
  • func (vs *VerificationStore) CreateSettings(s verification.Settings) (*verification.Settings, error)
  • func (vs *VerificationStore) DeleteAssignment(id string) (bool, error)
  • func (vs *VerificationStore) GetAssignment(id string) (*verification.Assignment, error)
  • func (vs *VerificationStore) GetAssignmentByResponseAndVerifier(responseID uint64, verifierID int64) (*verification.Assignment, error)
  • func (vs *VerificationStore) GetAssignments(p verification.Params) (verification.Assignments, error)
  • func (vs *VerificationStore) GetEligibleJobIDs(verifierID uint64, JobIDs []uint64) ([]uint64, error)
  • func (vs *VerificationStore) GetJobsWithEmptyAssignments(verifierID uint64) (verification.JobEmptyAssignments, error)
  • func (vs *VerificationStore) GetResponse(id string) (*verification.VerificationResponse, error)
  • func (vs *VerificationStore) GetResponses(p verification.Params) (verification.VerificationResponses, error)
  • func (vs *VerificationStore) GetSettings(jobID uint64) (*verification.Settings, error)
  • func (vs *VerificationStore) GetWhitelist(jobID uint64, verifierID uint64) (*verification.Whitelist, error)
  • func (vs *VerificationStore) UpdateAssignment(a *verification.Assignment) (*verification.Assignment, error)

Types

type AlreadyAssigned

type AlreadyAssigned struct{}

func (AlreadyAssigned) Error

func (err AlreadyAssigned) Error() string

type AlreadyHasSettings

type AlreadyHasSettings struct{}

func (AlreadyHasSettings) Error

func (err AlreadyHasSettings) Error() string

type AlreadyResponded

type AlreadyResponded struct{}

func (AlreadyResponded) Error

func (err AlreadyResponded) Error() string

type AssignmentNotFound

type AssignmentNotFound struct {
	ID         string
	WorkerID   uint64
	VerifierID nulls.Int64
	JobID      uint64
	ResponseID uint64
}

func (AssignmentNotFound) Error

func (err AssignmentNotFound) Error() string

type DbQueryExecutor

type DbQueryExecutor interface {
	sqlx.Execer
	sqlx.Queryer
	Get(dest interface{}, query string, args ...interface{}) error
}

type NoAssignmentsAvailable

type NoAssignmentsAvailable struct {
	JobID uint64
}

func (NoAssignmentsAvailable) Error

func (err NoAssignmentsAvailable) Error() string

type NoRowErr

type NoRowErr struct{}

func (NoRowErr) Error

func (err NoRowErr) Error() string

type Storage

type Storage interface {
	GetAssignmentByResponseAndVerifier(responseID uint64, verifierID int64) (*verification.Assignment, error)
	UpdateAssignment(a *verification.Assignment) (*verification.Assignment, error)
	GetResponses(verification.Params) (verification.VerificationResponses, error)
	GetResponse(id string) (*verification.VerificationResponse, error)
	CreateResponse(r verification.VerificationResponse) (*verification.VerificationResponse, error)
	CreateResponses(rs verification.VerificationResponses) (verification.VerificationResponses, error)
	GetSettings(jobID uint64) (*verification.Settings, error)
	CreateSettings(s verification.Settings) (*verification.Settings, error)
	GetWhitelist(jobID uint64, verifierID uint64) (*verification.Whitelist, error)
	CreateAssignment(*verification.EmptyAssignment) (*verification.Assignment, error)
	GetAssignment(id string) (*verification.Assignment, error)
	GetAssignments(verification.Params) (verification.Assignments, error)
	DeleteAssignment(id string) (bool, error)
	GetJobsWithEmptyAssignments(verifierID uint64) (verification.JobEmptyAssignments, error)
	GetEligibleJobIDs(verifierID uint64, JobIDs []uint64) ([]uint64, error)
	Assign(a *verification.NewAssignment) (*verification.Assignment, error)
}

type VerificationStore

type VerificationStore struct {
	DB *sqlx.DB
}

func NewDatastore

func NewDatastore(db *sqlx.DB) *VerificationStore

func (*VerificationStore) Assign

func (vs *VerificationStore) Assign(a *verification.NewAssignment) (*verification.Assignment, error)

func (*VerificationStore) CreateAssignment

func (vs *VerificationStore) CreateAssignment(a *verification.EmptyAssignment) (*verification.Assignment, error)

func (*VerificationStore) CreateResponse

func (vs *VerificationStore) CreateResponse(r verification.VerificationResponse) (*verification.VerificationResponse, error)

func (*VerificationStore) CreateResponses

func (vs *VerificationStore) CreateResponses(rs verification.VerificationResponses) (verification.VerificationResponses, error)

func (*VerificationStore) CreateSettings

func (vs *VerificationStore) CreateSettings(s verification.Settings) (*verification.Settings, error)

func (*VerificationStore) DeleteAssignment

func (vs *VerificationStore) DeleteAssignment(id string) (bool, error)

func (*VerificationStore) GetAssignment

func (vs *VerificationStore) GetAssignment(id string) (*verification.Assignment, error)

func (*VerificationStore) GetAssignmentByResponseAndVerifier

func (vs *VerificationStore) GetAssignmentByResponseAndVerifier(responseID uint64, verifierID int64) (*verification.Assignment, error)

func (*VerificationStore) GetAssignments

func (vs *VerificationStore) GetAssignments(p verification.Params) (verification.Assignments, error)

func (*VerificationStore) GetEligibleJobIDs

func (vs *VerificationStore) GetEligibleJobIDs(verifierID uint64, JobIDs []uint64) ([]uint64, error)

func (*VerificationStore) GetJobsWithEmptyAssignments

func (vs *VerificationStore) GetJobsWithEmptyAssignments(verifierID uint64) (verification.JobEmptyAssignments, error)

func (*VerificationStore) GetResponse

func (vs *VerificationStore) GetResponse(id string) (*verification.VerificationResponse, error)

func (*VerificationStore) GetResponses

func (vs *VerificationStore) GetResponses(p verification.Params) (verification.VerificationResponses, error)

func (*VerificationStore) GetSettings

func (vs *VerificationStore) GetSettings(jobID uint64) (*verification.Settings, error)

func (*VerificationStore) GetWhitelist

func (vs *VerificationStore) GetWhitelist(jobID uint64, verifierID uint64) (*verification.Whitelist, error)

func (*VerificationStore) UpdateAssignment

func (vs *VerificationStore) UpdateAssignment(a *verification.Assignment) (*verification.Assignment, error)