fastws

Documentation

Index

• func MustNew(opts ...Option) *bundle
• func New(opts ...Option) (*bundle, error)
• type Option
  • func Listen(protoAddr string) Option
  • func WithCustomRPC(in ronykit.IncomingRPCFactory, out ronykit.OutgoingRPCFactory) Option
  • func WithLogger(l ronykit.Logger) Option
  • func WithPredicateKey(key string) Option
• type Selector
  • func RPC(predicate string) Selector
  • func (r Selector) GetEncoding() ronykit.Encoding
  • func (r Selector) GetPredicate() string
  • func (r Selector) Query(q string) interface{}
  • func (r *Selector) SetEncoding(enc ronykit.Encoding) *Selector
• type SwitchProtocol
  • func (sp *SwitchProtocol) Upgrade(conn io.ReadWriter) (hs ws.Handshake, err error)

Functions

func MustNew

func MustNew(opts ...Option) *bundle

func New

func New(opts ...Option) (*bundle, error)

Types

type Option

type Option func(b *bundle)

func Listen

func Listen(protoAddr string) Option

func WithCustomRPC

func WithCustomRPC(in ronykit.IncomingRPCFactory, out ronykit.OutgoingRPCFactory) Option

WithCustomRPC lets you define your RPC message container. RPC message container will be represented as Envelope in your application. RPCContainer only defines the behavior of serialization and deserialization of the Envelope.

func WithLogger

func WithLogger(l ronykit.Logger) Option

func WithPredicateKey

func WithPredicateKey(key string) Option

type Selector

type Selector struct {
	Predicate string
	Encoding  ronykit.Encoding
}

func RPC

func RPC(predicate string) Selector

RPC returns a selector that acts on websocket messages

func (Selector) GetEncoding

func (r Selector) GetEncoding() ronykit.Encoding

func (Selector) GetPredicate

func (r Selector) GetPredicate() string

func (Selector) Query

func (r Selector) Query(q string) interface{}

func (*Selector) SetEncoding

func (r *Selector) SetEncoding(enc ronykit.Encoding) *Selector

type SwitchProtocol

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

func (*SwitchProtocol) Upgrade

func (sp *SwitchProtocol) Upgrade(conn io.ReadWriter) (hs ws.Handshake, err error)