persister

Documentation

Index

• type MongoPersister
  • func NewMongoPersister(c config.PersisterMongo) *MongoPersister
  • func (MongoPersister) GetTaskByID(id string) (*model.Task, error)
  • func (MongoPersister) GetTaskDefinitionByID(id string) (*model.TaskDefinition, error)
  • func (p MongoPersister) Prepare() error
  • func (MongoPersister) SaveAgent(agent model.Agent) error
  • func (MongoPersister) SaveTask(task model.Task) error
  • func (MongoPersister) SaveTaskDefinition(taskDefinition model.TaskDefinition) error
• type Persister

Types

type MongoPersister

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

func NewMongoPersister

func NewMongoPersister(c config.PersisterMongo) *MongoPersister

func (MongoPersister) GetTaskByID

func (MongoPersister) GetTaskByID(id string) (*model.Task, error)

func (MongoPersister) GetTaskDefinitionByID

func (MongoPersister) GetTaskDefinitionByID(id string) (*model.TaskDefinition, error)

func (MongoPersister) Prepare

func (p MongoPersister) Prepare() error

func (MongoPersister) SaveAgent

func (MongoPersister) SaveAgent(agent model.Agent) error

func (MongoPersister) SaveTask

func (MongoPersister) SaveTask(task model.Task) error

func (MongoPersister) SaveTaskDefinition

func (MongoPersister) SaveTaskDefinition(taskDefinition model.TaskDefinition) error

type Persister

type Persister interface {
	Prepare() error

	SaveTask(task model.Task) error
	GetTaskByID(id string) (*model.Task, error)

	SaveTaskDefinition(taskDefinition model.TaskDefinition) error
	GetTaskDefinitionByID(id string) (*model.TaskDefinition, error)

	SaveAgent(agent model.Agent) error
}