ript_net

package
v0.0.0-...-0d5d430 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2020 License: BSD-2-Clause Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL