repositories

Documentation

Index

• type HistoryRepository
  • func NewHistoryRepository(db driver.Database, collectionName string) (*HistoryRepository, error)
  • func (repo *HistoryRepository) Create(ctx context.Context, entry history.Record) (dal.Entity, error)
  • func (repo *HistoryRepository) Find(ctx context.Context, q dal.Query) (history.QueryResult, error)
  • func (repo *HistoryRepository) Get(ctx context.Context, jobID string) (history.RecordEntity, error)
  • func (repo *HistoryRepository) Update(ctx context.Context, entry history.Record) (dal.Entity, error)
• type PersistenceRepository
  • func NewPersistenceRepository(db driver.Database, collectionName string) (*PersistenceRepository, error)
  • func (repo *PersistenceRepository) Create(ctx context.Context, record persistence.Record) (dal.Entity, error)
  • func (repo *PersistenceRepository) Delete(ctx context.Context, id string) error
  • func (repo *PersistenceRepository) Find(ctx context.Context, q dal.Query) (persistence.QueryResult, error)
  • func (repo *PersistenceRepository) FindByScriptID(ctx context.Context, scriptID string, q dal.Query) (persistence.QueryResult, error)
  • func (repo *PersistenceRepository) Get(ctx context.Context, id string) (persistence.RecordEntity, error)
  • func (repo *PersistenceRepository) Update(ctx context.Context, record persistence.Record) (dal.Entity, error)
• type ProjectRepository
  • func NewProjectRepository(client driver.Client, db driver.Database, collectionName string) (*ProjectRepository, error)
  • func (repo *ProjectRepository) Create(ctx context.Context, project projects.Project) (dal.Entity, error)
  • func (repo *ProjectRepository) Delete(ctx context.Context, id string) error
  • func (repo *ProjectRepository) Find(ctx context.Context, q dal.Query) (projects.QueryResult, error)
  • func (repo *ProjectRepository) Get(ctx context.Context, id string) (projects.ProjectEntity, error)
  • func (repo *ProjectRepository) Update(ctx context.Context, project projects.UpdateProject) (dal.Entity, error)
• type ScriptRepository
  • func NewScriptRepository(db driver.Database, collectionName string) (*ScriptRepository, error)
  • func (repo *ScriptRepository) Create(ctx context.Context, script scripts.Script) (dal.Entity, error)
  • func (repo *ScriptRepository) Delete(ctx context.Context, id string) error
  • func (repo *ScriptRepository) Find(ctx context.Context, q dal.Query) (scripts.QueryResult, error)
  • func (repo *ScriptRepository) Get(ctx context.Context, id string) (scripts.ScriptEntity, error)
  • func (repo *ScriptRepository) Update(ctx context.Context, script scripts.UpdateScript) (dal.Entity, error)

Types

type HistoryRepository

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

func NewHistoryRepository

func NewHistoryRepository(db driver.Database, collectionName string) (*HistoryRepository, error)

func (*HistoryRepository) Create

func (repo *HistoryRepository) Create(ctx context.Context, entry history.Record) (dal.Entity, error)

func (*HistoryRepository) Find

func (repo *HistoryRepository) Find(ctx context.Context, q dal.Query) (history.QueryResult, error)

func (*HistoryRepository) Get

func (repo *HistoryRepository) Get(ctx context.Context, jobID string) (history.RecordEntity, error)

func (*HistoryRepository) Update

func (repo *HistoryRepository) Update(ctx context.Context, entry history.Record) (dal.Entity, error)

type PersistenceRepository

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

func NewPersistenceRepository

func NewPersistenceRepository(db driver.Database, collectionName string) (*PersistenceRepository, error)

func (*PersistenceRepository) Create

func (repo *PersistenceRepository) Create(ctx context.Context, record persistence.Record) (dal.Entity, error)

func (*PersistenceRepository) Delete

func (repo *PersistenceRepository) Delete(ctx context.Context, id string) error

func (*PersistenceRepository) Find

func (repo *PersistenceRepository) Find(ctx context.Context, q dal.Query) (persistence.QueryResult, error)

func (*PersistenceRepository) FindByScriptID

func (repo *PersistenceRepository) FindByScriptID(ctx context.Context, scriptID string, q dal.Query) (persistence.QueryResult, error)

func (*PersistenceRepository) Get

func (repo *PersistenceRepository) Get(ctx context.Context, id string) (persistence.RecordEntity, error)

func (*PersistenceRepository) Update

func (repo *PersistenceRepository) Update(ctx context.Context, record persistence.Record) (dal.Entity, error)

type ProjectRepository

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

func NewProjectRepository

func NewProjectRepository(client driver.Client, db driver.Database, collectionName string) (*ProjectRepository, error)

func (*ProjectRepository) Create

func (repo *ProjectRepository) Create(ctx context.Context, project projects.Project) (dal.Entity, error)

func (*ProjectRepository) Delete

func (repo *ProjectRepository) Delete(ctx context.Context, id string) error

func (*ProjectRepository) Find

func (repo *ProjectRepository) Find(ctx context.Context, q dal.Query) (projects.QueryResult, error)

func (*ProjectRepository) Get

func (repo *ProjectRepository) Get(ctx context.Context, id string) (projects.ProjectEntity, error)

func (*ProjectRepository) Update

func (repo *ProjectRepository) Update(ctx context.Context, project projects.UpdateProject) (dal.Entity, error)

type ScriptRepository

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

func NewScriptRepository

func NewScriptRepository(db driver.Database, collectionName string) (*ScriptRepository, error)

func (*ScriptRepository) Create

func (repo *ScriptRepository) Create(ctx context.Context, script scripts.Script) (dal.Entity, error)

func (*ScriptRepository) Delete

func (repo *ScriptRepository) Delete(ctx context.Context, id string) error

func (*ScriptRepository) Find

func (repo *ScriptRepository) Find(ctx context.Context, q dal.Query) (scripts.QueryResult, error)

func (*ScriptRepository) Get

func (repo *ScriptRepository) Get(ctx context.Context, id string) (scripts.ScriptEntity, error)

func (*ScriptRepository) Update

func (repo *ScriptRepository) Update(ctx context.Context, script scripts.UpdateScript) (dal.Entity, error)