argo/client/client.go

package client

import (
	"context"
	"github.com/argoproj/argo-workflows/v3/pkg/apiclient"
	"github.com/argoproj/argo-workflows/v3/pkg/apiclient/workflow"
	"github.com/argoproj/argo-workflows/v3/pkg/apiclient/workflowtemplate"
	"github.com/pkg/errors"
	"k8s.io/client-go/tools/clientcmd"
	"os"
	"sync"
)

var watchWorkflowTokenMap sync.Map

type Client struct {
	ctx                     context.Context
	client                  apiclient.Client
	workflowTemplateService workflowtemplate.WorkflowTemplateServiceClient
	workflowService         workflow.WorkflowServiceClient
}

func NewClient(kubeConfigEnv string) (*Client, error) {
	err := os.Setenv("KUBECONFIG", kubeConfigEnv)
	if err != nil {
		return nil, errors.New(err.Error())
	}

	apiClientCtx, apiClient, err := apiclient.NewClientFromOpts(apiclient.Opts{
		ArgoServerOpts: apiclient.ArgoServerOpts{},
		ClientConfigSupplier: func() clientcmd.ClientConfig {
			return clientcmd.NewNonInteractiveDeferredLoadingClientConfig(clientcmd.NewDefaultClientConfigLoadingRules(), nil)
		},
		Context: context.Background(),
	})
	if err != nil {
		return nil, errors.New(err.Error())
	}

	workflowTemplateService, err := apiClient.NewWorkflowTemplateServiceClient()
	if err != nil {
		return nil, errors.New(err.Error())
	}

	return &Client{
		ctx:                     apiClientCtx,
		client:                  apiClient,
		workflowTemplateService: workflowTemplateService,
		workflowService:         apiClient.NewWorkflowServiceClient(),
	}, nil
}

func Destroy(c *Client) {
	if c == nil {
		return
	}

	c.ctx.Done()
	c.client = nil
	c.workflowTemplateService = nil
	c.workflowService = nil
}