reporter

func NewDockerTelemetrySession ¶

func NewDockerTelemetrySession(
	containerInstanceArn string,
	credentialProvider *credentials.Credentials,
	cfg *config.Config,
	deregisterInstanceEventStream *eventstream.EventStream,
	ecsClient ecs.ECSClient,
	taskEngine engine.TaskEngine,
	metricsChannel <-chan ecstcs.TelemetryMessage,
	healthChannel <-chan ecstcs.HealthMessage,
	doctor *doctor.Doctor) (*DockerTelemetrySession, error)

NewDockerTelemetrySession returns creates a DockerTelemetrySession, which has a tcshandler.TelemetrySession embedded. tcshandler.TelemetrySession contains the logic to manage the TCSClient and corresponding websocket connection