mongo

Documentation

Index

• Constants
• func NewFromFunction(f *aggregate.Function) *mongoFunction
• type MongoRepository
  • func New(ctx context.Context, mC *mongodb.MongoConfig, collectionName string) (*MongoRepository, error)
  • func (mr *MongoRepository) AddAssigner(id, userID value_object.UUID) error
  • func (mr *MongoRepository) AddExecuter(id, userID value_object.UUID) error
  • func (mr *MongoRepository) AddReader(id, userID value_object.UUID) error
  • func (mr *MongoRepository) AliveReport(id value_object.UUID) error
  • func (mr *MongoRepository) All(withoutFields []string) ([]*aggregate.Function, error)
  • func (mr *MongoRepository) Create(f *aggregate.Function) error
  • func (mr *MongoRepository) FindOrCreate(f *aggregate.Function) (alreadyExistFunction *aggregate.Function, err error)
  • func (mr *MongoRepository) GetByID(id value_object.UUID) (*aggregate.Function, error)
  • func (mr *MongoRepository) GetByIDForCheckAliveTime(id value_object.UUID) (*aggregate.Function, error)
  • func (mr *MongoRepository) GetSameIptOptFunction(iptDigest, optDigest string) (*aggregate.Function, error)
  • func (mr *MongoRepository) IDMapFunctionAll() (map[value_object.UUID]*aggregate.Function, error)
  • func (mr *MongoRepository) PatchDescription(id value_object.UUID, desc string) error
  • func (mr *MongoRepository) PatchGroupName(id value_object.UUID, groupName string) error
  • func (mr *MongoRepository) PatchName(id value_object.UUID, name string) error
  • func (mr *MongoRepository) PatchProgressMilestones(id value_object.UUID, progressMilestones []string) error
  • func (mr *MongoRepository) PatchProviderName(id value_object.UUID, providerName string) error
  • func (mr *MongoRepository) RemoveAssigner(id, userID value_object.UUID) error
  • func (mr *MongoRepository) RemoveExecuter(id, userID value_object.UUID) error
  • func (mr *MongoRepository) RemoveReader(id, userID value_object.UUID) error
  • func (mr *MongoRepository) UserReadAbleAll(user *aggregate.User, withoutFields []string) ([]*aggregate.Function, error)

Constants

const (
	DefaultCollectionName = "function"
)

Functions

func NewFromFunction

func NewFromFunction(f *aggregate.Function) *mongoFunction

Types

type MongoRepository

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

func New

func New(
	ctx context.Context,
	mC *mongodb.MongoConfig, collectionName string,
) (*MongoRepository, error)

Create a new mongodb repository

func (*MongoRepository) AddAssigner

func (mr *MongoRepository) AddAssigner(id, userID value_object.UUID) error

func (*MongoRepository) AddExecuter

func (mr *MongoRepository) AddExecuter(id, userID value_object.UUID) error

func (*MongoRepository) AddReader

func (mr *MongoRepository) AddReader(id, userID value_object.UUID) error

func (*MongoRepository) AliveReport

func (mr *MongoRepository) AliveReport(
	id value_object.UUID,
) error

func (*MongoRepository) All

func (mr *MongoRepository) All(withoutFields []string) ([]*aggregate.Function, error)

func (*MongoRepository) Create

func (mr *MongoRepository) Create(
	f *aggregate.Function,
) error

func (*MongoRepository) FindOrCreate

func (mr *MongoRepository) FindOrCreate(
	f *aggregate.Function,
) (
	alreadyExistFunction *aggregate.Function,
	err error,
)

func (*MongoRepository) GetByID

func (mr *MongoRepository) GetByID(
	id value_object.UUID,
) (*aggregate.Function, error)

func (*MongoRepository) GetByIDForCheckAliveTime

func (mr *MongoRepository) GetByIDForCheckAliveTime(
	id value_object.UUID,
) (*aggregate.Function, error)

func (*MongoRepository) GetSameIptOptFunction

func (mr *MongoRepository) GetSameIptOptFunction(
	iptDigest, optDigest string,
) (*aggregate.Function, error)

func (*MongoRepository) IDMapFunctionAll

func (mr *MongoRepository) IDMapFunctionAll() (map[value_object.UUID]*aggregate.Function, error)

func (*MongoRepository) PatchDescription

func (mr *MongoRepository) PatchDescription(id value_object.UUID, desc string) error

func (*MongoRepository) PatchGroupName

func (mr *MongoRepository) PatchGroupName(id value_object.UUID, groupName string) error

func (*MongoRepository) PatchName

func (mr *MongoRepository) PatchName(id value_object.UUID, name string) error

func (*MongoRepository) PatchProgressMilestones

func (mr *MongoRepository) PatchProgressMilestones(
	id value_object.UUID,
	progressMilestones []string,
) error

func (*MongoRepository) PatchProviderName

func (mr *MongoRepository) PatchProviderName(
	id value_object.UUID, providerName string,
) error

func (*MongoRepository) RemoveAssigner

func (mr *MongoRepository) RemoveAssigner(id, userID value_object.UUID) error

func (*MongoRepository) RemoveExecuter

func (mr *MongoRepository) RemoveExecuter(id, userID value_object.UUID) error

func (*MongoRepository) RemoveReader

func (mr *MongoRepository) RemoveReader(id, userID value_object.UUID) error

func (*MongoRepository) UserReadAbleAll

func (mr *MongoRepository) UserReadAbleAll(
	user *aggregate.User, withoutFields []string,
) ([]*aggregate.Function, error)