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 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) (err error)
  • func (node *Node) SetFileFromPath(path 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 DB *mgo.Collection

var (
	LockMgr = NewLocker()
)

Functions

func Initialize

func Initialize()

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 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"`
	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"`
}

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) (err error)

func (*Node) SetFileFromPath

func (node *Node) SetFileFromPath(path 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)