Skip to content

Commit 83f19e0

Browse files
committed
Refactor ACS attach instance ENI message handling
1 parent f898800 commit 83f19e0

File tree

7 files changed

+665
-479
lines changed

7 files changed

+665
-479
lines changed

agent/acs/handler/acs_handler.go

+1-13
Original file line numberDiff line numberDiff line change
@@ -263,19 +263,6 @@ func (acsSession *session) startACSSession(client wsclient.ClientServer) error {
263263
dataClient: acsSession.dataClient,
264264
}
265265

266-
// Add handler to ack instance ENI attach message
267-
instanceENIAttachHandler := newAttachInstanceENIHandler(
268-
acsSession.ctx,
269-
cfg.Cluster,
270-
acsSession.containerInstanceARN,
271-
client,
272-
eniHandler,
273-
)
274-
instanceENIAttachHandler.start()
275-
defer instanceENIAttachHandler.stop()
276-
277-
client.AddRequestHandler(instanceENIAttachHandler.handlerFunc())
278-
279266
manifestMessageIDAccessor := &manifestMessageIDAccessor{}
280267

281268
// Add TaskManifestHandler
@@ -314,6 +301,7 @@ func (acsSession *session) startACSSession(client wsclient.ClientServer) error {
314301
}
315302
responders := []wsclient.RequestResponder{
316303
acssession.NewAttachTaskENIResponder(eniHandler, responseSender),
304+
acssession.NewAttachInstanceENIResponder(eniHandler, responseSender),
317305
acssession.NewHeartbeatResponder(acsSession.doctor, responseSender),
318306
}
319307
for _, r := range responders {

agent/acs/handler/attach_instance_eni_handler.go

-163
This file was deleted.

0 commit comments

Comments
 (0)