tree

Documentation

Index

• type INode
  • func NewINode() *INode
  • func (d *INode) AddNode(node *Node)
  • func (d *INode) Insert(topic topic.Topic, tenant string, subscription *pb.Metadata)
  • func (d *INode) Remove(tenant, id string, topic topic.Topic) error
  • func (d *INode) Select(tenant string, set []*pb.Metadata, topic topic.Topic) []*pb.Metadata
• type Node
  • func NewNode(tenant string, pattern []byte) *Node
  • func (n *Node) AddSubscription(tenant string, subscription *pb.Metadata) *Node
  • func (n *Node) DelSubscription(id string) *Node

Types

type INode

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

func NewINode

func NewINode() *INode

func (*INode) AddNode

func (d *INode) AddNode(node *Node)

func (*INode) Insert

func (d *INode) Insert(topic topic.Topic, tenant string, subscription *pb.Metadata)

func (*INode) Remove

func (d *INode) Remove(tenant, id string, topic topic.Topic) error

func (*INode) Select

func (d *INode) Select(tenant string, set []*pb.Metadata, topic topic.Topic) []*pb.Metadata

type Node

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

func NewNode

func NewNode(tenant string, pattern []byte) *Node

func (*Node) AddSubscription

func (n *Node) AddSubscription(tenant string, subscription *pb.Metadata) *Node

func (*Node) DelSubscription

func (n *Node) DelSubscription(id string) *Node