server

package
v0.18.7 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2026 License: MIT Imports: 23 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AcceptConn added in v0.18.0 

func AcceptConn(
	conn io.ReadWriteCloser, mach *am.Machine, fwdTo []*rpc.Client,
)

AcceptConn accepts a std rpc connection, or alike.

func StartRpc added in v0.7.0 

func StartRpc(
	mach *am.Machine, addr string, mux chan<- cmux.CMux, p types.Params,
)

Types

type Client added in v0.16.1 

type Client struct {
	// bits which get saved into the go file
	*Exportable

	// current transition, 1-based, mirrors the slider (eg 1 means tx.ID == 0)
	// TODO atomic
	// current step, 1-based, mirrors the slider
	// TODO atomic
	ReaderCollapsed bool
	Id              string
	MTimeSum        uint64
	SelectedGroup   string
	Connected       atomic.Bool
	ConnId          string
	SchemaHash      string
	// processed list of filtered tx _indexes_
	MsgTxsFiltered []int
	// cache of processed log entries
	LogMsgs [][]*am.LogEntry
	// indexes of txs with errors, desc order for bisects
	// TOOD refresh on GC
	Errors []int
	// processed
	MsgTxsParsed    []*types.MsgTxParsed
	MsgSchemaParsed *types.MsgSchemaParsed
	// contains filtered or unexported fields
}

func (*Client) ClearCache added in v0.16.1 

func (c *Client) ClearCache()

func (*Client) FilterIndexByCursor1 added in v0.16.1 

func (c *Client) FilterIndexByCursor1(cursor1 int) int

func (*Client) HadErrSinceTx added in v0.16.1 

func (c *Client) HadErrSinceTx(tx, distance int) bool

func (*Client) IndexesToStates added in v0.16.1 

func (c *Client) IndexesToStates(indexes []int) am.S

func (*Client) LastActive added in v0.16.1 

func (c *Client) LastActive() time.Time

func (*Client) LastTxTill added in v0.16.1 

func (c *Client) LastTxTill(hTime time.Time) int

func (*Client) ParseSchema added in v0.16.1 

func (c *Client) ParseSchema()

func (*Client) StatesToIndexes added in v0.16.1 

func (c *Client) StatesToIndexes(states am.S) []int

func (*Client) Tx added in v0.16.1 

func (c *Client) Tx(idx int) *dbg.DbgMsgTx

func (*Client) TxByMachTime added in v0.16.1 

func (c *Client) TxByMachTime(sum uint64) int

func (*Client) TxIndex added in v0.16.1 

func (c *Client) TxIndex(id string) int

TxIndex returns the index of transition ID [id] or -1 if not found.

func (*Client) TxParsed added in v0.16.1 

func (c *Client) TxParsed(idx int) *types.MsgTxParsed

type DbgMsgSchemaFwd added in v0.12.0 

type DbgMsgSchemaFwd struct {
	MsgStruct *dbg.DbgMsgStruct
	ConnId    string
}

type DbgMsgTx added in v0.12.0 

type DbgMsgTx struct {
	MsgTx  *dbg.DbgMsgTx
	ConnId string
}

type Exportable added in v0.16.1 

type Exportable struct {
	// TODO refac to MsgSchema
	// TODO version schemas
	MsgStruct *dbg.DbgMsgStruct
	MsgTxs    []*dbg.DbgMsgTx
}

type RPCServer 

type RPCServer struct {
	Mach *am.Machine
	// TODO ConnId
	ConnID string
	FwdTo  []*rpc.Client
}

TODO rename to RPCServer (compat break)

func (*RPCServer) DbgMsgSchema added in v0.15.0 

func (r *RPCServer) DbgMsgSchema(
	msgSchema *dbg.DbgMsgStruct, _ *string,
) error

func (*RPCServer) DbgMsgSchemaFwd added in v0.12.0 

func (r *RPCServer) DbgMsgSchemaFwd(
	msg *DbgMsgSchemaFwd, _ *string,
) error

TODO rename to RemoteMsgSchemaReceive (compat break)

func (*RPCServer) DbgMsgTx 

func (r *RPCServer) DbgMsgTx(msgTx *dbg.DbgMsgTx, _ *string) error

func (*RPCServer) DbgMsgTxFwd added in v0.12.0 

func (r *RPCServer) DbgMsgTxFwd(msg *DbgMsgTx, _ *string) error

TODO rename to RemoteMsgTxReceive (compat break)

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.