package states
Import Path
github.com/pancsta/asyncmachine-go/pkg/pubsub/states (on go.dev)
Dependency Relation
imports 3 packages, and imported by one package
Involved Source Files
Package states contains a stateful schema-v2 for Topic.
Bootstrapped with am-gen. Edit manually or re-gen & merge.
Package-Level Type Names (total 2)
TopicGroupsDef contains all the state groups Topic state machine.
ConnectedGroupsDef *ss.ConnectedGroupsDef
ConnectedGroupsDef.Connected states.S
var TopicGroups
TopicStatesDef contains all the states of the Topic state machine.
inherit from BasicStatesDef
ErrHandlerTimeout indicates one of the state machine handlers has timed
out.
ErrNetwork indicates a generic network error.
Healthcheck is a periodic request making sure that the machine is still
alive.
Heartbeat is a periodic state that ensures the integrity of the machine.
Ready indicates the machine meets criteria to perform work.
Start indicates the machine should be working. Removing start can force
stop the machine.
inherit from ConnectedStatesDef
ConnectedStatesDef.Connected states.ConnectedState
ConnectedStatesDef.Connecting states.ConnectedState
ConnectedStatesDef.Disconnected states.ConnectedState
ConnectedStatesDef.Disconnecting states.ConnectedState
ErrConnecting is a detailed connection error, eg no access.
inherit from DisposedStatesDef
Disposed indicates that the machine has disposed allocated resoruces
and is ready to be garbage collected by calling [am.Machine.Dispose].
Disposing indicates that the machine is during the disposal process.
RegisterDisposal registers a disposal handler passed under the
DisposedArgHandler key.
Sends MsgInfo to specific peers or the channel.
ErrJoining string
ErrListening string
Joined string
Joining string
ListMachines is a request to return the filtered list of connected machines
via chan, as [rpc.Worker].
Heard about peers, but doesnt know them
Updates for unknown peers
Other peers have later clock values for some known peers
MsgBye string
MsgInfo string
MsgReceived means a general msg was sent to the channel.
MsgReqInfo received
MsgReqUpdates received
MsgUpdates received
PeerJoined string
PeerLeft string
ProcessMsgs string
ReqMissingPeers string
ReqMissingUpdates string
SendGossips string
SendInfo string
SendMsg string
SendUpdates string
Started string
StatesBase *am.StatesBase
Exception is the only built-in state and mean a global error. All errors
have to [State.Require] the Exception state. If [Machine.PanicToErr] is
true, Exception will receive it.
( TopicStatesDef) Names() machine.S
( TopicStatesDef) SetNames(names machine.S)
( TopicStatesDef) SetStateGroups(groups map[string][]int, order []string)
( TopicStatesDef) StateGroups() (map[string][]int, []string)
TopicStatesDef : github.com/pancsta/asyncmachine-go/pkg/machine.States
var TopicStates
Package-Level Variables (total 3)
TopicGroups contains all the state groups for the Topic machine.
TopicSchema represents all relations and properties of TopicStates.
TopicStates contains all the states for the Topic machine.
![]() |
The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64) Golds is a Go 101 project developed by Tapir Liu. PR and bug reports are welcome and can be submitted to the issue list. Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds. |