Versions in this module Expand all Collapse all v1 v1.1.1 Aug 18, 2020 Changes in this version + const CsfbServiceName + const DefaultMMEName + const DefaultVLRIPAddress + const DefaultVLRPort + const LocalAddrEnv + const LocalIPAddress + const LocalPort + const MCCLength + const MMECLength + const MMEGILength + const MMEServiceName + const MNCLength + const TimeOut + const VLRAddrEnv + func ConstructMMEName() (string, error) + func ConstructSCTPAddr(ip string, port int) *sctp.SCTPAddr + func GetCsfbConfig() *mconfProtos.CsfbConfig + func SplitIP(IPsandPort string) (ipStr string, portInt int, err error) + type ClientConnectionInterface interface + CloseConn func() error + EstablishConn func() error + Receive func() ([]byte, error) + Send func(message []byte) error + type CsfbServer struct + Conn ClientConnectionInterface + ReceivingBuffer SafeBuffer + func NewCsfbServer(ConnectionInterface ClientConnectionInterface) (*CsfbServer, error) + func (srv *CsfbServer) AlertAc(ctx context.Context, req *protos.AlertAck) (*orcprotos.Void, error) + func (srv *CsfbServer) AlertRej(ctx context.Context, req *protos.AlertReject) (*orcprotos.Void, error) + func (srv *CsfbServer) EPSDetachInd(ctx context.Context, req *protos.EPSDetachIndication) (*orcprotos.Void, error) + func (srv *CsfbServer) IMSIDetachInd(ctx context.Context, req *protos.IMSIDetachIndication) (*orcprotos.Void, error) + func (srv *CsfbServer) LocationUpdateReq(ctx context.Context, req *protos.LocationUpdateRequest) (*orcprotos.Void, error) + func (srv *CsfbServer) MMEResetAck(ctx context.Context, req *protos.ResetAck) (*orcprotos.Void, error) + func (srv *CsfbServer) MMEResetIndication(ctx context.Context, req *protos.ResetIndication) (*orcprotos.Void, error) + func (srv *CsfbServer) MMEStatus(ctx context.Context, req *protos.Status) (*orcprotos.Void, error) + func (srv *CsfbServer) PagingRej(ctx context.Context, req *protos.PagingReject) (*orcprotos.Void, error) + func (srv *CsfbServer) SendResetAck() error + func (srv *CsfbServer) ServiceReq(ctx context.Context, req *protos.ServiceRequest) (*orcprotos.Void, error) + func (srv *CsfbServer) TMSIReallocationComp(ctx context.Context, req *protos.TMSIReallocationComplete) (*orcprotos.Void, error) + func (srv *CsfbServer) UEActivityInd(ctx context.Context, req *protos.UEActivityIndication) (*orcprotos.Void, error) + func (srv *CsfbServer) UEUnreach(ctx context.Context, req *protos.UEUnreachable) (*orcprotos.Void, error) + func (srv *CsfbServer) Uplink(ctx context.Context, req *protos.UplinkUnitdata) (*orcprotos.Void, error) + type PortNumber = int + type SCTPClientConnection struct + func CreateVlrSCTPconnection(config *mconfig.CsfbConfig) (*SCTPClientConnection, error) + func NewSCTPClientConnection(vlrSCTPAddr *sctp.SCTPAddr, localSGsAddr *sctp.SCTPAddr) (*SCTPClientConnection, error) + func (conn *SCTPClientConnection) CloseConn() error + func (conn *SCTPClientConnection) EstablishConn() error + func (conn *SCTPClientConnection) GetLocalIPandPort() ([]string, int) + func (conn *SCTPClientConnection) GetVlrIPandPort() ([]string, int) + func (conn *SCTPClientConnection) Receive() ([]byte, error) + func (conn *SCTPClientConnection) Send(message []byte) error + type SCTPServerConnection struct + func NewSCTPServerConnection() (*SCTPServerConnection, error) + func (conn *SCTPServerConnection) AcceptConn() error + func (conn *SCTPServerConnection) CloseConn() error + func (conn *SCTPServerConnection) CloseListener() error + func (conn *SCTPServerConnection) ConnectionEstablished() bool + func (conn *SCTPServerConnection) ReceiveThroughListener() ([]byte, error) + func (conn *SCTPServerConnection) SendFromServer(msg []byte) error + func (conn *SCTPServerConnection) StartListener(ipAddr string, port PortNumber) (PortNumber, error) + type SafeBuffer struct + func NewSafeBuffer() (*SafeBuffer, error) + func (safeBuffer *SafeBuffer) GetNextMessage(timeOutInSec int) (decode.SGsMessageType, *any.Any, error) + func (safeBuffer *SafeBuffer) WriteChunk(chunk []byte) (int, error) + type ServerConnectionInterface interface + AcceptConn func() error + CloseConn func() error + CloseListener func() error + ConnectionEstablished func() bool + ReceiveThroughListener func() ([]byte, error) + SendFromServer func([]byte) error + StartListener func(ipAddr string, port PortNumber) (PortNumber, error) Other modules containing this package github.com/go-magma/magma