transporter

type Channel string

type DaemonCmd uint

type Event uint

type PayloadDiscovery struct {
	Blocks map[types.BlockName][]types.ActionName `json:"blocks"`
	Event  Event                                  `json:"event"`
}

type PayloadMessage struct {
	Data any `json:"data"`
}

type Pocket[P []byte | any] struct {
	Channel      Channel               `json:"channel"`
	VersionName  types.NodeVersionName `json:"version_name"`
	FromID       types.NodeID          `json:"from_id"`
	TargetID     *types.NodeID         `json:"target_id"`
	TargetAction *types.TargetAction   `json:"target_action"`
	Payload      P                     `json:"payload"`
	Hash         string                `json:"hash"`
	ResponseHash string                `json:"hash_res"`
}

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

type Redis struct {
	Transporter
	// contains filtered or unexported fields
}

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

type Transporter interface {
	Connect() error
	Disconnect() error
	Send(channel Channel, payload []byte) error
	Subscribe(channel Channel, callback func(payload []byte)) error
}