node

Documentation

Index

• Variables
• func Initialize()
• func IsInMappy(item string, mp mappy) bool
• func ReloadFromDisk(path string) (err error)
• type FormFile
• type FormFiles
• type IdxInfo
• type Indexes
• type Locker
  • func NewLocker() *Locker
  • func (l *Locker) LockPartOp()
  • func (l *Locker) UnlockPartOp()
• type Node
  • func CreateNodeUpload(u *user.User, params map[string]string, files FormFiles) (node *Node, err error)
  • func Load(id string, uuid string) (n *Node, err error)
  • func LoadFromDisk(id string) (n *Node, err error)
  • func LoadUnauth(id string) (n *Node, err error)
  • func New() (node *Node)
  • func (node *Node) Delete() (err error)
  • func (node *Node) FileExt() string
  • func (node *Node) FilePath() string
  • func (node *Node) FileReader() (reader file.ReaderAt, err error)
  • func (node *Node) HasFile() bool
  • func (node *Node) HasIndex(index string) bool
  • func (node *Node) HasParent() bool
  • func (node *Node) Index(name string) (idx index.Index, err error)
  • func (node *Node) IndexPath() string
  • func (node *Node) Mkdir() (err error)
  • func (node *Node) Path() string
  • func (node *Node) Rmdir() (err error)
  • func (node *Node) Save() (err error)
  • func (node *Node) SetAttributes(attr FormFile) (err error)
  • func (node *Node) SetFile(file FormFile) (err error)
  • func (node *Node) SetFileFormat(format string) (err error)
  • func (node *Node) SetFileFromParts(p *partsList, allowEmpty bool) (err error)
  • func (node *Node) SetFileFromPath(path string, action string) (err error)
  • func (node *Node) SetIndexInfo(indextype string, idxinfo IdxInfo) (err error)
  • func (node *Node) ToJson() (s string, err error)
  • func (node *Node) Update(params map[string]string, files FormFiles) (err error)
  • func (node *Node) UpdateDataTags(types string) (err error)
  • func (node *Node) UpdateLinkages(ltype string, ids string, operation string) (err error)
  • func (node *Node) UpdateVersion() (err error)
• type Nodes
  • func LoadNodes(ids []string) (n Nodes, err error)
  • func (n *Nodes) GetAll(q bson.M) (err error)
  • func (n *Nodes) GetPaginated(q bson.M, limit int, offset int) (count int, err error)

Variables

var (
	LockMgr = NewLocker()
)

Functions

func Initialize

func Initialize()

Initialize creates a copy of the mongodb connection and then uses that connection to create the Nodes collection in mongodb. Then, it ensures that there is a unique index on the id key in this collection, creating the index if necessary.

func IsInMappy

func IsInMappy(item string, mp mappy) bool

func ReloadFromDisk

func ReloadFromDisk(path string) (err error)

Types

type FormFile

type FormFile struct {
	Name     string
	Path     string
	Checksum map[string]string
}

type FormFiles

type FormFiles map[string]FormFile

type IdxInfo

type IdxInfo struct {
	Type        string `bson:"index_type" json:"-"`
	TotalUnits  int64  `bson:"total_units" json:"total_units"`
	AvgUnitSize int64  `bson:"average_unit_size" json:"average_unit_size"`
}

type Indexes

type Indexes map[string]IdxInfo

type Locker

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

func NewLocker

func NewLocker() *Locker

func (*Locker) LockPartOp

func (l *Locker) LockPartOp()

func (*Locker) UnlockPartOp

func (l *Locker) UnlockPartOp()

type Node

type Node struct {
	Id           string            `bson:"id" json:"id"`
	Version      string            `bson:"version" json:"version"`
	File         file.File         `bson:"file" json:"file"`
	Attributes   interface{}       `bson:"attributes" json:"attributes"`
	Public       bool              `bson:"public" json:"public"`
	Indexes      Indexes           `bson:"indexes" json:"indexes"`
	Acl          acl.Acl           `bson:"acl" json:"-"`
	VersionParts map[string]string `bson:"version_parts" json:"-"`
	Tags         []string          `bson:"tags" json:"tags"`
	Revisions    []Node            `bson:"revisions" json:"-"`
	Linkages     []linkage         `bson:"linkage" json:"linkages"`
	CreatedOn    string            `bson:"created_on" json:"created_on"`
	LastModified string            `bson:"last_modified" json:"last_modified"`
}

func CreateNodeUpload

func CreateNodeUpload(u *user.User, params map[string]string, files FormFiles) (node *Node, err error)

func Load

func Load(id string, uuid string) (n *Node, err error)

func LoadFromDisk

func LoadFromDisk(id string) (n *Node, err error)

func LoadUnauth

func LoadUnauth(id string) (n *Node, err error)

func New

func New() (node *Node)

func (*Node) Delete

func (node *Node) Delete() (err error)

func (*Node) FileExt

func (node *Node) FileExt() string

func (*Node) FilePath

func (node *Node) FilePath() string

func (*Node) FileReader

func (node *Node) FileReader() (reader file.ReaderAt, err error)

func (*Node) HasFile

func (node *Node) HasFile() bool

has

func (*Node) HasIndex

func (node *Node) HasIndex(index string) bool

func (*Node) HasParent

func (node *Node) HasParent() bool

func (*Node) Index

func (node *Node) Index(name string) (idx index.Index, err error)

Index functions

func (*Node) IndexPath

func (node *Node) IndexPath() string

func (*Node) Mkdir

func (node *Node) Mkdir() (err error)

func (*Node) Path

func (node *Node) Path() string

path

func (*Node) Rmdir

func (node *Node) Rmdir() (err error)

func (*Node) Save

func (node *Node) Save() (err error)

func (*Node) SetAttributes

func (node *Node) SetAttributes(attr FormFile) (err error)

func (*Node) SetFile

func (node *Node) SetFile(file FormFile) (err error)

func (*Node) SetFileFormat

func (node *Node) SetFileFormat(format string) (err error)

func (*Node) SetFileFromParts

func (node *Node) SetFileFromParts(p *partsList, allowEmpty bool) (err error)

func (*Node) SetFileFromPath

func (node *Node) SetFileFromPath(path string, action string) (err error)

func (*Node) SetIndexInfo

func (node *Node) SetIndexInfo(indextype string, idxinfo IdxInfo) (err error)

func (*Node) ToJson

func (node *Node) ToJson() (s string, err error)

func (*Node) Update

func (node *Node) Update(params map[string]string, files FormFiles) (err error)

Modification functions

func (*Node) UpdateDataTags

func (node *Node) UpdateDataTags(types string) (err error)

func (*Node) UpdateLinkages

func (node *Node) UpdateLinkages(ltype string, ids string, operation string) (err error)

func (*Node) UpdateVersion

func (node *Node) UpdateVersion() (err error)

type Nodes

type Nodes []*Node

Node array type

func LoadNodes

func LoadNodes(ids []string) (n Nodes, err error)

func (*Nodes) GetAll

func (n *Nodes) GetAll(q bson.M) (err error)

func (*Nodes) GetPaginated

func (n *Nodes) GetPaginated(q bson.M, limit int, offset int) (count int, err error)