INNER CODE UNIT · Go

out

lucagrulla/cw · main.go:221

	out := make(chan *logEvent)

	var wg sync.WaitGroup

	triggerChannels := make([]chan<- time.Time, len(t.LogGroupStreamName))

	coordinator := &tailCoordinator{log: ctx.DebugLog}
	for idx, gs := range t.LogGroupStreamName {
		trigger := make(chan time.Time, 1)
		go func(groupStream string) {
			tokens := strings.Split(groupStream, ":")
			var prefix string
			group := tokens[0]
			if len(tokens) > 1 && tokens[1] != "*" {
				prefix = tokens[1]
			}
			ch, e := cloudwatch.Tail(&ctx.Client, cloudwatch.TailConfig{
				LogGroupName:  &group,

View source record →