const SOL_SCTP … const SCTP_BINDX_ADD_ADDR … const SCTP_BINDX_REM_ADDR … const MSG_NOTIFICATION … const SCTP_RTOINFO … const SCTP_ASSOCINFO … const SCTP_INITMSG … const SCTP_NODELAY … const SCTP_AUTOCLOSE … const SCTP_SET_PEER_PRIMARY_ADDR … const SCTP_PRIMARY_ADDR … const SCTP_ADAPTATION_LAYER … const SCTP_DISABLE_FRAGMENTS … const SCTP_PEER_ADDR_PARAMS … const SCTP_DEFAULT_SENT_PARAM … const SCTP_EVENTS … const SCTP_I_WANT_MAPPED_V4_ADDR … const SCTP_MAXSEG … const SCTP_STATUS … const SCTP_GET_PEER_ADDR_INFO … const SCTP_DELAYED_ACK_TIME … const SCTP_DELAYED_ACK … const SCTP_DELAYED_SACK … const SCTP_SOCKOPT_BINDX_ADD … const SCTP_SOCKOPT_BINDX_REM … const SCTP_SOCKOPT_PEELOFF … const SCTP_GET_PEER_ADDRS … const SCTP_GET_LOCAL_ADDRS … const SCTP_SOCKOPT_CONNECTX … const SCTP_SOCKOPT_CONNECTX3 … const SCTP_EVENT_DATA_IO … const SCTP_EVENT_ASSOCIATION … const SCTP_EVENT_ADDRESS … const SCTP_EVENT_SEND_FAILURE … const SCTP_EVENT_PEER_ERROR … const SCTP_EVENT_SHUTDOWN … const SCTP_EVENT_PARTIAL_DELIVERY … const SCTP_EVENT_ADAPTATION_LAYER … const SCTP_EVENT_AUTHENTICATION … const SCTP_EVENT_SENDER_DRY … const SCTP_EVENT_ALL … type SCTPNotificationType … const SCTP_SN_TYPE_BASE … const SCTP_ASSOC_CHANGE … const SCTP_PEER_ADDR_CHANGE … const SCTP_SEND_FAILED … const SCTP_REMOTE_ERROR … const SCTP_SHUTDOWN_EVENT … const SCTP_PARTIAL_DELIVERY_EVENT … const SCTP_ADAPTATION_INDICATION … const SCTP_AUTHENTICATION_INDICATION … const SCTP_SENDER_DRY_EVENT … type NotificationHandler … type EventSubscribe … const SCTP_CMSG_INIT … const SCTP_CMSG_SNDRCV … const SCTP_CMSG_SNDINFO … const SCTP_CMSG_RCVINFO … const SCTP_CMSG_NXTINFO … const SCTP_UNORDERED … const SCTP_ADDR_OVER … const SCTP_ABORT … const SCTP_SACK_IMMEDIATELY … const SCTP_EOF … const SCTP_MAX_STREAM … type InitMsg … type SndRcvInfo … type SndInfo … type GetAddrsOld … type NotificationHeader … type SCTPState … const SCTP_COMM_UP … const SCTP_COMM_LOST … const SCTP_RESTART … const SCTP_SHUTDOWN_COMP … const SCTP_CANT_STR_ASSOC … var nativeEndian … var sndRcvInfoSize … func init() { … } func toBuf(v interface{ … } func htons(h uint16) uint16 { … } var ntohs … // setInitOpts sets options for an SCTP association initialization // see https://tools.ietf.org/html/rfc4960#page-25 func setInitOpts(fd int, options InitMsg) error { … } func setNumOstreams(fd, num int) error { … } type SCTPAddr … func (a *SCTPAddr) ToRawSockAddrBuf() []byte { … } func (a *SCTPAddr) String() string { … } func (a *SCTPAddr) Network() string { … } func ResolveSCTPAddr(network, addrs string) (*SCTPAddr, error) { … } func SCTPConnect(fd int, addr *SCTPAddr) (int, error) { … } func SCTPBind(fd int, addr *SCTPAddr, flags int) error { … } type SCTPConn … func (c *SCTPConn) fd() int { … } func NewSCTPConn(fd int, handler NotificationHandler) *SCTPConn { … } func (c *SCTPConn) Write(b []byte) (int, error) { … } func (c *SCTPConn) Read(b []byte) (int, error) { … } func (c *SCTPConn) SetInitMsg(numOstreams, maxInstreams, maxAttempts, maxInitTimeout int) error { … } func (c *SCTPConn) SubscribeEvents(flags int) error { … } func (c *SCTPConn) SubscribedEvents() (int, error) { … } func (c *SCTPConn) SetDefaultSentParam(info *SndRcvInfo) error { … } func (c *SCTPConn) GetDefaultSentParam() (*SndRcvInfo, error) { … } func (c *SCTPConn) Getsockopt(optname, optval, optlen uintptr) (uintptr, uintptr, error) { … } func (c *SCTPConn) Setsockopt(optname, optval, optlen uintptr) (uintptr, uintptr, error) { … } func resolveFromRawAddr(ptr unsafe.Pointer, n int) (*SCTPAddr, error) { … } func sctpGetAddrs(fd, id, optname int) (*SCTPAddr, error) { … } func (c *SCTPConn) SCTPGetPrimaryPeerAddr() (*SCTPAddr, error) { … } func (c *SCTPConn) SCTPLocalAddr(id int) (*SCTPAddr, error) { … } func (c *SCTPConn) SCTPRemoteAddr(id int) (*SCTPAddr, error) { … } func (c *SCTPConn) LocalAddr() net.Addr { … } func (c *SCTPConn) RemoteAddr() net.Addr { … } func (c *SCTPConn) PeelOff(id int) (*SCTPConn, error) { … } func (c *SCTPConn) SetDeadline(t time.Time) error { … } func (c *SCTPConn) SetReadDeadline(t time.Time) error { … } func (c *SCTPConn) SetWriteDeadline(t time.Time) error { … } type SCTPListener … func (ln *SCTPListener) Addr() net.Addr { … } type SCTPSndRcvInfoWrappedConn … func NewSCTPSndRcvInfoWrappedConn(conn *SCTPConn) *SCTPSndRcvInfoWrappedConn { … } func (c *SCTPSndRcvInfoWrappedConn) Write(b []byte) (int, error) { … } func (c *SCTPSndRcvInfoWrappedConn) Read(b []byte) (int, error) { … } func (c *SCTPSndRcvInfoWrappedConn) Close() error { … } func (c *SCTPSndRcvInfoWrappedConn) LocalAddr() net.Addr { … } func (c *SCTPSndRcvInfoWrappedConn) RemoteAddr() net.Addr { … } func (c *SCTPSndRcvInfoWrappedConn) SetDeadline(t time.Time) error { … } func (c *SCTPSndRcvInfoWrappedConn) SetReadDeadline(t time.Time) error { … } func (c *SCTPSndRcvInfoWrappedConn) SetWriteDeadline(t time.Time) error { … } func (c *SCTPSndRcvInfoWrappedConn) SetWriteBuffer(bytes int) error { … } func (c *SCTPSndRcvInfoWrappedConn) GetWriteBuffer() (int, error) { … } func (c *SCTPSndRcvInfoWrappedConn) SetReadBuffer(bytes int) error { … } func (c *SCTPSndRcvInfoWrappedConn) GetReadBuffer() (int, error) { … } type SocketConfig … func (cfg *SocketConfig) Listen(net string, laddr *SCTPAddr) (*SCTPListener, error) { … } func (cfg *SocketConfig) Dial(net string, laddr, raddr *SCTPAddr) (*SCTPConn, error) { … }
Codebase Browser
kubernetes