nprotoo

type AcceptFunc ¶

type AcceptFunc func(data RawMessage)

AcceptFunc .

type BroadCastFunc ¶

type BroadCastFunc func(data Notification, subj string)

BroadCastFunc .

type Broadcaster ¶

type Broadcaster struct {
	emission.Emitter
	// contains filtered or unexported fields
}

Broadcaster .

func (bc *Broadcaster) Say(method string, data interface{})

type CommonData ¶

type CommonData struct {
	ID     int        `json:"id"`
	Method string     `json:"method"`
	Data   RawMessage `json:"data"`
}

type Error ¶

type Error struct {
	Code   int
	Reason string
}

Error .

func (e Error) Error() string

type Future ¶

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

Future .

func NewFuture() *Future

func (future *Future) Await() (RawMessage, *Error)

func (future *Future) Then(resolve func(result RawMessage), reject func(err *Error))

type NatsProtoo ¶

type NatsProtoo struct {
	emission.Emitter
	// contains filtered or unexported fields
}

NatsProtoo .

func NewNatsProtoo(server string) *NatsProtoo

func (np *NatsProtoo) Close()

func (np *NatsProtoo) NewBroadcaster(channel string) *Broadcaster

func (np *NatsProtoo) NewRequestor(channel string) *Requestor

func (np *NatsProtoo) OnBroadcast(channel string, listener BroadCastFunc)

func (np *NatsProtoo) OnRequest(channel string, listener RequestFunc)

func (np *NatsProtoo) Reply(message []byte, reply string) error

func (np *NatsProtoo) Send(message []byte, subj string, reply string) error

type Notification ¶

type Notification struct {
	CommonData
	NotificationData
}

* Notification

{
  notification : true,
  method       : 'chatmessage',
  data         :
  {
    foo : 'bar'
  }
}

type NotificationData ¶

type NotificationData struct {
	Notification bool `json:"notification"`
}

type PeerMsg ¶

type PeerMsg struct {
	RequestData
	ResponseData
	NotificationData
	CommonData
}

func (m PeerMsg) ToNotification() Notification

func (m PeerMsg) ToRequest() Request

type RawMessage ¶

type RawMessage []byte

func (m RawMessage) MarshalJSON() ([]byte, error)

func (r RawMessage) Unmarshal(msgType interface{}) *Error

func (m *RawMessage) UnmarshalJSON(data []byte) error

type RejectFunc ¶

type RejectFunc func(errorCode int, errorReason string)

RejectFunc .

type Request ¶

type Request struct {
	RequestData
	CommonData
}

* Request

{
  request : true,
  id      : 12345678,
  method  : 'chatmessage',
  data    :
  {
    type  : 'text',
    value : 'Hi there!'
  }
}

type RequestData ¶

type RequestData struct {
	Request   bool   `json:"request"`
	ReplySubj string `json:"reply"`
}

type RequestFunc ¶

type RequestFunc func(request Request, accept RespondFunc, reject RejectFunc)

RequestFunc .

type Requestor ¶

type Requestor struct {
	emission.Emitter
	// contains filtered or unexported fields
}

Requestor .

func (req *Requestor) AsyncRequest(method string, data interface{}) *Future

func (req *Requestor) Request(method string, data interface{}, success AcceptFunc, reject RejectFunc)

func (req *Requestor) SetRequestTimeout(d time.Duration)

func (req *Requestor) SyncRequest(method string, data interface{}) (RawMessage, *Error)

type RespondFunc ¶

type RespondFunc func(data interface{})

type Response ¶

type Response struct {
	ResponseData
	CommonData
}

* Success response

{
	response : true,
	id       : 12345678,
	ok       : true,
	data     :
	{
	  foo : 'lalala'
	}
}

func NewResponse(id int, data interface{}) (*Response, error)

func NewResponseErr(id int, errorCode int, errorReason string) *Response

type ResponseData ¶

type ResponseData struct {
	Response bool `json:"response"`
	Ok       bool `json:"ok"`
	ResponseErrData
}

type ResponseErrData ¶

type ResponseErrData struct {
	ErrorCode   int    `json:"errorCode"`
	ErrorReason string `json:"errorReason"`
}

type ResponseError ¶

type ResponseError struct {
	ResponseData
	CommonData
}

* Error response

{
  response    : true,
  id          : 12345678,
  ok          : false,
  errorCode   : 123,
  errorReason : 'Something failed'
}

type Transcation ¶

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

Transcation .