spanner

func (r Repo) Close()

func (c Repo) DeleteCircle(ctx context.Context, circleID string) error

func (c Repo) GetCircleData(
	ctx context.Context, circleID string, timeFrom time.Time) (
	model.CircleData, error,
)

func (c Repo) GetCircles(ctx context.Context) ([]model.Circle, error)

func (j Repo) GetExpiredJobs(ctx context.Context,
	isExecuted bool,
) ([]model.Job, error)

func (j Repo) GetJob(
	ctx context.Context, jobID string) (
	model.Job, error,
)

func (j Repo) GetJobs(ctx context.Context,
	isExecuted bool,
) ([]model.Job, error)

func (c Repo) InsertCircle(ctx context.Context, circle model.Circle) error

func (c Repo) InsertCircleData(ctx context.Context, cd model.CircleData) error

func (j Repo) InsertExecutedJob(ctx context.Context, executedJob model.ExecutedJob) error

func (j Repo) InsertJob(ctx context.Context, job model.Job) error

func (r Repo) TxManager() repository.TxManager

func (j Repo) UpdateJobExecution(ctx context.Context,
	JobID string,
	nextExecutionTime time.Time,
	isExecuted bool,
) error

func (j Repo) UpdateJobLock(ctx context.Context,
	JobID string,
	lock bool,
) error