INNER CODE UNIT · Go

triggerChannels

lucagrulla/cw · main.go:225

	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,
				LogStreamName: &prefix,
				Follow:        &t.Follow,
				Retry:         &t.Retry,
				StartTime:     &st,

View source record →