realTime

Documentation

Index

• Variables
• func DialLocalhost(_ context.Context, _, _ string) (net.Conn, error)
• func DialUnix(_ context.Context, _, _ string) (net.Conn, error)
• type Client
  • func (c *Client) AnnounceClose() error
  • func (c *Client) Close()
  • func (c *Client) CloseWrite() error
  • func (c *Client) Connect(ctx context.Context, uri *url.URL, bootstrap string, dial ConnectFn) (*types.RPCResponse, error)
  • func (c *Client) On(name sharedTypes.EditorEventMessage, fn func(response types.RPCResponse))
  • func (c *Client) Ping() error
  • func (c *Client) RPC(res *types.RPCResponse, r *types.RPCRequest) error
  • func (c *Client) RPCAsyncRead(r *types.RPCRequest) error
  • func (c *Client) RPCAsyncWrite(res *types.RPCResponse, r *types.RPCRequest) error
  • func (c *Client) ReadOnce() error
  • func (c *Client) SetDeadline(d time.Time) error
  • func (c *Client) StartHealthCheck() error
• type ConnectFn

Variables

var UnixRunRealTime = &net.UnixAddr{
	Net:  "unix",
	Name: "/tmp/real-time.socket",
}

Functions

func DialLocalhost

func DialLocalhost(_ context.Context, _, _ string) (net.Conn, error)

func DialUnix

func DialUnix(_ context.Context, _, _ string) (net.Conn, error)

Types

type Client

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

func (*Client) AnnounceClose

func (c *Client) AnnounceClose() error

func (*Client) Close

func (c *Client) Close()

func (*Client) CloseWrite

func (c *Client) CloseWrite() error

func (*Client) Connect

func (c *Client) Connect(ctx context.Context, uri *url.URL, bootstrap string, dial ConnectFn) (*types.RPCResponse, error)

func (*Client) On

func (c *Client) On(name sharedTypes.EditorEventMessage, fn func(response types.RPCResponse))

func (*Client) Ping

func (c *Client) Ping() error

func (*Client) RPC

func (c *Client) RPC(res *types.RPCResponse, r *types.RPCRequest) error

func (*Client) RPCAsyncRead

func (c *Client) RPCAsyncRead(r *types.RPCRequest) error

func (*Client) RPCAsyncWrite

func (c *Client) RPCAsyncWrite(res *types.RPCResponse, r *types.RPCRequest) error

func (*Client) ReadOnce

func (c *Client) ReadOnce() error

func (*Client) SetDeadline

func (c *Client) SetDeadline(d time.Time) error

func (*Client) StartHealthCheck

func (c *Client) StartHealthCheck() error

type ConnectFn

type ConnectFn = func(ctx context.Context, network, addr string) (net.Conn, error)