mongo

Documentation

Index

• Variables
• type ImportTypeCriteria
• type ImportTypeWithCriteria
• type Mongo
  • func New(conf config.Config, ctx context.Context, wg *sync.WaitGroup) (*Mongo, error)
  • func (this *Mongo) CreateId() string
  • func (this *Mongo) Disconnect()
  • func (this *Mongo) GetImportType(ctx context.Context, id string) (importType model.ImportType, exists bool, err error)
  • func (this *Mongo) ListImportTypes(ctx context.Context, listOptions model.ImportTypeListOptions) (result []model.ImportType, total int64, err error)
  • func (this *Mongo) RemoveImportType(ctx context.Context, id string) error
  • func (this *Mongo) SetImportType(ctx context.Context, importType model.ImportType) error

Variables

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

Types

type ImportTypeCriteria

type ImportTypeCriteria struct {
	FunctionId string `json:"function_id" bson:"function_id"`
	AspectId   string `json:"aspect_id" bson:"aspect_id"`
}

type ImportTypeWithCriteria

type ImportTypeWithCriteria struct {
	model.ImportType `bson:",inline" json:",inline"`
	Criteria         []ImportTypeCriteria `json:"criteria" bson:"criteria"`
}

type Mongo

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

func New

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

func (*Mongo) CreateId

func (this *Mongo) CreateId() string

func (*Mongo) Disconnect

func (this *Mongo) Disconnect()

func (*Mongo) GetImportType

func (this *Mongo) GetImportType(ctx context.Context, id string) (importType model.ImportType, exists bool, err error)

func (*Mongo) ListImportTypes

func (this *Mongo) ListImportTypes(ctx context.Context, listOptions model.ImportTypeListOptions) (result []model.ImportType, total int64, err error)

func (*Mongo) RemoveImportType

func (this *Mongo) RemoveImportType(ctx context.Context, id string) error

func (*Mongo) SetImportType

func (this *Mongo) SetImportType(ctx context.Context, importType model.ImportType) error