source_metadata_job_repository.go

package memory

import (
	"context"
	"go.opencensus.io/trace"
)

// SourceMetadataJob defines table version backup job
type SourceMetadataJob struct {
	SourceMetadataID int
	JobID            string
}

// DefaultSourceMetadataJobRepository gives possibility to add new SourceMetadataJob
type DefaultSourceMetadataJobRepository struct {
	sourceMetadataJobs []*SourceMetadataJob
}

// Add gives possibility add new SourceMetadataJob
func (r *DefaultSourceMetadataJobRepository) Add(ctxIn context.Context, sourceMetadataID int, jobID string) error {
	_, span := trace.StartSpan(ctxIn, "(*DefaultSourceMetadataJobRepository).Add")
	defer span.End()

	r.sourceMetadataJobs = append(r.sourceMetadataJobs, &SourceMetadataJob{SourceMetadataID: sourceMetadataID, JobID: jobID})
	return nil
}