ript_net

Documentation

Index

• func HandleCalls(face *QuicFace, writer http.ResponseWriter, request *http.Request)
• func HandleMedia(face *QuicFace, writer http.ResponseWriter, request *http.Request)
• func HandleTgDiscovery(face *QuicFace, writer http.ResponseWriter, request *http.Request)
• func HandlerRegistration(face *QuicFace, writer http.ResponseWriter, request *http.Request)
• func Match(s, o api.Advertisement) ([]api.DirectiveInfo, bool)
• type Call
• type Face
• type FaceFactory
• type Handler
• type QuicFace
  • func NewQuicFace(name string) *QuicFace
  • func (f *QuicFace) CanStream() bool
  • func (f *QuicFace) Close(err error)
  • func (f *QuicFace) Name() api.FaceName
  • func (f *QuicFace) OnClose() chan error
  • func (f *QuicFace) Read()
  • func (f *QuicFace) Send(pkt api.Packet) error
  • func (f *QuicFace) SetReceiveChan(recv chan api.PacketEvent)
• type QuicFaceServer
  • func NewQuicFaceServer(port int, host, certFile, keyFile string) *QuicFaceServer
  • func (server *QuicFaceServer) Feed() chan Face
• type RIPTService
  • func NewRIPTService() *RIPTService
• type Router
  • func NewRouter(name string, service *RIPTService) *Router
  • func (r *Router) AddFace(face Face)
  • func (r *Router) AddFaceFactory(factory FaceFactory)
  • func (r *Router) RemoveFace(face Face, err error)
• type TrunkGroup
• type TrunkGroupDirection
• type WebSocketFace
  • func NewWebSocketClientFace(url string) (*WebSocketFace, error)
  • func NewWebSocketFace(conn *websocket.Conn) *WebSocketFace
  • func (ws *WebSocketFace) CanStream() bool
  • func (ws *WebSocketFace) Close(err error)
  • func (ws *WebSocketFace) Name() api.FaceName
  • func (ws *WebSocketFace) OnClose() chan error
  • func (ws *WebSocketFace) Read()
  • func (ws *WebSocketFace) Send(pkt api.Packet) error
  • func (ws *WebSocketFace) SetReceiveChan(recv chan api.PacketEvent)
• type WebSocketFaceServer
  • func NewWebSocketFaceServer(port int) *WebSocketFaceServer
  • func (wss *WebSocketFaceServer) Feed() chan Face
  • func (wss *WebSocketFaceServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func HandleCalls

func HandleCalls(face *QuicFace, writer http.ResponseWriter, request *http.Request)

func HandleMedia

func HandleMedia(face *QuicFace, writer http.ResponseWriter, request *http.Request)

func HandleTgDiscovery

func HandleTgDiscovery(face *QuicFace, writer http.ResponseWriter, request *http.Request)

func HandlerRegistration

func HandlerRegistration(face *QuicFace, writer http.ResponseWriter, request *http.Request)

Client Handler Registration

func Match

func Match(s, o api.Advertisement) ([]api.DirectiveInfo, bool)

Crude and incorrect match implementation. Needs to be redone

Types

type Call

type Call struct {
	// contains filtered or unexported fields
}

capture service representation direction, allowed identities, allowed numbers, media capabilities of the service

type Face

type Face interface {
	Name() api.FaceName
	Send(pkt api.Packet) error
	Read()
	SetReceiveChan(recv chan api.PacketEvent)
	Close(err error)
	OnClose() chan error
	CanStream() bool
}

Abstract interface for the underlying transport

type FaceFactory

type FaceFactory interface {
	Feed() chan Face
}

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

Handler Information

type QuicFace

type QuicFace struct {
	// contains filtered or unexported fields
}

func NewQuicFace

func NewQuicFace(name string) *QuicFace

func (*QuicFace) CanStream

func (f *QuicFace) CanStream() bool

func (*QuicFace) Close

func (f *QuicFace) Close(err error)

func (*QuicFace) Name

func (f *QuicFace) Name() api.FaceName

func (*QuicFace) OnClose

func (f *QuicFace) OnClose() chan error

func (*QuicFace) Read

func (f *QuicFace) Read()

func (*QuicFace) Send

func (f *QuicFace) Send(pkt api.Packet) error

func (*QuicFace) SetReceiveChan

func (f *QuicFace) SetReceiveChan(recv chan api.PacketEvent)

type QuicFaceServer

type QuicFaceServer struct {
	*http3.Server
	// contains filtered or unexported fields
}

func NewQuicFaceServer

func NewQuicFaceServer(port int, host, certFile, keyFile string) *QuicFaceServer

func (*QuicFaceServer) Feed

func (server *QuicFaceServer) Feed() chan Face

type RIPTService

type RIPTService struct {
	// contains filtered or unexported fields
}

/ local cache (replace this with db or file/json store)

func NewRIPTService

func NewRIPTService() *RIPTService

type Router

type Router struct {
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(name string, service *RIPTService) *Router

func (*Router) AddFace

func (r *Router) AddFace(face Face)

func (*Router) AddFaceFactory

func (r *Router) AddFaceFactory(factory FaceFactory)

func (*Router) RemoveFace

func (r *Router) RemoveFace(face Face, err error)

type TrunkGroup

type TrunkGroup struct {
	// contains filtered or unexported fields
}

type TrunkGroupDirection

type TrunkGroupDirection string

type WebSocketFace

type WebSocketFace struct {
	// contains filtered or unexported fields
}

func NewWebSocketClientFace

func NewWebSocketClientFace(url string) (*WebSocketFace, error)

func NewWebSocketFace

func NewWebSocketFace(conn *websocket.Conn) *WebSocketFace

func (*WebSocketFace) CanStream

func (ws *WebSocketFace) CanStream() bool

func (*WebSocketFace) Close

func (ws *WebSocketFace) Close(err error)

func (*WebSocketFace) Name

func (ws *WebSocketFace) Name() api.FaceName

func (*WebSocketFace) OnClose

func (ws *WebSocketFace) OnClose() chan error

func (*WebSocketFace) Read

func (ws *WebSocketFace) Read()

func (*WebSocketFace) Send

func (ws *WebSocketFace) Send(pkt api.Packet) error

func (*WebSocketFace) SetReceiveChan

func (ws *WebSocketFace) SetReceiveChan(recv chan api.PacketEvent)

type WebSocketFaceServer

type WebSocketFaceServer struct {
	*http.Server
	// contains filtered or unexported fields
}

func NewWebSocketFaceServer

func NewWebSocketFaceServer(port int) *WebSocketFaceServer

func (*WebSocketFaceServer) Feed

func (wss *WebSocketFaceServer) Feed() chan Face

func (*WebSocketFaceServer) ServeHTTP

func (wss *WebSocketFaceServer) ServeHTTP(w http.ResponseWriter, r *http.Request)