mongo

Documentation

Index

• Variables
• type Mongo
  • func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config) (*Mongo, error)
  • func (this *Mongo) CountVariables(userId string, query model.VariablesQueryOptions) (result model.Count, err error)
  • func (this *Mongo) DeleteVariable(userId string, key string) error
  • func (this *Mongo) DeleteVariablesOfProcessDefinition(definitionId string) error
  • func (this *Mongo) DeleteVariablesOfProcessInstance(instanceId string) error
  • func (this *Mongo) GetVariable(userId string, key string) (result model.VariableWithUser, err error)
  • func (this *Mongo) ListVariables(userId string, query model.VariablesQueryOptions) (result []model.VariableWithUnixTimestamp, err error)
  • func (this *Mongo) SetVariable(variable model.VariableWithUser) error
• type QueryOptions

Variables

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

var VariableBson = getBsonFieldObject[model.VariableWithUser]()

Types

type Mongo

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

func New

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

func (*Mongo) CountVariables

func (this *Mongo) CountVariables(userId string, query model.VariablesQueryOptions) (result model.Count, err error)

func (*Mongo) DeleteVariable

func (this *Mongo) DeleteVariable(userId string, key string) error

func (*Mongo) DeleteVariablesOfProcessDefinition

func (this *Mongo) DeleteVariablesOfProcessDefinition(definitionId string) error

func (*Mongo) DeleteVariablesOfProcessInstance

func (this *Mongo) DeleteVariablesOfProcessInstance(instanceId string) error

func (*Mongo) GetVariable

func (this *Mongo) GetVariable(userId string, key string) (result model.VariableWithUser, err error)

func (*Mongo) ListVariables

func (this *Mongo) ListVariables(userId string, query model.VariablesQueryOptions) (result []model.VariableWithUnixTimestamp, err error)

func (*Mongo) SetVariable

func (this *Mongo) SetVariable(variable model.VariableWithUser) error

type QueryOptions

type QueryOptions interface {
	GetLimit() int64
	GetOffset() int64
	GetSort() string
}