node

Documentation

Index

• type Node
  • func New(int63n func(n int64) int64) *Node
  • func (n *Node) AddChild(key uint64) *Node
  • func (n *Node) AddSubscription(s func(interface{}), shardID, deterministicRoutingName string) int64
  • func (n *Node) ChildLen() int
  • func (n *Node) DeleteChild(key uint64)
  • func (n *Node) DeleteSubscription(id int64)
  • func (n *Node) FetchChild(key uint64) *Node
  • func (n *Node) ForEachSubscription(f func(shardID string, isDeterministic bool, s []SubscriptionEnvelope))
  • func (n *Node) SubscriptionLen() int
• type SubscriptionEnvelope

Types

type Node

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

func New

func New(int63n func(n int64) int64) *Node

func (*Node) AddChild

func (n *Node) AddChild(key uint64) *Node

func (*Node) AddSubscription

func (n *Node) AddSubscription(s func(interface{}), shardID, deterministicRoutingName string) int64

func (*Node) ChildLen

func (n *Node) ChildLen() int

func (*Node) DeleteChild

func (n *Node) DeleteChild(key uint64)

func (*Node) DeleteSubscription

func (n *Node) DeleteSubscription(id int64)

func (*Node) FetchChild

func (n *Node) FetchChild(key uint64) *Node

func (*Node) ForEachSubscription

func (n *Node) ForEachSubscription(f func(shardID string, isDeterministic bool, s []SubscriptionEnvelope))

func (*Node) SubscriptionLen

func (n *Node) SubscriptionLen() int

type SubscriptionEnvelope

type SubscriptionEnvelope struct {
	Subscription func(interface{})
	// contains filtered or unexported fields
}