Method AddProcedure

core/procedures/collection.go:115–141

AddProcedure adds a new procedure.

(ctx context.Context, proc Procedure)

// AddProcedure adds a new procedure.
func (pgp *Collection) AddProcedure(ctx context.Context, proc Procedure) error {
	// First we'll check to see if it exists
	if _, ok := pgp.accessCache[proc.ID]; ok {
		return errors.Errorf(`procedure "%s" already exists with same argument types`, proc.ID.ProcedureName())
	}

	// Now we'll add the procedure to our map
	data, err := proc.Serialize(ctx)
	if err != nil {
		return err
	}
	h, err := pgp.ns.WriteBytes(ctx, data)
	if err != nil {
		return err
	}
	mapEditor := pgp.underlyingMap.Editor()
	if err = mapEditor.Add(ctx, string(proc.ID), h); err != nil {
		return err
	}
	newMap, err := mapEditor.Flush(ctx)
	if err != nil {
		return err
	}
	pgp.underlyingMap = newMap
	pgp.mapHash = pgp.underlyingMap.HashOf()
	return pgp.reloadCaches(ctx)
}

// DropProcedure drops an existing procedure.
func (pgp *Collection) DropProcedure(ctx context.Context, procIDs ...id.Procedure) error {