m3ua

May 1, 2023

Changes in this version

+ func DisableLogging()

+ func EnableLogging(l *log.Logger)

+ func SetLogger(l *log.Logger)

type Conn

+ func (c *Conn) WriteToStream(b []byte, streamID uint16) (n int, err error)

Jul 28, 2019

Changes in this version

type Config

+ func NewConfig(opc, dpc uint32, si, ni, mp, sls uint8) *Config

+ func (c *Config) EnableHeartbeat(interval, timer time.Duration) *Config

+ func (c *Config) SetAspIdentifier(id uint32) *Config

+ func (c *Config) SetCorrelationID(id uint32) *Config

+ func (c *Config) SetNetworkAppearance(nwApr uint32) *Config

+ func (c *Config) SetRoutingContexts(rtCtxs ...uint32) *Config

+ func (c *Config) SetTrafficModeType(tmType uint32) *Config

type HeartbeatInfo

+ func NewHeartbeatInfo(interval, timer time.Duration, data []byte) *HeartbeatInfo

Nov 6, 2018

Changes in this version

+ const PCFormat3_2_3

+ var ErrFailedToEstablish = errors.New("failed to establish M3UA Conn")

+ var ErrFailedToPeelOff = errors.New("failed to peel off Protocol Data")

+ var ErrFailedToWriteSignal = errors.New("failed to write signal")

+ var ErrHeartbeatExpired = errors.New("heartbeat timer expired")

+ var ErrInvalidState = errors.New("invalid state")

+ var ErrNotEstablished = errors.New("M3UA Conn not established")

+ var ErrSCTPNotAlive = errors.New("SCTP is no longer alive")

+ var ErrTimeout = errors.New("timed out")

+ func FormatPC(pc uint32, format PCFormat) string

+ func ParsePC(pc string, format PCFormat) uint32

+ type Config struct

+ AspIdentifier *params.Param

+ CorrelationID *params.Param

+ DestinationPointCode uint32

+ MessagePriority uint8

+ NetworkAppearance *params.Param

+ NetworkIndicator uint8

+ OriginatingPointCode uint32

+ RoutingContexts *params.Param

+ ServiceIndicator uint8

+ SignalingLinkSelection uint8

+ TrafficModeType *params.Param

+ func NewClientConfig(hbInfo *HeartbeatInfo, opc, dpc, aspID, tmt, nwApr, corrID uint32, ...) *Config

+ func NewServerConfig(hbInfo *HeartbeatInfo, opc, dpc, aspID, tmt, nwApr, corrID uint32, ...) *Config

+ type Conn struct

+ func Dial(ctx context.Context, net string, laddr, raddr *sctp.SCTPAddr, cfg *Config) (*Conn, error)

+ func (c *Conn) Close() error

+ func (c *Conn) LocalAddr() net.Addr

+ func (c *Conn) Read(b []byte) (n int, err error)

+ func (c *Conn) RemoteAddr() net.Addr

+ func (c *Conn) SetDeadline(t time.Time) error

+ func (c *Conn) SetReadDeadline(t time.Time) error

+ func (c *Conn) SetWriteDeadline(t time.Time) error

+ func (c *Conn) State() State

+ func (c *Conn) Write(b []byte) (n int, err error)

+ func (c *Conn) WriteSignal(m3 messages.M3UA) (n int, err error)

+ type ErrAspIDRequired struct

+ func NewErrAspIDRequired() *ErrAspIDRequired

+ func (e *ErrAspIDRequired) Error() string

+ type ErrInvalidSCTPStreamID struct

+ ID uint16

+ func NewErrInvalidSCTPStreamID(id uint16) *ErrInvalidSCTPStreamID

+ func (e *ErrInvalidSCTPStreamID) Error() string

+ type ErrInvalidVersion struct

+ Ver uint8

+ func NewErrInvalidVersion(ver uint8) *ErrInvalidVersion

+ func (e *ErrInvalidVersion) Error() string

+ type ErrUnexpectedMessage struct

+ Msg messages.M3UA

+ func NewErrUnexpectedMessage(msg messages.M3UA) *ErrUnexpectedMessage

+ func (e *ErrUnexpectedMessage) Error() string

+ type ErrUnsupportedClass struct

+ Msg messages.M3UA

+ func NewErrUnsupportedClass(msg messages.M3UA) *ErrUnsupportedClass

+ func (e *ErrUnsupportedClass) Error() string

+ type ErrUnsupportedMessage struct

+ Msg messages.M3UA

+ func NewErrUnsupportedMessage(msg messages.M3UA) *ErrUnsupportedMessage

+ func (e *ErrUnsupportedMessage) Error() string

+ type HeartbeatInfo struct

+ Data []byte

+ Enabled bool

+ Interval time.Duration

+ Timer time.Duration

+ type Listener struct

+ func Listen(net string, laddr *sctp.SCTPAddr, cfg *Config) (*Listener, error)

+ func (l *Listener) Accept(ctx context.Context) (*Conn, error)

+ func (l *Listener) Addr() net.Addr

+ func (l *Listener) Close() error

+ type PCFormat string

+ type State uint8

+ const StateAspActive

+ const StateAspDown

+ const StateAspInactive

+ const StateSCTPCDI

+ const StateSCTPRI