mongo

Documentation

Index

• Variables
• type IndexDesc
• type KeyMapping
• type Mongo
  • func New(conf configuration.Config) (*Mongo, error)
  • func (this *Mongo) Disconnect()
  • func (this *Mongo) FilterNetworkIds(networkIds []string) (result []string, err error)
  • func (this *Mongo) GetDefinitionByDeploymentId(networkId string, deploymentId string) (processDefinition model.ProcessDefinition, err error)
  • func (this *Mongo) GetDefinitionsOfDeploymentIdList(networkId string, deploymentIds []string) (result map[string]model.ProcessDefinition, err error)
  • func (this *Mongo) GetDeploymentMetadataOfDeploymentIdList(networkId string, deploymentIds []string) (result map[string]model.DeploymentMetadata, err error)
  • func (this *Mongo) GetOldNetworkIds(maxAge time.Duration) (result []string, err error)
  • func (this *Mongo) ListDeploymentMetadata(query model.MetadataQuery) (result []model.DeploymentMetadata, err error)
  • func (this *Mongo) ListDeploymentMetadataByEventDeviceGroupId(deviceGroupId string) (result []model.DeploymentMetadata, err error)
  • func (this *Mongo) ListDeployments(networkIds []string, limit int64, offset int64, sort string) (result []model.Deployment, err error)
  • func (this *Mongo) ListHistoricProcessInstances(networkIds []string, query model.HistoryQuery, limit int64, offset int64, ...) (result []model.HistoricProcessInstance, total int64, err error)
  • func (this *Mongo) ListIncidents(networkIds []string, processInstanceId string, limit int64, offset int64, ...) (result []model.Incident, err error)
  • func (this *Mongo) ListProcessDefinitions(networkIds []string, limit int64, offset int64, sort string) (result []model.ProcessDefinition, err error)
  • func (this *Mongo) ListProcessInstances(networkIds []string, limit int64, offset int64, sort string) (result []model.ProcessInstance, err error)
  • func (this *Mongo) ReadDeployment(networkId string, deploymentId string) (deployment model.Deployment, err error)
  • func (this *Mongo) ReadDeploymentMetadata(networkId string, deploymentId string) (metadata model.DeploymentMetadata, err error)
  • func (this *Mongo) ReadHistoricProcessInstance(networkId string, historicProcessInstanceId string) (historicProcessInstance model.HistoricProcessInstance, err error)
  • func (this *Mongo) ReadIncident(networkId string, incidentId string) (incident model.Incident, err error)
  • func (this *Mongo) ReadProcessDefinition(networkId string, processDefinitionId string) (processDefinition model.ProcessDefinition, err error)
  • func (this *Mongo) ReadProcessInstance(networkId string, processInstanceId string) (processInstance model.ProcessInstance, err error)
  • func (this *Mongo) RemoveDeployment(networkId string, deploymentId string) error
  • func (this *Mongo) RemoveDeploymentMetadata(networkId string, deploymentId string) error
  • func (this *Mongo) RemoveHistoricProcessInstance(networkId string, historicProcessInstanceId string) error
  • func (this *Mongo) RemoveIncident(networkId string, incidentId string) error
  • func (this *Mongo) RemoveIncidentOfDefinition(networkId string, definitionId string) error
  • func (this *Mongo) RemoveIncidentOfInstance(networkId string, instanceId string) error
  • func (this *Mongo) RemoveIncidentOfNotDefinitions(networkId string, notDefinitionIds []string) error
  • func (this *Mongo) RemoveIncidentOfNotInstances(networkId string, notInstanceIds []string) error
  • func (this *Mongo) RemoveOldElements(maxAge time.Duration) (err error)
  • func (this *Mongo) RemovePlaceholderDeployments(networkId string) error
  • func (this *Mongo) RemovePlaceholderHistoricProcessInstances(networkId string) error
  • func (this *Mongo) RemovePlaceholderProcessInstances(networkId string) error
  • func (this *Mongo) RemoveProcessDefinition(networkId string, processDefinitionId string) error
  • func (this *Mongo) RemoveProcessInstance(networkId string, processInstanceId string) error
  • func (this *Mongo) RemoveUnknownDeploymentMetadata(networkId string, knownIds []string) error
  • func (this *Mongo) RemoveUnknownDeployments(networkId string, knownIds []string) error
  • func (this *Mongo) RemoveUnknownHistoricProcessInstances(networkId string, knownIds []string) error
  • func (this *Mongo) RemoveUnknownIncidents(networkId string, knownIds []string) error
  • func (this *Mongo) RemoveUnknownProcessDefinitions(networkId string, knownIds []string) error
  • func (this *Mongo) RemoveUnknownProcessInstances(networkId string, knownIds []string) error
  • func (this *Mongo) SaveDeployment(deployment model.Deployment) error
  • func (this *Mongo) SaveDeploymentMetadata(metadata model.DeploymentMetadata) error
  • func (this *Mongo) SaveHistoricProcessInstance(historicProcessInstance model.HistoricProcessInstance) error
  • func (this *Mongo) SaveIncident(incident model.Incident) (newDocument bool, err error)
  • func (this *Mongo) SaveLastContact(lastContact model.LastNetworkContact) error
  • func (this *Mongo) SaveProcessDefinition(processDefinition model.ProcessDefinition) error
  • func (this *Mongo) SaveProcessInstance(processInstance model.ProcessInstance) error
  • func (this *Mongo) SearchDeployments(networkIds []string, search string, limit int64, offset int64, sort string) (result []model.Deployment, err error)

Variables

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

Types

type IndexDesc

type IndexDesc struct {
	Name        string
	Unique      bool
	Asc         bool
	Keys        []*string
	IsTextIndex bool
}

type KeyMapping

type KeyMapping struct {
	FieldName string
	Key       *string
}

type Mongo

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

func New

func New(conf configuration.Config) (*Mongo, error)

func (*Mongo) Disconnect

func (this *Mongo) Disconnect()

func (*Mongo) FilterNetworkIds

func (this *Mongo) FilterNetworkIds(networkIds []string) (result []string, err error)

func (*Mongo) GetDefinitionByDeploymentId

func (this *Mongo) GetDefinitionByDeploymentId(networkId string, deploymentId string) (processDefinition model.ProcessDefinition, err error)

func (*Mongo) GetDefinitionsOfDeploymentIdList

func (this *Mongo) GetDefinitionsOfDeploymentIdList(networkId string, deploymentIds []string) (result map[string]model.ProcessDefinition, err error)

func (*Mongo) GetDeploymentMetadataOfDeploymentIdList

func (this *Mongo) GetDeploymentMetadataOfDeploymentIdList(networkId string, deploymentIds []string) (result map[string]model.DeploymentMetadata, err error)

func (*Mongo) GetOldNetworkIds

func (this *Mongo) GetOldNetworkIds(maxAge time.Duration) (result []string, err error)

func (*Mongo) ListDeploymentMetadata

func (this *Mongo) ListDeploymentMetadata(query model.MetadataQuery) (result []model.DeploymentMetadata, err error)

func (*Mongo) ListDeploymentMetadataByEventDeviceGroupId

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

func (*Mongo) ListDeployments

func (this *Mongo) ListDeployments(networkIds []string, limit int64, offset int64, sort string) (result []model.Deployment, err error)

func (*Mongo) ListHistoricProcessInstances

func (this *Mongo) ListHistoricProcessInstances(networkIds []string, query model.HistoryQuery, limit int64, offset int64, sort string) (result []model.HistoricProcessInstance, total int64, err error)

func (*Mongo) ListIncidents

func (this *Mongo) ListIncidents(networkIds []string, processInstanceId string, limit int64, offset int64, sort string) (result []model.Incident, err error)

func (*Mongo) ListProcessDefinitions

func (this *Mongo) ListProcessDefinitions(networkIds []string, limit int64, offset int64, sort string) (result []model.ProcessDefinition, err error)

func (*Mongo) ListProcessInstances

func (this *Mongo) ListProcessInstances(networkIds []string, limit int64, offset int64, sort string) (result []model.ProcessInstance, err error)

func (*Mongo) ReadDeployment

func (this *Mongo) ReadDeployment(networkId string, deploymentId string) (deployment model.Deployment, err error)

func (*Mongo) ReadDeploymentMetadata

func (this *Mongo) ReadDeploymentMetadata(networkId string, deploymentId string) (metadata model.DeploymentMetadata, err error)

func (*Mongo) ReadHistoricProcessInstance

func (this *Mongo) ReadHistoricProcessInstance(networkId string, historicProcessInstanceId string) (historicProcessInstance model.HistoricProcessInstance, err error)

func (*Mongo) ReadIncident

func (this *Mongo) ReadIncident(networkId string, incidentId string) (incident model.Incident, err error)

func (*Mongo) ReadProcessDefinition

func (this *Mongo) ReadProcessDefinition(networkId string, processDefinitionId string) (processDefinition model.ProcessDefinition, err error)

func (*Mongo) ReadProcessInstance

func (this *Mongo) ReadProcessInstance(networkId string, processInstanceId string) (processInstance model.ProcessInstance, err error)

func (*Mongo) RemoveDeployment

func (this *Mongo) RemoveDeployment(networkId string, deploymentId string) error

func (*Mongo) RemoveDeploymentMetadata

func (this *Mongo) RemoveDeploymentMetadata(networkId string, deploymentId string) error

func (*Mongo) RemoveHistoricProcessInstance

func (this *Mongo) RemoveHistoricProcessInstance(networkId string, historicProcessInstanceId string) error

func (*Mongo) RemoveIncident

func (this *Mongo) RemoveIncident(networkId string, incidentId string) error

func (*Mongo) RemoveIncidentOfDefinition

func (this *Mongo) RemoveIncidentOfDefinition(networkId string, definitionId string) error

func (*Mongo) RemoveIncidentOfInstance

func (this *Mongo) RemoveIncidentOfInstance(networkId string, instanceId string) error

func (*Mongo) RemoveIncidentOfNotDefinitions

func (this *Mongo) RemoveIncidentOfNotDefinitions(networkId string, notDefinitionIds []string) error

func (*Mongo) RemoveIncidentOfNotInstances

func (this *Mongo) RemoveIncidentOfNotInstances(networkId string, notInstanceIds []string) error

func (*Mongo) RemoveOldElements

func (this *Mongo) RemoveOldElements(maxAge time.Duration) (err error)

func (*Mongo) RemovePlaceholderDeployments

func (this *Mongo) RemovePlaceholderDeployments(networkId string) error

func (*Mongo) RemovePlaceholderHistoricProcessInstances

func (this *Mongo) RemovePlaceholderHistoricProcessInstances(networkId string) error

func (*Mongo) RemovePlaceholderProcessInstances

func (this *Mongo) RemovePlaceholderProcessInstances(networkId string) error

func (*Mongo) RemoveProcessDefinition

func (this *Mongo) RemoveProcessDefinition(networkId string, processDefinitionId string) error

func (*Mongo) RemoveProcessInstance

func (this *Mongo) RemoveProcessInstance(networkId string, processInstanceId string) error

func (*Mongo) RemoveUnknownDeploymentMetadata

func (this *Mongo) RemoveUnknownDeploymentMetadata(networkId string, knownIds []string) error

func (*Mongo) RemoveUnknownDeployments

func (this *Mongo) RemoveUnknownDeployments(networkId string, knownIds []string) error

func (*Mongo) RemoveUnknownHistoricProcessInstances

func (this *Mongo) RemoveUnknownHistoricProcessInstances(networkId string, knownIds []string) error

func (*Mongo) RemoveUnknownIncidents

func (this *Mongo) RemoveUnknownIncidents(networkId string, knownIds []string) error

func (*Mongo) RemoveUnknownProcessDefinitions

func (this *Mongo) RemoveUnknownProcessDefinitions(networkId string, knownIds []string) error

func (*Mongo) RemoveUnknownProcessInstances

func (this *Mongo) RemoveUnknownProcessInstances(networkId string, knownIds []string) error

func (*Mongo) SaveDeployment

func (this *Mongo) SaveDeployment(deployment model.Deployment) error

func (*Mongo) SaveDeploymentMetadata

func (this *Mongo) SaveDeploymentMetadata(metadata model.DeploymentMetadata) error

func (*Mongo) SaveHistoricProcessInstance

func (this *Mongo) SaveHistoricProcessInstance(historicProcessInstance model.HistoricProcessInstance) error

func (*Mongo) SaveIncident

func (this *Mongo) SaveIncident(incident model.Incident) (newDocument bool, err error)

func (*Mongo) SaveLastContact

func (this *Mongo) SaveLastContact(lastContact model.LastNetworkContact) error

func (*Mongo) SaveProcessDefinition

func (this *Mongo) SaveProcessDefinition(processDefinition model.ProcessDefinition) error

func (*Mongo) SaveProcessInstance

func (this *Mongo) SaveProcessInstance(processInstance model.ProcessInstance) error

func (*Mongo) SearchDeployments

func (this *Mongo) SearchDeployments(networkIds []string, search string, limit int64, offset int64, sort string) (result []model.Deployment, err error)