astiws

README

// TODO

Documentation

Index

• Constants
• type BodyMessage
• type BodyMessageRead
• type Client
  • func NewClient(c ClientConfiguration, l astikit.StdLogger) *Client
  • func NewClientWithContext(ctx context.Context, cfg ClientConfiguration, l astikit.StdLogger) (c *Client)
  • func (c *Client) AddListener(eventName string, f ListenerFunc)
  • func (c *Client) Close() error
  • func (c *Client) CloseWithCode(closeCode int) (err error)
  • func (c *Client) Context() context.Context
  • func (c *Client) DelListener(eventName string)
  • func (c *Client) Dial(addr string) error
  • func (c *Client) DialAndRead(w *astikit.Worker, o DialAndReadOptions)
  • func (c *Client) DialWithHeaders(addr string, h http.Header) (err error)
  • func (c *Client) ExtendConnection() error
  • func (c *Client) Read() error
  • func (c *Client) SetListener(eventName string, f ListenerFunc)
  • func (c *Client) SetMessageHandler(h MessageHandler)
  • func (c *Client) WithContext(ctx context.Context) *Client
  • func (c *Client) Write(eventName string, payload interface{}) error
  • func (c *Client) WriteJSON(m interface{}) (err error)
  • func (c *Client) WriteText(m []byte) (err error)
• type ClientAdapter
• type ClientConfiguration
• type DialAndReadOptions
• type ListenerFunc
• type MessageHandler
• type OnServeError
• type Server
  • func NewServer(o ServerOptions) *Server
  • func (s *Server) Clients() []*Client
  • func (s *Server) Close() error
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ServerOptions

Constants

const (
	EventNameDisconnect = "astiws.disconnect"
)

Constants

Types

type BodyMessage

type BodyMessage struct {
	EventName string      `json:"event_name"`
	Payload   interface{} `json:"payload"`
}

BodyMessage represents the body of a message

type BodyMessageRead

type BodyMessageRead struct {
	BodyMessage
	Payload json.RawMessage `json:"payload"`
}

BodyMessageRead represents the body of a message for read purposes Indeed when reading the body, we need the payload to be a json.RawMessage

type Client

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

Client represents a websocket client

func NewClient

func NewClient(c ClientConfiguration, l astikit.StdLogger) *Client

NewClient creates a new client

func NewClientWithContext

func NewClientWithContext(ctx context.Context, cfg ClientConfiguration, l astikit.StdLogger) (c *Client)

NewClientWithContext creates a new client with a context

func (*Client) AddListener

func (c *Client) AddListener(eventName string, f ListenerFunc)

AddListener adds a listener

func (*Client) Close

func (c *Client) Close() error

Close closes the client properly

func (*Client) CloseWithCode

func (c *Client) CloseWithCode(closeCode int) (err error)

CloseWithCode closes the client with a specific code

func (*Client) Context

func (c *Client) Context() context.Context

Context return the client's context

func (*Client) DelListener

func (c *Client) DelListener(eventName string)

DelListener deletes a listener

func (*Client) Dial

func (c *Client) Dial(addr string) error

Dial dials an addr

func (*Client) DialAndRead

func (c *Client) DialAndRead(w *astikit.Worker, o DialAndReadOptions)

DialAndReadOptions dials and read with options It's the responsibility of the caller to close the Client

func (*Client) DialWithHeaders

func (c *Client) DialWithHeaders(addr string, h http.Header) (err error)

DialWithHeader dials an addr with specific headers

func (*Client) ExtendConnection

func (c *Client) ExtendConnection() error

ExtendConnection extends the connection

func (*Client) Read

func (c *Client) Read() error

Read reads from the client

func (*Client) SetListener

func (c *Client) SetListener(eventName string, f ListenerFunc)

SetListener sets a listener

func (*Client) SetMessageHandler

func (c *Client) SetMessageHandler(h MessageHandler)

SetMessageHandler sets the message handler

func (*Client) WithContext

func (c *Client) WithContext(ctx context.Context) *Client

WithContext updates the client's context

func (*Client) Write

func (c *Client) Write(eventName string, payload interface{}) error

Write writes a message to the client

func (*Client) WriteJSON

func (c *Client) WriteJSON(m interface{}) (err error)

WriteJSON writes a JSON message to the client

func (*Client) WriteText

func (c *Client) WriteText(m []byte) (err error)

WriteText writes a text message to the client

type ClientAdapter

type ClientAdapter func(c *Client) error

type ClientConfiguration

type ClientConfiguration struct {
	MaxMessageSize int `toml:"max_message_size"`
	// Timeout after which connections are closed. If Timeout <= 0, default timeout is used.
	Timeout time.Duration `toml:"timeout"`
}

ClientConfiguration represents a client configuration

type DialAndReadOptions

type DialAndReadOptions struct {
	Addr        string
	Header      http.Header
	OnDial      func() error
	OnReadError func(err error)
}

DialAndReadOptions represents dial and read options

type ListenerFunc

type ListenerFunc func(c *Client, eventName string, payload json.RawMessage) error

ListenerFunc represents a listener callback

type MessageHandler

type MessageHandler func(m []byte) error

MessageHandler represents a message handler

type OnServeError

type OnServeError func(*Client, error)

type Server

type Server struct {
	Upgrader websocket.Upgrader
	// contains filtered or unexported fields
}

func NewServer

func NewServer(o ServerOptions) *Server

func (*Server) Clients

func (s *Server) Clients() []*Client

func (*Server) Close

func (s *Server) Close() error

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ServerOptions

type ServerOptions struct {
	CheckOrigin    func(r *http.Request) bool
	ClientAdapter  ClientAdapter
	Logger         astikit.StdLogger
	MaxMessageSize int
	OnServeError   OnServeError
	Timeout        time.Duration
}