action

Documentation

Index

• type BaseAction
  • func (this *BaseAction) PrepareSend(connectPeerId string, data interface{}, targetPeerId string) *entity.ChainMessage
  • func (this *BaseAction) Receive(chainMessage *entity.ChainMessage) (*entity.ChainMessage, error)
  • func (this *BaseAction) Response(chainMessage *entity.ChainMessage) error
  • func (this *BaseAction) Send(chainMessage *entity.ChainMessage) (*entity.ChainMessage, error)

Types

type BaseAction

type BaseAction struct {
	MsgType string
}

func (*BaseAction) PrepareSend

func (this *BaseAction) PrepareSend(connectPeerId string, data interface{}, targetPeerId string) *entity.ChainMessage

func (*BaseAction) Receive

func (this *BaseAction) Receive(chainMessage *entity.ChainMessage) (*entity.ChainMessage, error)

* 接收消息进行处理，返回为空则没有返回消息，否则，有返回消息

func (*BaseAction) Response

func (this *BaseAction) Response(chainMessage *entity.ChainMessage) error

* 处理返回消息

func (*BaseAction) Send

func (this *BaseAction) Send(chainMessage *entity.ChainMessage) (*entity.ChainMessage, error)

* 主动发送消息