repository

Documentation

Index

• type CircleDataRepositry
• type CircleRepository
• type ExecutedJobsRepositary
• type JobRepositary
• type Repository
• type TxManager

Types

type CircleDataRepositry

type CircleDataRepositry interface {
	InsertCircleData(ctx context.Context, cd model.CircleData) error
	GetCircleData(ctx context.Context, circleID string, timeFrom time.Time) (model.CircleData, error)
}

type CircleRepository

type CircleRepository interface {
	InsertCircle(ctx context.Context, circle model.Circle) error
	GetCircles(ctx context.Context) ([]model.Circle, error)
	DeleteCircle(ctx context.Context, circleID string) error
}

type ExecutedJobsRepositary

type ExecutedJobsRepositary interface {
	InsertExecutedJob(ctx context.Context, executedJob model.ExecutedJob) error
}

type JobRepositary

type JobRepositary interface {
	GetJobs(ctx context.Context, isExecuted bool) ([]model.Job, error)
	GetJob(ctx context.Context, jobID string) (model.Job, error)
	InsertJob(ctx context.Context, job model.Job) error
	UpdateJobExecution(ctx context.Context, JobID string, nextExecutionTime time.Time, isExecuted bool) error
	UpdateJobLock(ctx context.Context, JobID string, lock bool) error
	GetExpiredJobs(ctx context.Context, isExecuted bool) ([]model.Job, error)
}

type Repository

type Repository interface {
	JobRepositary
	ExecutedJobsRepositary
	CircleRepository
	CircleDataRepositry
	TxManager() TxManager
}

type TxManager

type TxManager interface {
	ReadWriteTx(context.Context, func(ctx context.Context) error) error
	ReadOnlyTx(context.Context, func(ctx context.Context) error) error
}