mongo

Documentation

Index

• Variables
• type Mongo
  • func New(ctx context.Context, wg *sync.WaitGroup, conf configuration.Config) (*Mongo, error)
  • func (this *Mongo) GetEventDescriptionsByDeviceAndService(deviceId string, serviceId string) (result []model.EventDesc, err error)
  • func (this *Mongo) GetEventDescriptionsByDeviceGroup(deviceGroupId string) (result []model.EventDesc, err error)
  • func (this *Mongo) GetEventDescriptionsByEventId(eventId string) (result []model.EventDesc, err error)
  • func (this *Mongo) GetEventDescriptionsByImportId(importId string) (result []model.EventDesc, err error)
  • func (this *Mongo) GetEventDescriptionsByServiceId(serviceId string) (result []model.EventDesc, err error)
  • func (this *Mongo) RemoveEventDescriptionsByDeploymentId(deploymentId string) (deletedCount int64, err error)
  • func (this *Mongo) SetEventDescription(element model.EventDesc) (err error)

Variables

var CreateCollections = []func(db *Mongo) error{}

var DescBson = getBsonFieldObject[model.EventDesc]()

var ErrReleaseNotFound = errors.New("release not found")

Types

type Mongo

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

func New

func New(ctx context.Context, wg *sync.WaitGroup, conf configuration.Config) (*Mongo, error)

func (*Mongo) GetEventDescriptionsByDeviceAndService

func (this *Mongo) GetEventDescriptionsByDeviceAndService(deviceId string, serviceId string) (result []model.EventDesc, err error)

func (*Mongo) GetEventDescriptionsByDeviceGroup

func (this *Mongo) GetEventDescriptionsByDeviceGroup(deviceGroupId string) (result []model.EventDesc, err error)

func (*Mongo) GetEventDescriptionsByEventId

func (this *Mongo) GetEventDescriptionsByEventId(eventId string) (result []model.EventDesc, err error)

func (*Mongo) GetEventDescriptionsByImportId

func (this *Mongo) GetEventDescriptionsByImportId(importId string) (result []model.EventDesc, err error)

func (*Mongo) GetEventDescriptionsByServiceId

func (this *Mongo) GetEventDescriptionsByServiceId(serviceId string) (result []model.EventDesc, err error)

func (*Mongo) RemoveEventDescriptionsByDeploymentId

func (this *Mongo) RemoveEventDescriptionsByDeploymentId(deploymentId string) (deletedCount int64, err error)

func (*Mongo) SetEventDescription

func (this *Mongo) SetEventDescription(element model.EventDesc) (err error)