forked from iotaledger/goshimmer
-
Notifications
You must be signed in to change notification settings - Fork 0
/
packet.go
33 lines (27 loc) · 875 Bytes
/
packet.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
package packet
import (
"sync"
"github.com/cockroachdb/errors"
"github.com/izuc/zipp.foundation/core/protocol/message"
"github.com/izuc/zipp.foundation/core/protocol/tlv"
)
// ErrMalformedPacket is returned when malformed packets are tried to be parsed.
var ErrMalformedPacket = errors.New("malformed packet")
var (
// analysisBlkRegistry holds all block definitions for analysis server related blocks
analysisBlkRegistry *message.Registry
heartBeatOnce sync.Once
)
func init() {
// block definitions to be registered in registry
definitions := []*message.Definition{
tlv.HeaderMessageDefinition,
HeartBeatBlockDefinition(),
MetricHeartbeatBlockDefinition,
}
analysisBlkRegistry = message.NewRegistry(definitions)
}
// AnalysisBlkRegistry gets the analysisBlkRegistry.
func AnalysisBlkRegistry() *message.Registry {
return analysisBlkRegistry
}