server

Documentation

Index

• type Item
• type MessageServer
  • func NewMsgServer(network ServerService, name string, requestLifetime time.Duration) *MessageServer
  • func (p *MessageServer) Close()
  • func (p *MessageServer) RegisterMsgHandler(msgType MessageType, reqHandler func(msg []byte) []byte)
  • func (p *MessageServer) SendAsyncRequest(msgType MessageType, payload []byte, address crypto.PublicKey, ...) error
  • func (p *MessageServer) SendRequest(msgType MessageType, payload []byte, address crypto.PublicKey, ...) (interface{}, error)
• type MessageType
• type ServerMessage
• type ServerService

Types

type Item

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

type MessageServer

type MessageServer struct {
	ReqId uint64 //request id
	// contains filtered or unexported fields
}

func NewMsgServer

func NewMsgServer(network ServerService, name string, requestLifetime time.Duration) *MessageServer

func (*MessageServer) Close

func (p *MessageServer) Close()

func (*MessageServer) RegisterMsgHandler

func (p *MessageServer) RegisterMsgHandler(msgType MessageType, reqHandler func(msg []byte) []byte)

func (*MessageServer) SendAsyncRequest

func (p *MessageServer) SendAsyncRequest(msgType MessageType, payload []byte, address crypto.PublicKey, resHandler func(msg []byte)) error

func (*MessageServer) SendRequest

func (p *MessageServer) SendRequest(msgType MessageType, payload []byte, address crypto.PublicKey, timeout time.Duration) (interface{}, error)

type MessageType

type MessageType uint32

type ServerMessage

type ServerMessage interface {
	service.Message
	Data() *service.DataMsgWrapper
}

type ServerService

type ServerService interface {
	service.Service
	SendWrappedMessage(nodeID string, protocol string, payload *service.DataMsgWrapper) error
}