relay

package

v0.18.2 Latest Latest Go to latest Published: Mar 9, 2026 License: MIT Imports: 24 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pancsta/asyncmachine-go

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type A
type Relay
- func New(ctx context.Context, args types.Args) (*Relay, error)
type WsTcpTun
- func NewWsTcpTun(ctx context.Context, wsConn *websocket.Conn, ...) (*WsTcpTun, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	Pass = types.Pass
)

Functions ¶

This section is empty.

Types ¶

type A ¶ added in v0.18.0

type A = types.A

type Relay ¶

type Relay struct {
	Mach    *am.Machine
	Args    types.Args
	HttpMux *http.ServeMux
	// contains filtered or unexported fields
}

func New ¶

func New(ctx context.Context, args types.Args) (*Relay, error)

New creates a new Relay - state machine, RPC server.

func (*Relay) ClientMsgEnter ¶

func (r *Relay) ClientMsgEnter(e *am.Event) bool

func (*Relay) ClientMsgState ¶

func (r *Relay) ClientMsgState(e *am.Event)

func (*Relay) ConnectEventEnter ¶

func (r *Relay) ConnectEventEnter(e *am.Event) bool

func (*Relay) ConnectEventState ¶

func (r *Relay) ConnectEventState(e *am.Event)

func (*Relay) DisconnectEventEnter ¶

func (r *Relay) DisconnectEventEnter(e *am.Event) bool

func (*Relay) DisconnectEventState ¶

func (r *Relay) DisconnectEventState(e *am.Event)

func (*Relay) HandleWsTcpListen ¶ added in v0.18.0

func (r *Relay) HandleWsTcpListen(
	e *am.Event, w http.ResponseWriter, req *http.Request,
)

func (*Relay) HttpReadyEnd ¶ added in v0.18.0

func (r *Relay) HttpReadyEnd(e *am.Event)

func (*Relay) HttpReadyState ¶ added in v0.18.0

func (r *Relay) HttpReadyState(e *am.Event)

func (*Relay) HttpStartingState ¶ added in v0.18.0

func (r *Relay) HttpStartingState(e *am.Event)

func (*Relay) Start ¶ added in v0.18.0

func (r *Relay) Start(e *am.Event) am.Result

func (*Relay) StartState ¶

func (r *Relay) StartState(e *am.Event)

func (*Relay) Stop ¶ added in v0.18.0

func (r *Relay) Stop(e *am.Event) am.Result

type WsTcpTun ¶ added in v0.18.0

type WsTcpTun struct {
	*ssam.DisposedHandlers

	Mach *am.Machine
	// Incoming WebSocket connection
	WsConn *websocket.Conn
	// TCP addr to listen on
	TcpAddr    string
	TcpLn      net.Listener
	RemoteAddr string
	RemoteId   string
}

func NewWsTcpTun ¶ added in v0.18.0

func NewWsTcpTun(
	ctx context.Context, wsConn *websocket.Conn, idRemote, addr, remoteAddr,
	idTun string, parent am.Api, debug bool,
) (*WsTcpTun, error)

func (*WsTcpTun) DisposingState ¶ added in v0.18.2

func (t *WsTcpTun) DisposingState(e *am.Event)

func (*WsTcpTun) StartEnd ¶ added in v0.18.0

func (t *WsTcpTun) StartEnd(e *am.Event)

func (*WsTcpTun) StartEnter ¶ added in v0.18.0

func (t *WsTcpTun) StartEnter(e *am.Event) bool

func (*WsTcpTun) StartState ¶ added in v0.18.0

func (t *WsTcpTun) StartState(e *am.Event)

func (*WsTcpTun) TcpAcceptedState ¶ added in v0.18.0

func (t *WsTcpTun) TcpAcceptedState(e *am.Event)

func (*WsTcpTun) TcpListenState ¶ added in v0.18.0

func (t *WsTcpTun) TcpListenState(e *am.Event)

func (*WsTcpTun) TcpListeningState ¶ added in v0.18.0

func (t *WsTcpTun) TcpListeningState(e *am.Event)

func (*WsTcpTun) WebSocketEnd ¶ added in v0.18.0

func (t *WsTcpTun) WebSocketEnd(e *am.Event)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
states Package states contains a stateful schema-v2 for Relay.	Package states contains a stateful schema-v2 for Relay.
types

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