netq

package

v0.1.0 Latest Latest Go to latest Published: Oct 29, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Details

View Source

const (
	LoginURL    = "auth/v1/login"
	OpIdURL     = "auth/v1/select/opid"
	TopologyURL = "telemetry/v1/object/topologygraph/fetch-topology"
)

View Source

const NAME = "netq"

This section is empty.

func Loader(ctx context.Context, config providers.Config) (providers.Provider, error)

func NamedLoader() (string, providers.Loader)

type AuthOutput struct {
	AccessToken string `json:"access_token"`
}

type CNode struct {
	Id   string `json:"id"`
	Name string `json:"name"`
	Tier int    `json:"tier"`
}

type Credentials struct {
	// contains filtered or unexported fields
}

func GetCred(cred map[string]string) (*Credentials, error)

type Links struct {
	Id string `json:"id"`
}

type NetqResponse struct {
	Links []Links `json:"links"`
	Nodes []Nodes `json:"nodes"`
}

type Nodes struct {
	Cnode []CNode `json:"compounded_nodes"`
}

type Provider struct {
	// contains filtered or unexported fields
}

func (p *Provider) GenerateTopologyConfig(ctx context.Context, _ *int, instances []topology.ComputeInstances) (*topology.Vertex, error)

func (p *Provider) GetInstancesRegions(ctx context.Context, nodes []string) (map[string]string, error)

GetInstancesRegions implements slurm.instanceMapper

func (p *Provider) Instances2NodeMap(ctx context.Context, nodes []string) (map[string]string, error)

Instances2NodeMap implements slurm.instanceMapper

type ProviderParams struct {
	ApiURL string `mapstructure:"apiUrl"`
	OpID   string `mapstructure:"opid"`
}

func GetParams(params map[string]any) (*ProviderParams, error)