rendezvous

package
v0.0.0-...-40131ec Latest Latest
Warning

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

 Go to latest Published: Sep 4, 2024 License: MIT Imports: 17 Imported by: 0

Documentation

Overview

Package rendezvous is a generated GoMock package.

Package rendezvous is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrTokenNotFound = errors.BadRequest("token not found", "token not found")
)

Functions

This section is empty.

Types

type CheckinMessage 

type CheckinMessage struct {
	Ack int8 `json:"ack"`
}

type ConnectHandler 

type ConnectHandler interface {
	HandleConnect(conn *net.TCPConn, token string, nat int8) error
}

type ConnectMessage 

type ConnectMessage struct {
	Token   string `json:"token"`
	NATType int8   `json:"nat_type"`
}

func (*ConnectMessage) Reset 

func (m *ConnectMessage) Reset() *ConnectMessage

type FrontDesk 

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

func NewFrontDesk 

func NewFrontDesk(listenAddr string, connectHandler ConnectHandler) (*FrontDesk, error)

func (*FrontDesk) Close 

func (f *FrontDesk) Close() error

func (*FrontDesk) Serve 

func (f *FrontDesk) Serve()

type HolePunchMessage 

type HolePunchMessage struct {
	Addr string `json:"addr"`
}

type MeetingHandler 

type MeetingHandler interface {
	Meeting(token string, conn1, conn2 *holePunchConn) error
}

func NewMeetingImpl 

func NewMeetingImpl() MeetingHandler

func NewMeetingImplV2 

func NewMeetingImplV2() MeetingHandler

type MockConn 

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

MockConn is a mock of Conn interface.

func NewMockConn 

func NewMockConn(ctrl *gomock.Controller) *MockConn

NewMockConn creates a new mock instance.

func (*MockConn) Close 

func (m *MockConn) Close() error

Close mocks base method.

func (*MockConn) EXPECT 

func (m *MockConn) EXPECT() *MockConnMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConn) LocalAddr 

func (m *MockConn) LocalAddr() net.Addr

LocalAddr mocks base method.

func (*MockConn) Read 

func (m *MockConn) Read(arg0 []byte) (int, error)

Read mocks base method.

func (*MockConn) RemoteAddr 

func (m *MockConn) RemoteAddr() net.Addr

RemoteAddr mocks base method.

func (*MockConn) SetDeadline 

func (m *MockConn) SetDeadline(arg0 time.Time) error

SetDeadline mocks base method.

func (*MockConn) SetReadDeadline 

func (m *MockConn) SetReadDeadline(arg0 time.Time) error

SetReadDeadline mocks base method.

func (*MockConn) SetWriteDeadline 

func (m *MockConn) SetWriteDeadline(arg0 time.Time) error

SetWriteDeadline mocks base method.

func (*MockConn) Write 

func (m *MockConn) Write(arg0 []byte) (int, error)

Write mocks base method.

type MockConnMockRecorder 

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

MockConnMockRecorder is the mock recorder for MockConn.

func (*MockConnMockRecorder) Close 

func (mr *MockConnMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockConnMockRecorder) LocalAddr 

func (mr *MockConnMockRecorder) LocalAddr() *gomock.Call

LocalAddr indicates an expected call of LocalAddr.

func (*MockConnMockRecorder) Read 

func (mr *MockConnMockRecorder) Read(arg0 any) *gomock.Call

Read indicates an expected call of Read.

func (*MockConnMockRecorder) RemoteAddr 

func (mr *MockConnMockRecorder) RemoteAddr() *gomock.Call

RemoteAddr indicates an expected call of RemoteAddr.

func (*MockConnMockRecorder) SetDeadline 

func (mr *MockConnMockRecorder) SetDeadline(arg0 any) *gomock.Call

SetDeadline indicates an expected call of SetDeadline.

func (*MockConnMockRecorder) SetReadDeadline 

func (mr *MockConnMockRecorder) SetReadDeadline(arg0 any) *gomock.Call

SetReadDeadline indicates an expected call of SetReadDeadline.

func (*MockConnMockRecorder) SetWriteDeadline 

func (mr *MockConnMockRecorder) SetWriteDeadline(arg0 any) *gomock.Call

SetWriteDeadline indicates an expected call of SetWriteDeadline.

func (*MockConnMockRecorder) Write 

func (mr *MockConnMockRecorder) Write(arg0 any) *gomock.Call

Write indicates an expected call of Write.

type MockConnectHandler 

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

MockConnectHandler is a mock of ConnectHandler interface.

func NewMockConnectHandler 

func NewMockConnectHandler(ctrl *gomock.Controller) *MockConnectHandler

NewMockConnectHandler creates a new mock instance.

func (*MockConnectHandler) EXPECT 

func (m *MockConnectHandler) EXPECT() *MockConnectHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConnectHandler) HandleConnect 

func (m *MockConnectHandler) HandleConnect(conn *net.TCPConn, token string, nat int8) error

HandleConnect mocks base method.

type MockConnectHandlerMockRecorder 

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

MockConnectHandlerMockRecorder is the mock recorder for MockConnectHandler.

func (*MockConnectHandlerMockRecorder) HandleConnect 

func (mr *MockConnectHandlerMockRecorder) HandleConnect(conn, token, nat any) *gomock.Call

HandleConnect indicates an expected call of HandleConnect.

type MockMeetingHandler 

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

MockMeetingHandler is a mock of MeetingHandler interface.

func NewMockMeetingHandler 

func NewMockMeetingHandler(ctrl *gomock.Controller) *MockMeetingHandler

NewMockMeetingHandler creates a new mock instance.

func (*MockMeetingHandler) EXPECT 

func (m *MockMeetingHandler) EXPECT() *MockMeetingHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMeetingHandler) Meeting 

func (m *MockMeetingHandler) Meeting(token string, conn1, conn2 *holePunchConn) error

Meeting mocks base method.

type MockMeetingHandlerMockRecorder 

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

MockMeetingHandlerMockRecorder is the mock recorder for MockMeetingHandler.

func (*MockMeetingHandlerMockRecorder) Meeting 

func (mr *MockMeetingHandlerMockRecorder) Meeting(token, conn1, conn2 any) *gomock.Call

Meeting indicates an expected call of Meeting.

type NegotiationMessage 

type NegotiationMessage struct {
	LocalPublicAddr  string `json:"local_public_addr"`
	RemotePublicAddr string `json:"remote_public_addr"`
	RemoteNATType    int8   `json:"remote_nat_type"`
	ServerPort       int    `json:"server_port"`
	IsActive         bool   `json:"is_active"`
}

type RoomKeyCard 

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

type Server 

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

func Builder 

func Builder(listenAddr string) (*Server, error)

func NewServer 

func NewServer(meetingHandler MeetingHandler, frontDesk *FrontDesk, waitingRoom *WaitingRoomManager) *Server

func (*Server) Close 

func (s *Server) Close()

func (*Server) Serve 

func (s *Server) Serve()

type WaitingRoomManager 

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

func NewWaitingRoomManager 

func NewWaitingRoomManager(meetingHandler MeetingHandler, tokenTTL time.Duration, tokenCleanInterval time.Duration) (*WaitingRoomManager, error)

func (*WaitingRoomManager) Close 

func (wrm *WaitingRoomManager) Close() error

func (*WaitingRoomManager) CreateWaitingRoom 

func (wrm *WaitingRoomManager) CreateWaitingRoom(tcpConn net.Conn, token string, nat types.NATType) error

CreateWaitingRoom Create a new token and a channel to wait for a connection

func (*WaitingRoomManager) HandleConnect 

func (wrm *WaitingRoomManager) HandleConnect(conn *net.TCPConn, token string, nat int8) error

func (*WaitingRoomManager) JoinWaitingRoom 

func (wrm *WaitingRoomManager) JoinWaitingRoom(token string, conn net.Conn, natType types.NATType) error

JoinWaitingRoom Join the waiting room with the token

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳