peer

type AcceptFunc func(data json.RawMessage)

type Notification struct {
	Notification bool            `json:"notification"`
	Method       string          `json:"method"`
	Data         json.RawMessage `json:"data"`
}

type Peer struct {
	PeerChans
	// contains filtered or unexported fields
}

type PeerChans struct {
	OnRequest      chan RequestData
	SendRequest    chan SendRequestData
	OnNotification chan Notification
	OnClose        chan transport.TransportErr
	OnError        chan transport.TransportErr
}

type PeerErr transport.TransportErr

type PeerMsg struct {
	Request      bool `json:"request"`
	Response     bool `json:"response"`
	Ok           bool `json:"ok"`
	Notification bool `json:"notification"`
}

type RejectFunc func(errorCode int, errorReason string)

type Request struct {
	Request bool            `json:"request"`
	Id      int             `json:"id"`
	Method  string          `json:"method"`
	Data    json.RawMessage `json:"data"`
}

type RequestData struct {
	Accept  RespondFunc
	Reject  RejectFunc
	Request Request
}

type RespondFunc func(data interface{})

type Response struct {
	Response bool            `json:"response"`
	Id       int             `json:"id"`
	Ok       bool            `json:"ok"`
	Data     json.RawMessage `json:"data"`
}

type ResponseError struct {
	Response    bool   `json:"response"`
	Id          int    `json:"id"`
	Ok          bool   `json:"ok"`
	ErrorCode   int    `json:"errorCode"`
	ErrorReason string `json:"errorReason"`
}

type ResultFuture struct {
	Result json.RawMessage
	Err    *PeerErr
}

type SendRequestData struct {
	*Request
	*Transcation
}

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