@@ -106,16 +106,14 @@ func parseTimeCounts(times string, counts string) ([]timeCount, error) {
106
106
return tc , nil
107
107
}
108
108
109
- type Scaler struct {
109
+ type scaler struct {
110
110
timeCounts []timeCount
111
111
selector labels.Selector
112
112
start time.Time
113
113
pos int
114
114
done chan struct {}
115
115
}
116
116
117
- var posError = errors .New ("could not find position" )
118
-
119
117
func findPos (tc []timeCount , cur int , offset time.Duration ) int {
120
118
first := true
121
119
for i := cur ; i != cur || first ; i = (i + 1 ) % len (tc ) {
@@ -127,7 +125,7 @@ func findPos(tc []timeCount, cur int, offset time.Duration) int {
127
125
return 0
128
126
}
129
127
130
- func (s * Scaler ) setCount (c int ) {
128
+ func (s * scaler ) setCount (c int ) {
131
129
glog .Infof ("scaling to %d replicas" , c )
132
130
rcList , err := client .ReplicationControllers (namespace ).List (s .selector )
133
131
if err != nil {
@@ -142,15 +140,15 @@ func (s *Scaler) setCount(c int) {
142
140
}
143
141
}
144
142
145
- func (s * Scaler ) timeOffset () time.Duration {
143
+ func (s * scaler ) timeOffset () time.Duration {
146
144
return time .Since (s .start ) % dayPeriod
147
145
}
148
146
149
- func (s * Scaler ) curpos (offset time.Duration ) int {
147
+ func (s * scaler ) curpos (offset time.Duration ) int {
150
148
return findPos (s .timeCounts , s .pos , offset )
151
149
}
152
150
153
- func (s * Scaler ) scale () {
151
+ func (s * scaler ) scale () {
154
152
for {
155
153
select {
156
154
case <- s .done :
@@ -168,7 +166,7 @@ func (s *Scaler) scale() {
168
166
}
169
167
}
170
168
171
- func (s * Scaler ) Start () error {
169
+ func (s * scaler ) Start () error {
172
170
now := time .Now ().UTC ()
173
171
s .start = time .Date (now .Year (), now .Month (), now .Day (), 0 , 0 , 0 , 0 , now .Location ())
174
172
if * startNow {
@@ -196,7 +194,7 @@ func safeclose(c chan<- struct{}) (err error) {
196
194
return nil
197
195
}
198
196
199
- func (s * Scaler ) Stop () error {
197
+ func (s * scaler ) Stop () error {
200
198
if err := safeclose (s .done ); err != nil {
201
199
return errors .New ("already stopped scaling" )
202
200
}
@@ -211,7 +209,7 @@ var (
211
209
local = flag .Bool ("local" , false , "set to true if running on local machine not within cluster" )
212
210
localPort = flag .Int ("localport" , 8001 , "port that kubectl proxy is running on (local must be true)" )
213
211
214
- namespace string = os .Getenv ("POD_NAMESPACE" )
212
+ namespace = os .Getenv ("POD_NAMESPACE" )
215
213
216
214
client * kclient.Client
217
215
)
@@ -259,7 +257,7 @@ func main() {
259
257
if namespace == "" {
260
258
glog .Fatal ("POD_NAMESPACE is not set. Set to the namespace of the replication controller if running locally." )
261
259
}
262
- scaler := Scaler {timeCounts : tc , selector : selector }
260
+ scaler := scaler {timeCounts : tc , selector : selector }
263
261
if err != nil {
264
262
glog .Fatal (err )
265
263
}
0 commit comments