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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
package speed
import (
"fmt"
"github.com/pkg/errors"
)
// InstanceDomain defines the interface for an instance domain
type InstanceDomain interface {
ID() uint32 // unique identifier for the instance domain
Name() string // name of the instance domain
Description() string // description for the instance domain
HasInstance(name string) bool // checks if an instance is in the indom
InstanceCount() int // returns the number of instances in the indom
Instances() []string // returns a slice of instances in the instance domain
}
// PCPInstanceDomainBitLength is the maximum bit length of a PCP Instance Domain
//
// see: https://github.com/performancecopilot/pcp/blob/main/src/include/pcp/impl.h#L102-L121
const PCPInstanceDomainBitLength = 22
// PCPInstanceDomain wraps a PCP compatible instance domain
type PCPInstanceDomain struct {
id uint32
name string
instances map[string]*pcpInstance
shortDescription, longDescription string
}
// NewPCPInstanceDomain creates a new instance domain or returns an already created one for the passed name
// NOTE: this is different from parfait's idea of generating ids for InstanceDomains
// We simply generate a unique 32 bit hash for an instance domain name, and if it has not
// already been created, we create it, otherwise we return the already created version
func NewPCPInstanceDomain(name string, instances []string, desc ...string) (*PCPInstanceDomain, error) {
if name == "" {
return nil, errors.New("Instance Domain name cannot be empty")
}
if len(desc) > 2 {
return nil, errors.New("Only 2 description strings allowed to define an instance domain")
}
shortDescription, longDescription := "", ""
if len(desc) > 0 {
shortDescription = desc[0]
}
if len(desc) > 1 {
longDescription = desc[1]
}
imap := make(map[string]*pcpInstance)
for _, instance := range instances {
if len(instance) > StringLength {
return nil, errors.Errorf("instance name %v is too long", instance)
}
imap[instance] = newpcpInstance(instance)
}
return &PCPInstanceDomain{
id: hash(name, PCPInstanceDomainBitLength),
name: name,
instances: imap,
shortDescription: shortDescription,
longDescription: longDescription,
}, nil
}
// HasInstance returns true if an instance of the specified name is in the Indom
func (indom *PCPInstanceDomain) HasInstance(name string) bool {
_, present := indom.instances[name]
return present
}
// ID returns the id for PCPInstanceDomain
func (indom *PCPInstanceDomain) ID() uint32 { return indom.id }
// Name returns the name for PCPInstanceDomain
func (indom *PCPInstanceDomain) Name() string { return indom.name }
// InstanceCount returns the number of instances in the current instance domain
func (indom *PCPInstanceDomain) InstanceCount() int {
return len(indom.instances)
}
// Instances returns a slice of defined instances for the instance domain
func (indom *PCPInstanceDomain) Instances() []string {
ans, i := make([]string, len(indom.instances)), 0
for k := range indom.instances {
ans[i] = k
i++
}
return ans
}
// MatchInstances returns true if the passed InstanceDomain
// has exactly the same instances as the passed array
func (indom *PCPInstanceDomain) MatchInstances(ins []string) bool {
if len(ins) != len(indom.instances) {
return false
}
for _, i := range ins {
if _, ok := indom.instances[i]; !ok {
return false
}
}
return true
}
// Description returns the description for PCPInstanceDomain
func (indom *PCPInstanceDomain) Description() string {
return indom.shortDescription + "\n" + indom.longDescription
}
func (indom *PCPInstanceDomain) String() string {
return fmt.Sprintf("%s%v", indom.name, indom.Instances())
}
|
