nng

Documentation

Index

• func CreateConnection(_ api.StreamContext) modules.Connection
• type Sock
  • func (s *Sock) Close(_ api.StreamContext) error
  • func (s *Sock) Dial(ctx api.StreamContext) error
  • func (s *Sock) GetId(_ api.StreamContext) string
  • func (s *Sock) Ping(_ api.StreamContext) error
  • func (s *Sock) Provision(ctx api.StreamContext, conId string, props map[string]any) error
  • func (s *Sock) Send(ctx api.StreamContext, data []byte) error
  • func (s *Sock) SetStatusChangeHandler(_ api.StreamContext, handler api.StatusChangeHandler)
  • func (s *Sock) Status(_ api.StreamContext) modules.ConnectionStatus
• type SockConf
  • func ValidateConf(props map[string]any) (*SockConf, error)

Functions

func CreateConnection

func CreateConnection(_ api.StreamContext) modules.Connection

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) Dial

func (s *Sock) Dial(ctx api.StreamContext) error

func (*Sock) GetId

func (s *Sock) GetId(_ api.StreamContext) string

func (*Sock) Ping

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

func (*Sock) Provision

func (s *Sock) Provision(ctx api.StreamContext, conId string, props map[string]any) error

func (*Sock) Send

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

func (*Sock) SetStatusChangeHandler

func (s *Sock) SetStatusChangeHandler(_ api.StreamContext, handler api.StatusChangeHandler)

func (*Sock) Status

func (s *Sock) Status(_ api.StreamContext) modules.ConnectionStatus

type SockConf

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

func ValidateConf

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