services

Documentation

Index

• type GetNodeByPathResponseInfoWrapper
  • func (n GetNodeByPathResponseInfoWrapper) GetMeta() []tree.Meta
  • func (n GetNodeByPathResponseInfoWrapper) GetNodeID() uint64
  • func (n GetNodeByPathResponseInfoWrapper) GetParentID() uint64
  • func (n GetNodeByPathResponseInfoWrapper) GetTimestamp() uint64
• type GetSubTreeResponseBodyWrapper
  • func (n GetSubTreeResponseBodyWrapper) GetMeta() []tree.Meta
  • func (n GetSubTreeResponseBodyWrapper) GetNodeID() uint64
  • func (n GetSubTreeResponseBodyWrapper) GetParentID() uint64
  • func (n GetSubTreeResponseBodyWrapper) GetTimestamp() uint64
• type PoolWrapper
  • func NewPoolWrapper(p *treepool.Pool) *PoolWrapper
  • func (w *PoolWrapper) AddNode(ctx context.Context, bktInfo *data.BucketInfo, treeID string, parent uint64, ...) (uint64, error)
  • func (w *PoolWrapper) AddNodeByPath(ctx context.Context, bktInfo *data.BucketInfo, treeID string, path []string, ...) (uint64, error)
  • func (w *PoolWrapper) GetNodes(ctx context.Context, prm *tree.GetNodesParams) ([]tree.NodeResponse, error)
  • func (w *PoolWrapper) GetSubTree(ctx context.Context, bktInfo *data.BucketInfo, treeID string, rootID uint64, ...) ([]tree.NodeResponse, error)
  • func (w *PoolWrapper) GetSubTreeStream(ctx context.Context, bktInfo *data.BucketInfo, treeID string, rootID uint64, ...) (tree.SubTreeStream, error)
  • func (w *PoolWrapper) MoveNode(ctx context.Context, bktInfo *data.BucketInfo, treeID string, ...) error
  • func (w *PoolWrapper) RemoveNode(ctx context.Context, bktInfo *data.BucketInfo, treeID string, nodeID uint64) error
• type SubTreeStreamImpl
  • func (s *SubTreeStreamImpl) Next() (tree.NodeResponse, error)

Types

type GetNodeByPathResponseInfoWrapper

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

func (GetNodeByPathResponseInfoWrapper) GetMeta

func (n GetNodeByPathResponseInfoWrapper) GetMeta() []tree.Meta

func (GetNodeByPathResponseInfoWrapper) GetNodeID

func (n GetNodeByPathResponseInfoWrapper) GetNodeID() uint64

func (GetNodeByPathResponseInfoWrapper) GetParentID

func (n GetNodeByPathResponseInfoWrapper) GetParentID() uint64

func (GetNodeByPathResponseInfoWrapper) GetTimestamp

func (n GetNodeByPathResponseInfoWrapper) GetTimestamp() uint64

type GetSubTreeResponseBodyWrapper

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

func (GetSubTreeResponseBodyWrapper) GetMeta

func (n GetSubTreeResponseBodyWrapper) GetMeta() []tree.Meta

func (GetSubTreeResponseBodyWrapper) GetNodeID

func (n GetSubTreeResponseBodyWrapper) GetNodeID() uint64

func (GetSubTreeResponseBodyWrapper) GetParentID

func (n GetSubTreeResponseBodyWrapper) GetParentID() uint64

func (GetSubTreeResponseBodyWrapper) GetTimestamp

func (n GetSubTreeResponseBodyWrapper) GetTimestamp() uint64

type PoolWrapper

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

func NewPoolWrapper

func NewPoolWrapper(p *treepool.Pool) *PoolWrapper

func (*PoolWrapper) AddNode

func (w *PoolWrapper) AddNode(ctx context.Context, bktInfo *data.BucketInfo, treeID string, parent uint64, meta map[string]string) (uint64, error)

func (*PoolWrapper) AddNodeByPath

func (w *PoolWrapper) AddNodeByPath(ctx context.Context, bktInfo *data.BucketInfo, treeID string, path []string, meta map[string]string) (uint64, error)

func (*PoolWrapper) GetNodes

func (w *PoolWrapper) GetNodes(ctx context.Context, prm *tree.GetNodesParams) ([]tree.NodeResponse, error)

func (*PoolWrapper) GetSubTree

func (w *PoolWrapper) GetSubTree(ctx context.Context, bktInfo *data.BucketInfo, treeID string, rootID uint64, depth uint32) ([]tree.NodeResponse, error)

func (*PoolWrapper) GetSubTreeStream

func (w *PoolWrapper) GetSubTreeStream(ctx context.Context, bktInfo *data.BucketInfo, treeID string, rootID uint64, depth uint32) (tree.SubTreeStream, error)

func (*PoolWrapper) MoveNode

func (w *PoolWrapper) MoveNode(ctx context.Context, bktInfo *data.BucketInfo, treeID string, nodeID, parentID uint64, meta map[string]string) error

func (*PoolWrapper) RemoveNode

func (w *PoolWrapper) RemoveNode(ctx context.Context, bktInfo *data.BucketInfo, treeID string, nodeID uint64) error

type SubTreeStreamImpl

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

func (*SubTreeStreamImpl) Next

func (s *SubTreeStreamImpl) Next() (tree.NodeResponse, error)