nng

Documentation

Index

• func CreateConnection(ctx api.StreamContext, props map[string]any) (modules.Connection, error)
• type Sock
  • func (s *Sock) Close(_ api.StreamContext) error
  • func (s *Sock) DetachSub(_ api.StreamContext, _ map[string]any)
  • func (s *Sock) Ping(_ api.StreamContext) error
  • func (s *Sock) Send(ctx api.StreamContext, data []byte) error
• type SockConf
  • func ValidateConf(props map[string]any) (*SockConf, error)

Functions

func CreateConnection

func CreateConnection(ctx api.StreamContext, props map[string]any) (modules.Connection, error)

Types

type Sock

type Sock struct {
	mangos.Socket
	// contains filtered or unexported fields
}

func (*Sock) Close

func (s *Sock) Close(_ api.StreamContext) error

func (*Sock) DetachSub

func (s *Sock) DetachSub(_ api.StreamContext, _ map[string]any)

func (*Sock) Ping

func (s *Sock) Ping(_ api.StreamContext) error

func (*Sock) Send

func (s *Sock) Send(ctx api.StreamContext, data []byte) error

type SockConf

type SockConf struct {
	Url      string `json:"url"`
	Protocol string `json:"protocol"`
}

func ValidateConf

func ValidateConf(props map[string]any) (*SockConf, error)