spanner

Documentation

Index

• type Repo
  • func NewRepo(ctx context.Context, cfg config.Spanner) (Repo, error)
  • 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, ...) error
  • func (j Repo) UpdateJobLock(ctx context.Context, JobID string, lock bool) error

Types

type Repo

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

func NewRepo

func NewRepo(ctx context.Context, cfg config.Spanner) (Repo, error)

func (Repo) Close

func (r Repo) Close()

func (Repo) DeleteCircle

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

func (Repo) GetCircleData

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

func (Repo) GetCircles

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

func (Repo) GetExpiredJobs

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

func (Repo) GetJob

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

func (Repo) GetJobs

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

func (Repo) InsertCircle

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

func (Repo) InsertCircleData

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

func (Repo) InsertExecutedJob

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

func (Repo) InsertJob

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

func (Repo) TxManager

func (r Repo) TxManager() repository.TxManager

func (Repo) UpdateJobExecution

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

func (Repo) UpdateJobLock

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