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
}

Node ...

func New

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

New ...

func (*Node) AddChild

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

AddChild ...

func (*Node) AddSubscription

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

AddSubscription ...

func (*Node) ChildLen

func (n *Node) ChildLen() int

ChildLen ...

func (*Node) DeleteChild

func (n *Node) DeleteChild(key uint64)

DeleteChild ...

func (*Node) DeleteSubscription

func (n *Node) DeleteSubscription(id int64)

DeleteSubscription ...

func (*Node) FetchChild

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

FetchChild ...

func (*Node) ForEachSubscription

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

ForEachSubscription ...

func (*Node) SubscriptionLen

func (n *Node) SubscriptionLen() int

SubscriptionLen ...

type SubscriptionEnvelope

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