action

Documentation

Index

• Variables
• func ConstructTxCmdPacket(tnp *transact.TransNodeParam, cmd transact.TransCmd) proto.Message
• func ContructTxResultPacket(parent, me *transact.TransNodeParam, tr *transact.TransResult) proto.Message
• func ContructTxStartPacket(parent, me *transact.TransNodeParam, ud interface{}) proto.Message
• type PacketSlicesHandler
  • func (this *PacketSlicesHandler) Process(s *netlib.Session, packetid int, data interface{}) error
• type PacketSlicesPacketFactory
  • func (this *PacketSlicesPacketFactory) CreatePacket() interface{}
• type TxCtrlCmdHandler
  • func (this *TxCtrlCmdHandler) Process(session *netlib.Session, packetid int, data interface{}) error
• type TxCtrlCmdPacketFactory
  • func (this *TxCtrlCmdPacketFactory) CreatePacket() interface{}
• type TxResultHandler
  • func (this *TxResultHandler) Process(session *netlib.Session, packetid int, data interface{}) error
• type TxResultPacketFactory
  • func (this *TxResultPacketFactory) CreatePacket() interface{}
• type TxStartHandler
  • func (this *TxStartHandler) Process(session *netlib.Session, packetid int, data interface{}) error
• type TxStartPacketFactory
  • func (this *TxStartPacketFactory) CreatePacket() interface{}

Variables

var (
	SessionAttributeBigBuf = &PacketSlicesHandler{}
)

Functions

func ConstructTxCmdPacket

func ConstructTxCmdPacket(tnp *transact.TransNodeParam, cmd transact.TransCmd) proto.Message

func ContructTxResultPacket

func ContructTxResultPacket(parent, me *transact.TransNodeParam, tr *transact.TransResult) proto.Message

func ContructTxStartPacket

func ContructTxStartPacket(parent, me *transact.TransNodeParam, ud interface{}) proto.Message

Types

type PacketSlicesHandler

type PacketSlicesHandler struct {
}

func (*PacketSlicesHandler) Process

func (this *PacketSlicesHandler) Process(s *netlib.Session, packetid int, data interface{}) error

type PacketSlicesPacketFactory

type PacketSlicesPacketFactory struct {
}

func (*PacketSlicesPacketFactory) CreatePacket

func (this *PacketSlicesPacketFactory) CreatePacket() interface{}

type TxCtrlCmdHandler

type TxCtrlCmdHandler struct {
}

func (*TxCtrlCmdHandler) Process

func (this *TxCtrlCmdHandler) Process(session *netlib.Session, packetid int, data interface{}) error

type TxCtrlCmdPacketFactory

type TxCtrlCmdPacketFactory struct {
}

func (*TxCtrlCmdPacketFactory) CreatePacket

func (this *TxCtrlCmdPacketFactory) CreatePacket() interface{}

type TxResultHandler

type TxResultHandler struct {
}

func (*TxResultHandler) Process

func (this *TxResultHandler) Process(session *netlib.Session, packetid int, data interface{}) error

type TxResultPacketFactory

type TxResultPacketFactory struct {
}

func (*TxResultPacketFactory) CreatePacket

func (this *TxResultPacketFactory) CreatePacket() interface{}

type TxStartHandler

type TxStartHandler struct {
}

func (*TxStartHandler) Process

func (this *TxStartHandler) Process(session *netlib.Session, packetid int, data interface{}) error

type TxStartPacketFactory

type TxStartPacketFactory struct {
}

func (*TxStartPacketFactory) CreatePacket

func (this *TxStartPacketFactory) CreatePacket() interface{}