tn

Documentation

Index

• func AddDefaultService(name string, s Service)
• type Break
  • func (B *Break) Error() string
• type CNode
  • func NewCNode(name string, sender Sender, s Handler) *CNode
  • func (N *CNode) Addr() string
  • func (N *CNode) Close() error
  • func (N *CNode) Handle(message *kk.Message) error
  • func (N *CNode) Match(name string) bool
  • func (N *CNode) Name() string
  • func (N *CNode) Priority() int
  • func (N *CNode) Send(message *kk.Message) error
• type Channel
• type Done
  • func (D *Done) Error() string
• type Handler
• type MNode
  • func (N *MNode) AddChidren(id int64, n Node) int64
  • func (N *MNode) AddParent(id int64, n Node)
  • func (N *MNode) Match(name string) bool
  • func (N *MNode) Name() string
  • func (N *MNode) NewId() int64
  • func (N *MNode) RemoveChidren(id int64)
  • func (N *MNode) RemoveParent(id int64)
  • func (N *MNode) Send(message *kk.Message, sender Sender) error
• type Node
• type NodeSet
  • func (N *NodeSet) AddNode(id int64, n Node)
  • func (N *NodeSet) RemoveNode(id int64)
  • func (N *NodeSet) Send(message *kk.Message) error
• type RService
  • func NewRService() *RService
  • func (S *RService) Handle(message *kk.Message, sender Sender) error
  • func (S *RService) Match(message *kk.Message) bool
  • func (S *RService) Send(sender Sender, to string, uri string, ctype string, data []byte, ...) (*kk.Response, error)
• type RespHandler
• type RespService
  • func NewRespService() *RespService
  • func (S *RespService) AddHandler(prefix string, handle func(req *kk.Request) (*kk.Response, error))
  • func (S *RespService) Handle(message *kk.Message, sender Sender) error
  • func (S *RespService) Match(message *kk.Message) bool
• type SNode
  • func (S *SNode) AddService(s Service)
  • func (S *SNode) Handle(message *kk.Message, sender Sender) error
• type Sender
• type Service
  • func GetDefaultService(name string) Service
• type TCPCNode
  • func NewTCPCNode(name string, addr string) *TCPCNode
  • func (N *TCPCNode) Addr() string
  • func (N *TCPCNode) Atime() time.Duration
  • func (N *TCPCNode) Close() error
  • func (N *TCPCNode) Handle(message *kk.Message, sender Sender) error
  • func (N *TCPCNode) Match(name string) bool
  • func (N *TCPCNode) Name() string
  • func (N *TCPCNode) Ping() time.Duration
  • func (N *TCPCNode) Priority() int
  • func (N *TCPCNode) Send(message *kk.Message) error
• type TCPChannel
  • func NewTCPChannel(conn net.Conn) *TCPChannel
  • func (C *TCPChannel) Addr() string
  • func (C *TCPChannel) Close() error
  • func (C *TCPChannel) Grow(size int)
  • func (C *TCPChannel) Read() (*kk.Message, error)
  • func (C *TCPChannel) Write(message *kk.Message) error
• type TCPMNode
  • func NewTCPMNode(name string, addr string) (*TCPMNode, error)
  • func (N *TCPMNode) Handle(message *kk.Message, sender Sender) error
  • func (N *TCPMNode) Run() error
• type Transport
  • func NewTransport(id int64, c Channel, s Handler, e chan int64) *Transport
  • func (T *Transport) Addr() string
  • func (T *Transport) Close() error
  • func (T *Transport) Send(message *kk.Message) error

Functions

func AddDefaultService

func AddDefaultService(name string, s Service)

Types

type Break

type Break struct {
}

func (*Break) Error

func (B *Break) Error() string

type CNode

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

func NewCNode

func NewCNode(name string, sender Sender, s Handler) *CNode

func (*CNode) Addr

func (N *CNode) Addr() string

func (*CNode) Close

func (N *CNode) Close() error

func (*CNode) Handle

func (N *CNode) Handle(message *kk.Message) error

func (*CNode) Match

func (N *CNode) Match(name string) bool

func (*CNode) Name

func (N *CNode) Name() string

func (*CNode) Priority

func (N *CNode) Priority() int

func (*CNode) Send

func (N *CNode) Send(message *kk.Message) error

type Channel

type Channel interface {
	Addr() string
	Read() (*kk.Message, error)
	Write(message *kk.Message) error
	Close() error
}

type Done

type Done struct {
}

func (*Done) Error

func (D *Done) Error() string

type Handler

type Handler interface {
	Handle(message *kk.Message, sender Sender) error
}

type MNode

type MNode struct {
	SNode
	// contains filtered or unexported fields
}

func (*MNode) AddChidren

func (N *MNode) AddChidren(id int64, n Node) int64

func (*MNode) AddParent

func (N *MNode) AddParent(id int64, n Node)

func (*MNode) Match

func (N *MNode) Match(name string) bool

func (*MNode) Name

func (N *MNode) Name() string

func (*MNode) NewId

func (N *MNode) NewId() int64

func (*MNode) RemoveChidren

func (N *MNode) RemoveChidren(id int64)

func (*MNode) RemoveParent

func (N *MNode) RemoveParent(id int64)

func (*MNode) Send

func (N *MNode) Send(message *kk.Message, sender Sender) error

type Node

type Node interface {
	Name() string
	Match(name string) bool
	Send(message *kk.Message) error
	Priority() int
}

type NodeSet

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

func (*NodeSet) AddNode

func (N *NodeSet) AddNode(id int64, n Node)

func (*NodeSet) RemoveNode

func (N *NodeSet) RemoveNode(id int64)

func (*NodeSet) Send

func (N *NodeSet) Send(message *kk.Message) error

type RService

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

func NewRService

func NewRService() *RService

func (*RService) Handle

func (S *RService) Handle(message *kk.Message, sender Sender) error

func (*RService) Match

func (S *RService) Match(message *kk.Message) bool

func (*RService) Send

func (S *RService) Send(sender Sender, to string, uri string, ctype string, data []byte, header map[string]string, timeout time.Duration) (*kk.Response, error)

type RespHandler

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

type RespService

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

func NewRespService

func NewRespService() *RespService

func (*RespService) AddHandler

func (S *RespService) AddHandler(prefix string, handle func(req *kk.Request) (*kk.Response, error))

func (*RespService) Handle

func (S *RespService) Handle(message *kk.Message, sender Sender) error

func (*RespService) Match

func (S *RespService) Match(message *kk.Message) bool

type SNode

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

func (*SNode) AddService

func (S *SNode) AddService(s Service)

func (*SNode) Handle

func (S *SNode) Handle(message *kk.Message, sender Sender) error

type Sender

type Sender interface {
	Addr() string
	Send(message *kk.Message) error
	Close() error
}

type Service

type Service interface {
	Match(message *kk.Message) bool
	Handle(message *kk.Message, sender Sender) error
}

func GetDefaultService

func GetDefaultService(name string) Service

type TCPCNode

type TCPCNode struct {
	SNode
	// contains filtered or unexported fields
}

func NewTCPCNode

func NewTCPCNode(name string, addr string) *TCPCNode

func (*TCPCNode) Addr

func (N *TCPCNode) Addr() string

func (*TCPCNode) Atime

func (N *TCPCNode) Atime() time.Duration

func (*TCPCNode) Close

func (N *TCPCNode) Close() error

func (*TCPCNode) Handle

func (N *TCPCNode) Handle(message *kk.Message, sender Sender) error

func (*TCPCNode) Match

func (N *TCPCNode) Match(name string) bool

func (*TCPCNode) Name

func (N *TCPCNode) Name() string

func (*TCPCNode) Ping

func (N *TCPCNode) Ping() time.Duration

func (*TCPCNode) Priority

func (N *TCPCNode) Priority() int

func (*TCPCNode) Send

func (N *TCPCNode) Send(message *kk.Message) error

type TCPChannel

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

func NewTCPChannel

func NewTCPChannel(conn net.Conn) *TCPChannel

func (*TCPChannel) Addr

func (C *TCPChannel) Addr() string

func (*TCPChannel) Close

func (C *TCPChannel) Close() error

func (*TCPChannel) Grow

func (C *TCPChannel) Grow(size int)

func (*TCPChannel) Read

func (C *TCPChannel) Read() (*kk.Message, error)

func (*TCPChannel) Write

func (C *TCPChannel) Write(message *kk.Message) error

type TCPMNode

type TCPMNode struct {
	MNode
	// contains filtered or unexported fields
}

func NewTCPMNode

func NewTCPMNode(name string, addr string) (*TCPMNode, error)

func (*TCPMNode) Handle

func (N *TCPMNode) Handle(message *kk.Message, sender Sender) error

func (*TCPMNode) Run

func (N *TCPMNode) Run() error

type Transport

type Transport struct {
	Id int64
	// contains filtered or unexported fields
}

func NewTransport

func NewTransport(id int64, c Channel, s Handler, e chan int64) *Transport

func (*Transport) Addr

func (T *Transport) Addr() string

func (*Transport) Close

func (T *Transport) Close() error

func (*Transport) Send

func (T *Transport) Send(message *kk.Message) error