clientutil

package
v0.1.26 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 7, 2026 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package clientutil provides some util functions to set client

Index

Constants

View Source
const (
	// TokenPrefix is the prefix used for cached tokens in the file system.
	TokenPrefix = "token"

	// BearerTokenKey is the key used to store the bearer token in the file cache.
	BearerTokenKey = "bearer"
)
View Source
const (
	// ChunkSize is the number of agents to fetch in each request.
	ChunkSize = 100
)

Variables

View Source
var (
	// ErrUnauthorized is returned when the client is unauthorized.
	ErrUnauthorized = errors.New("unauthorized")
)

Functions

func ListAgentFully added in v0.1.18

func ListAgentFully(ctx context.Context, cli *client.Client) ([]v1agent.Agent, error)

ListAgentFully lists all agents and applies the provided function to each agent. It continues to fetch agents until there are no more agents to fetch.

func ListAgentFullyByAgentGroup added in v0.1.22

func ListAgentFullyByAgentGroup(
	ctx context.Context,
	cli *client.Client,
	agentGroupName string,
) ([]v1agent.Agent, error)

ListAgentFullyByAgentGroup lists all agents in a specific agent group and applies the provided function to each agent. It continues to fetch agents until there are no more agents to fetch.

func ListAgentGroupFully added in v0.1.20

func ListAgentGroupFully(ctx context.Context, cli *client.Client) ([]v1agentgroup.AgentGroup, error)

ListAgentGroupFully lists all agent groups and applies the provided function to each agent group. It continues to fetch agent groups until there are no more agent groups to fetch.

func ListConnectionFully added in v0.1.18

func ListConnectionFully(ctx context.Context, cli *client.Client) ([]v1connection.Connection, error)

ListConnectionFully lists all connections and applies the provided function to each connection. It continues to fetch connections until there are no more connections to fetch.

func NewAuthedClient

func NewAuthedClient(
	config *config.GlobalConfig,
) (*client.Client, error)

NewAuthedClient creates a new authenticated OpAMP client using the cached bearer token. It retrieves the token from the file cache and initializes the client with it.

func NewAuthedClientByIssuingTokenInCli

func NewAuthedClientByIssuingTokenInCli(
	conf *config.GlobalConfig,
) (*client.Client, error)

NewAuthedClientByIssuingTokenInCli creates a new authenticated OpAMP client by issuing a token in the CLI. It supports different authentication methods such as basic auth, manual token input, and GitHub device.

func NewClient

func NewClient(
	config *config.GlobalConfig,
) (*client.Client, error)

NewClient creates a new authenticated Client.

func NewUnauthenticatedClient added in v0.1.18

func NewUnauthenticatedClient(
	config *config.GlobalConfig,
) *client.Client

NewUnauthenticatedClient creates a new unauthenticated Client.

func TokenPath

func TokenPath(username string) string

TokenPath constructs the file path for the cached token of a specific user.

Types

type UnsupportedAuthMethodError

type UnsupportedAuthMethodError struct {
	Method string
}

UnsupportedAuthMethodError represents an error for unsupported authentication methods.

func (*UnsupportedAuthMethodError) Error

Error implements the error interface for UnsupportedAuthMethodError.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL