support-perf-site-replication.go

// Copyright (c) 2023 MinIO, Inc.
//
// This file is part of MinIO Object Storage stack
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Affero General Public License for more details.
//
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package cmd

import (
	"context"
	"os"
	"time"

	tea "github.com/charmbracelet/bubbletea"
	"github.com/minio/cli"
	"github.com/minio/madmin-go/v3"
	"github.com/minio/mc/pkg/probe"
)

func mainAdminSpeedTestSiteReplication(ctx *cli.Context, aliasedURL string, outCh chan<- PerfTestResult) error {
	client, perr := newAdminClient(aliasedURL)
	if perr != nil {
		fatalIf(perr.Trace(aliasedURL), "Unable to initialize admin client.")
		return nil
	}

	ctxt, cancel := context.WithCancel(globalContext)
	defer cancel()

	duration, e := time.ParseDuration(ctx.String("duration"))
	if e != nil {
		fatalIf(probe.NewError(e), "Unable to parse duration")
		return nil
	}
	if duration <= 0 {
		fatalIf(errInvalidArgument(), "duration cannot be 0 or negative")
		return nil
	}

	resultCh := make(chan madmin.SiteNetPerfResult)
	errorCh := make(chan error)
	go func() {
		defer close(resultCh)
		defer close(errorCh)

		result, e := client.SiteReplicationPerf(ctxt, duration)
		if e != nil {
			errorCh <- e
		}
		resultCh <- result
	}()

	if globalJSON {
		select {
		case e := <-errorCh:
			printMsg(convertPerfResult(PerfTestResult{
				Type:  SiteReplicationPerfTest,
				Err:   e.Error(),
				Final: true,
			}))
		case result := <-resultCh:
			printMsg(convertPerfResult(PerfTestResult{
				Type:                  SiteReplicationPerfTest,
				SiteReplicationResult: &result,
				Final:                 true,
			}))
		}
		return nil
	}

	done := make(chan struct{})

	p := tea.NewProgram(initSpeedTestUI())
	go func() {
		if _, e := p.Run(); e != nil {
			os.Exit(1)
		}
		close(done)
	}()

	go func() {
		for {
			select {
			case e := <-errorCh:
				r := PerfTestResult{
					Type:  SiteReplicationPerfTest,
					Err:   e.Error(),
					Final: true,
				}
				p.Send(r)
				if outCh != nil {
					outCh <- r
				}
				return
			case result := <-resultCh:
				r := PerfTestResult{
					Type:                  SiteReplicationPerfTest,
					SiteReplicationResult: &result,
					Final:                 true,
				}
				p.Send(r)
				if outCh != nil {
					outCh <- r
				}
				return
			default:
				p.Send(PerfTestResult{
					Type:                  SiteReplicationPerfTest,
					SiteReplicationResult: &madmin.SiteNetPerfResult{},
				})
				time.Sleep(100 * time.Millisecond)
			}
		}
	}()

	<-done

	return nil
}