grpc

package
v0.0.0-...-f86c782 Latest Latest
Warning

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

Go to latest
Published: Mar 25, 2024 License: BSD-3-Clause Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewGrpcDialOption

func NewGrpcDialOption(runelog *runelog.Runelog, isdebug bool) grpc.DialOption

Types

type ServerClient

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

func (*ServerClient) Connect

func (*ServerClient) ConnectStreamPeerLoginSession

func (c *ServerClient) ConnectStreamPeerLoginSession(mk string) (*login.PeerLoginSessionResponse, error)

func (*ServerClient) Disconnect

func (*ServerClient) GetConnectionStatus

func (c *ServerClient) GetConnectionStatus(mk string) (*daemon.GetConnectionStatusResponse, error)

func (*ServerClient) LoginMachine

func (c *ServerClient) LoginMachine(mk, wgPrivKey string) (*login.LoginMachineResponse, error)

func (*ServerClient) SyncRemoteMachinesConfig

func (c *ServerClient) SyncRemoteMachinesConfig(mk, wgPrivKey string) (*machine.SyncMachinesResponse, error)

type ServerClientImpl

type ServerClientImpl interface {
	LoginMachine(mk, wgPrivKey string) (*login.LoginMachineResponse, error)
	SyncRemoteMachinesConfig(mk, wgPrivKey string) (*machine.SyncMachinesResponse, error)
	ConnectStreamPeerLoginSession(mk string) (*login.PeerLoginSessionResponse, error)
	Connect(mk string) (*daemon.GetConnectionStatusResponse, error)
	Disconnect(mk string) (*daemon.GetConnectionStatusResponse, error)
	GetConnectionStatus(mk string) (*daemon.GetConnectionStatusResponse, error)
}

func NewServerClient

func NewServerClient(
	sysInfo system.SysInfo,
	conn *grpc.ClientConn,
	runelog *runelog.Runelog,
) ServerClientImpl

type SignalClient

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

func (*SignalClient) Answer

func (c *SignalClient) Answer(
	dstmk, srcmk string,
	uFlag string,
	pwd string,
) error

func (*SignalClient) Candidate

func (c *SignalClient) Candidate(dstmk, srcmk string, candidate ice.Candidate) error

func (*SignalClient) Connect

func (c *SignalClient) Connect(mk string, handler func(msg *negotiation.NegotiationRequest) error) error

func (*SignalClient) Connected

func (c *SignalClient) Connected() error

func (*SignalClient) DisConnected

func (c *SignalClient) DisConnected() error

func (*SignalClient) GetConnStatus

func (c *SignalClient) GetConnStatus() string

func (*SignalClient) GetStunTurnConfig

func (c *SignalClient) GetStunTurnConfig() (*rtc.GetStunTurnConfigResponse, error)

func (*SignalClient) IsReady

func (c *SignalClient) IsReady() bool

func (*SignalClient) Offer

func (c *SignalClient) Offer(
	dstmk, srcmk string,
	uFlag string,
	pwd string,
) error

func (*SignalClient) WaitStartConnect

func (c *SignalClient) WaitStartConnect()

function to wait until connState becomes Connected until it can

type SignalClientImpl

type SignalClientImpl interface {
	Candidate(dstmk, srcmk string, candidate ice.Candidate) error
	Offer(dstmk, srcmk string, uFlag string, pwd string) error
	Answer(dstmk, srcmk string, uFlag string, pwd string) error
	Connect(mk string, handler func(msg *negotiation.NegotiationRequest) error) error

	WaitStartConnect()
	IsReady() bool
	GetStunTurnConfig() (*rtc.GetStunTurnConfigResponse, error)

	// Status
	DisConnected() error
	Connected() error
	GetConnStatus() string
}

func NewSignalClient

func NewSignalClient(
	sysInfo system.SysInfo,
	conn *grpc.ClientConn,
	cs *conn.ConnectState,
	runelog *runelog.Runelog,
) SignalClientImpl

Jump to

Keyboard shortcuts

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