repositories

Documentation

Index

• Constants
• type Brewjobrepository
  • func NewEventRepository(connection string) (Brewjobrepository, error)
  • func NewMongoDBLayer(connection string) (Brewjobrepository, error)
• type MongoDBLayer
  • func (mgoLayer *MongoDBLayer) AddBrewJob(brewjob entities.BrewJob) ([]byte, error)
  • func (mgoLayer *MongoDBLayer) ChangeStatus(brewJobId []byte, status string) error
  • func (mgoLayer *MongoDBLayer) ExecuteCommand(cmd interface{}) (interface{}, error)
  • func (mgoLayer *MongoDBLayer) FindAllBrewJobs() ([]entities.BrewJob, error)
  • func (mgoLayer *MongoDBLayer) FindByBrewJobById(brewJobId []byte) (entities.BrewJob, error)

Constants

const (
	MONGODB_BREWJOBCOLLECTION = "brewjob"
)

Types

type Brewjobrepository

type Brewjobrepository interface {
	AddBrewJob(entities.BrewJob) ([]byte, error)
	FindByBrewJobById([]byte) (entities.BrewJob, error)
	FindAllBrewJobs() ([]entities.BrewJob, error)
	ChangeStatus([]byte, string) error

	ExecuteCommand(interface{}) (interface{}, error)
}

func NewEventRepository

func NewEventRepository(connection string) (Brewjobrepository, error)

func NewMongoDBLayer

func NewMongoDBLayer(connection string) (Brewjobrepository, error)

type MongoDBLayer

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

func (*MongoDBLayer) AddBrewJob

func (mgoLayer *MongoDBLayer) AddBrewJob(brewjob entities.BrewJob) ([]byte, error)

func (*MongoDBLayer) ChangeStatus

func (mgoLayer *MongoDBLayer) ChangeStatus(brewJobId []byte, status string) error

func (*MongoDBLayer) ExecuteCommand

func (mgoLayer *MongoDBLayer) ExecuteCommand(cmd interface{}) (interface{}, error)

func (*MongoDBLayer) FindAllBrewJobs

func (mgoLayer *MongoDBLayer) FindAllBrewJobs() ([]entities.BrewJob, error)

func (*MongoDBLayer) FindByBrewJobById

func (mgoLayer *MongoDBLayer) FindByBrewJobById(brewJobId []byte) (entities.BrewJob, error)