pubsub

type A struct {
	// MsgInfo happend when a peer introduces it's exposed state machines.
	MsgInfo       *MsgInfo
	MsgUpdates    *MsgUpdates
	MsgBye        *MsgBye
	MsgReqInfo    *MsgReqInfo
	MsgReqUpdates *MsgReqUpdates
	MsgGossip     *MsgGossip
	// Msgs is a list of received general (non-semantic) PubSub messages.
	Msgs []*pubsub.Message
	// Msg is a raw msg.
	Msg []byte
	// PeerId is a peer ID
	PeerId  string `log:"peer"`
	PeerIds []string
	// MachId is a state machine ID
	MachId string
	// MTime is machine time
	MTime am.Time `log:"mtime"`
	// Addrs is a list of addresses.
	Addrs []multiaddr.Multiaddr `log:"addrs"`
	// WorkersCh is a return channel for a list of [rpc.Worker]. It has to be
	// buffered or the mutation will fail.
	WorkersCh   chan<- []*rpc.Worker
	ListFilters *ListFilters
	MachClocks  MachClocks
	MsgType     string `log:"msg_type"`
	PeersGossip PeerGossips
}

type Gossips map[int]uint64

type Info struct {
	Id     string
	Schema am.Struct
	States am.S
	MTime  am.Time
	Tags   []string
	Parent string
}

type ListFilters struct {
	IdExact   string
	IdPartial string
	IdRegexp  *regexp.Regexp
	Parent    string
	PeerId    string
	// Level to traverse towards the tree root.
	DepthLevel  int
	ChildrenMax int
	ChildrenMin int
}

type MachClocks map[int]am.Time

type MachInfo map[int]*Info

type Msg struct {
	Type MsgType
}

type MsgBye struct {
	Msg
	Machs map[int]MsgByeMach
}

type MsgByeMach struct {
	PeerBye bool
	Id      string
	MTime   am.Time
}

type MsgGossip struct {
	Msg
	// Number of workers from each peer
	PeerGossips PeerGossips
}

type MsgInfo struct {
	Msg
	// peer ID => mach idx => schema
	PeerInfo PeerInfo
	// Number of workers from each peer
	PeerGossips PeerGossips
}

type MsgReqInfo struct {
	Msg
	PeerIds []string
}

type MsgReqUpdates struct {
	Msg
	// TODO list specific mach indexes
	PeerIds []string
}

type MsgType string

type MsgUpdates struct {
	Msg
	PeerClocks PeerClocks
}

type PeerClocks map[string]MachClocks

type PeerGossips map[string]Gossips

type PeerInfo map[string]MachInfo

type Topic struct {
	*am.ExceptionHandler

	// T represents the PubSub topic used for communication.
	T *ps.Topic
	// Mach is a state machine for this PubSub.
	Mach *am.Machine
	// ListenAddrs contains the list of multiaddresses that this topic listens on.
	// None will allocate one automatically.
	ListenAddrs []ma.Multiaddr
	// Addrs is a list of addresses for this peer.
	Addrs atomic.Pointer[[]ma.Multiaddr]
	// Name indicates the name of the channel or topic instance,
	// typically associated with a given process.
	Name string
	// ConnAddrs contains a list of addresses for initial
	// connections to discovery nodes in the network.
	ConnAddrs []ma.Multiaddr
	// List of exposed state machines, index => mach_id, indexes are used on the
	// channel. Indexes should NOT change, as they are used for addressing. `nil`
	// value means empty.
	ExposedMachs []*am.Machine
	// Debounce for clock broadcasts (separate per each exposed state machine).
	Debounce   time.Time
	LogEnabled bool
	// HeartbeatFreq brodcasts changed clocks of exposed machines.
	HeartbeatFreq time.Duration
	// Maximum msgs per minute in the network,
	MaxMsgsPerWin int
	// DebugWorkerTelemetry exposes local workers to am-dbg
	DebugWorkerTelemetry bool
	ConnectionsToReady   int
	// contains filtered or unexported fields
}

type TopicOpts struct {
	// Parent is a parent state machine for a new Topic state machine. See
	// [am.Opts].
	Parent am.Api
}

type Tracer struct {
	*am.NoOpTracer
	// contains filtered or unexported fields
}