client

Documentation

Index

• Variables
• func UUID() (string, error)
• type Client
  • func New(config *Config) (*Client, error)
  • func (client *Client) Call(serviceMethod string, args interface{}, reply interface{}) error
  • func (client *Client) Close() error
  • func (client *Client) Go(serviceMethod string, args interface{}, reply interface{}, done chan *rpc.Call) *rpc.Call
• type Config
• type Dispatcher
• type DispatcherFunc
  • func (fn DispatcherFunc) Dispatch(events []*signaling.Event)
• type Node
  • func NewNode(config *Config) (*Node, error)
  • func (n *Node) Room() string
  • func (n *Node) Send(ev *signaling.Event) error
  • func (n *Node) Start(owner bool, dispatchers ...Dispatcher) error
  • func (n *Node) Stop() error
  • func (n *Node) User() string

Variables

var (

	// None ...
	None = &noneVal
	// DefaultSignalingServer ...
	DefaultSignalingServer = "wss://signaling.arsahosting.com/ws"
)

Functions

func UUID

func UUID() (string, error)

UUID generates a random UUID according to RFC 4122

Types

type Client

type Client struct {
	sync.RWMutex
	*rpc.Client
	// contains filtered or unexported fields
}

Client ...

func New

func New(config *Config) (*Client, error)

New ...

func (*Client) Call

func (client *Client) Call(serviceMethod string, args interface{}, reply interface{}) error

Call ...

func (*Client) Close

func (client *Client) Close() error

Close ...

func (*Client) Go

func (client *Client) Go(serviceMethod string, args interface{}, reply interface{}, done chan *rpc.Call) *rpc.Call

Go ...

type Config

type Config struct {
	signaling.Request
	URL    string
	Origin string
}

Config ...

type Dispatcher

type Dispatcher interface {
	Dispatch([]*signaling.Event)
}

Dispatcher ...

type DispatcherFunc

type DispatcherFunc func([]*signaling.Event)

DispatcherFunc ...

func (DispatcherFunc) Dispatch

func (fn DispatcherFunc) Dispatch(events []*signaling.Event)

Dispatch ...

type Node

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

Node ...

func NewNode

func NewNode(config *Config) (*Node, error)

NewNode ...

func (*Node) Room

func (n *Node) Room() string

Room ...

func (*Node) Send

func (n *Node) Send(ev *signaling.Event) error

Send ...

func (*Node) Start

func (n *Node) Start(owner bool, dispatchers ...Dispatcher) error

Start ...

func (*Node) Stop

func (n *Node) Stop() error

Stop ...

func (*Node) User

func (n *Node) User() string

User ...