client

package

Go to main page

Versions in this module

v5

v5.2.6

Sep 21, 2025

v5.2.5

Sep 20, 2025

v5.2.4

Sep 20, 2025

v5.2.3

Sep 19, 2025

v5.2.2

Sep 19, 2025

v5.2.1

Sep 19, 2025

Changes in this version

type GeminiWebClient

+ func (c *GeminiWebClient) UnregisterClientWithReason(reason interfaces.UnregisterReason)

type QwenClient

+ func (c *QwenClient) UnregisterClient()

+ func (c *QwenClient) UnregisterClientWithReason(reason interfaces.UnregisterReason)

v5.2.0

Sep 19, 2025

Changes in this version

type ClaudeClient

+ func (c *ClaudeClient) IsAvailable() bool

+ func (c *ClaudeClient) SetUnavailable()

type CodexClient

+ func (c *CodexClient) IsAvailable() bool

+ func (c *CodexClient) SetUnavailable()

type GeminiCLIClient

+ func (c *GeminiCLIClient) IsAvailable() bool

+ func (c *GeminiCLIClient) SetUnavailable()

type GeminiClient

+ func (c *GeminiClient) IsAvailable() bool

+ func (c *GeminiClient) SetUnavailable()

+ type GeminiWebClient struct

+ func NewGeminiWebClient(cfg *config.Config, ts *gemini.GeminiWebTokenStorage, tokenFilePath string) (*GeminiWebClient, error)

+ func (c *GeminiWebClient) CanProvideModel(modelName string) bool

+ func (c *GeminiWebClient) EnsureRegistered()

+ func (c *GeminiWebClient) GetEmail() string

+ func (c *GeminiWebClient) GetRequestMutex() *sync.Mutex

+ func (c *GeminiWebClient) GetUserAgent() string

+ func (c *GeminiWebClient) Init() error

+ func (c *GeminiWebClient) IsAvailable() bool

+ func (c *GeminiWebClient) IsModelQuotaExceeded(model string) bool

+ func (c *GeminiWebClient) IsReady() bool

+ func (c *GeminiWebClient) Provider() string

+ func (c *GeminiWebClient) RefreshTokens(ctx context.Context) error

+ func (c *GeminiWebClient) SaveTokenToFile() error

+ func (c *GeminiWebClient) SendRawMessage(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *GeminiWebClient) SendRawMessageStream(ctx context.Context, modelName string, rawJSON []byte, alt string) (<-chan []byte, <-chan *interfaces.ErrorMessage)

+ func (c *GeminiWebClient) SendRawTokenCount(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *GeminiWebClient) SetUnavailable()

+ func (c *GeminiWebClient) StableClientID() string

+ func (c *GeminiWebClient) Type() string

+ func (c *GeminiWebClient) UnregisterClient()

type OpenAICompatibilityClient

+ func (c *OpenAICompatibilityClient) IsAvailable() bool

+ func (c *OpenAICompatibilityClient) SetUnavailable()

type QwenClient

+ func (c *QwenClient) IsAvailable() bool

+ func (c *QwenClient) SetUnavailable()

v5.1.29

Sep 17, 2025

v5.1.28

Sep 16, 2025

v5.1.27

Sep 15, 2025

v5.1.26

Sep 14, 2025

v5.1.25

Sep 13, 2025

Changes in this version

+ type ClaudeClient struct

+ func NewClaudeClient(cfg *config.Config, ts *claude.ClaudeTokenStorage) *ClaudeClient

+ func NewClaudeClientWithKey(cfg *config.Config, apiKeyIndex int) *ClaudeClient

+ func (c *ClaudeClient) APIRequest(ctx context.Context, modelName, endpoint string, body interface{}, _ string, ...) (io.ReadCloser, *interfaces.ErrorMessage)

+ func (c *ClaudeClient) CanProvideModel(modelName string) bool

+ func (c *ClaudeClient) GetAPIKey() string

+ func (c *ClaudeClient) GetEmail() string

+ func (c *ClaudeClient) GetRequestMutex() *sync.Mutex

+ func (c *ClaudeClient) GetUserAgent() string

+ func (c *ClaudeClient) IsModelQuotaExceeded(model string) bool

+ func (c *ClaudeClient) Provider() string

+ func (c *ClaudeClient) RefreshTokens(ctx context.Context) error

+ func (c *ClaudeClient) SaveTokenToFile() error

+ func (c *ClaudeClient) SendRawMessage(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *ClaudeClient) SendRawMessageStream(ctx context.Context, modelName string, rawJSON []byte, alt string) (<-chan []byte, <-chan *interfaces.ErrorMessage)

+ func (c *ClaudeClient) SendRawTokenCount(_ context.Context, _ string, _ []byte, _ string) ([]byte, *interfaces.ErrorMessage)

+ func (c *ClaudeClient) TokenStorage() auth.TokenStorage

+ func (c *ClaudeClient) Type() string

+ type ClientBase struct

+ RequestMutex *sync.Mutex

+ func (c *ClientBase) AddAPIResponseData(ctx context.Context, line []byte)

+ func (c *ClientBase) ClearModelQuotaExceeded(modelID string)

+ func (c *ClientBase) GetClientID() string

+ func (c *ClientBase) GetRequestMutex() *sync.Mutex

+ func (c *ClientBase) InitializeModelRegistry(clientID string)

+ func (c *ClientBase) RegisterModels(provider string, models []*registry.ModelInfo)

+ func (c *ClientBase) SetModelQuotaExceeded(modelID string)

+ func (c *ClientBase) UnregisterClient()

+ type CodexClient struct

+ func NewCodexClient(cfg *config.Config, ts *codex.CodexTokenStorage) (*CodexClient, error)

+ func NewCodexClientWithKey(cfg *config.Config, apiKeyIndex int) *CodexClient

+ func (c *CodexClient) APIRequest(ctx context.Context, modelName, endpoint string, body interface{}, _ string, ...) (io.ReadCloser, *interfaces.ErrorMessage)

+ func (c *CodexClient) CanProvideModel(modelName string) bool

+ func (c *CodexClient) GetAPIKey() string

+ func (c *CodexClient) GetEmail() string

+ func (c *CodexClient) GetRequestMutex() *sync.Mutex

+ func (c *CodexClient) GetUserAgent() string

+ func (c *CodexClient) IsModelQuotaExceeded(model string) bool

+ func (c *CodexClient) Provider() string

+ func (c *CodexClient) RefreshTokens(ctx context.Context) error

+ func (c *CodexClient) SaveTokenToFile() error

+ func (c *CodexClient) SendRawMessage(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *CodexClient) SendRawMessageStream(ctx context.Context, modelName string, rawJSON []byte, alt string) (<-chan []byte, <-chan *interfaces.ErrorMessage)

+ func (c *CodexClient) SendRawTokenCount(_ context.Context, _ string, _ []byte, _ string) ([]byte, *interfaces.ErrorMessage)

+ func (c *CodexClient) TokenStorage() auth.TokenStorage

+ func (c *CodexClient) Type() string

+ type GeminiCLIClient struct

+ func NewGeminiCLIClient(httpClient *http.Client, ts *geminiAuth.GeminiTokenStorage, cfg *config.Config) *GeminiCLIClient

+ func (c *GeminiCLIClient) APIRequest(ctx context.Context, modelName, endpoint string, body interface{}, alt string, ...) (io.ReadCloser, *interfaces.ErrorMessage)

+ func (c *GeminiCLIClient) CanProvideModel(modelName string) bool

+ func (c *GeminiCLIClient) CheckCloudAPIIsEnabled() (bool, error)

+ func (c *GeminiCLIClient) GetEmail() string

+ func (c *GeminiCLIClient) GetProjectID() string

+ func (c *GeminiCLIClient) GetProjectList(ctx context.Context) (*interfaces.GCPProject, error)

+ func (c *GeminiCLIClient) GetRequestMutex() *sync.Mutex

+ func (c *GeminiCLIClient) GetUserAgent() string

+ func (c *GeminiCLIClient) IsAuto() bool

+ func (c *GeminiCLIClient) IsChecked() bool

+ func (c *GeminiCLIClient) IsModelQuotaExceeded(model string) bool

+ func (c *GeminiCLIClient) Provider() string

+ func (c *GeminiCLIClient) RefreshTokens(ctx context.Context) error

+ func (c *GeminiCLIClient) SaveTokenToFile() error

+ func (c *GeminiCLIClient) SendRawMessage(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *GeminiCLIClient) SendRawMessageStream(ctx context.Context, modelName string, rawJSON []byte, alt string) (<-chan []byte, <-chan *interfaces.ErrorMessage)

+ func (c *GeminiCLIClient) SendRawTokenCount(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *GeminiCLIClient) SetIsAuto(auto bool)

+ func (c *GeminiCLIClient) SetIsChecked(checked bool)

+ func (c *GeminiCLIClient) SetProjectID(projectID string)

+ func (c *GeminiCLIClient) SetupUser(ctx context.Context, email, projectID string) error

+ func (c *GeminiCLIClient) Type() string

+ type GeminiClient struct

+ func NewGeminiClient(httpClient *http.Client, cfg *config.Config, glAPIKey string) *GeminiClient

+ func (c *GeminiClient) APIRequest(ctx context.Context, modelName, endpoint string, body interface{}, alt string, ...) (io.ReadCloser, *interfaces.ErrorMessage)

+ func (c *GeminiClient) CanProvideModel(modelName string) bool

+ func (c *GeminiClient) GetEmail() string

+ func (c *GeminiClient) GetRequestMutex() *sync.Mutex

+ func (c *GeminiClient) GetUserAgent() string

+ func (c *GeminiClient) IsModelQuotaExceeded(model string) bool

+ func (c *GeminiClient) Provider() string

+ func (c *GeminiClient) RefreshTokens(ctx context.Context) error

+ func (c *GeminiClient) SaveTokenToFile() error

+ func (c *GeminiClient) SendRawMessage(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *GeminiClient) SendRawMessageStream(ctx context.Context, modelName string, rawJSON []byte, alt string) (<-chan []byte, <-chan *interfaces.ErrorMessage)

+ func (c *GeminiClient) SendRawTokenCount(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *GeminiClient) Type() string

+ type OpenAICompatibilityClient struct

+ func NewOpenAICompatibilityClient(cfg *config.Config, compatConfig *config.OpenAICompatibility, apiKeyIndex int) (*OpenAICompatibilityClient, error)

+ func (c *OpenAICompatibilityClient) APIRequest(ctx context.Context, modelName string, endpoint string, rawJSON []byte, ...) (io.ReadCloser, *interfaces.ErrorMessage)

+ func (c *OpenAICompatibilityClient) CanProvideModel(modelName string) bool

+ func (c *OpenAICompatibilityClient) GetActualModelName(alias string) string

+ func (c *OpenAICompatibilityClient) GetCurrentAPIKey() string

+ func (c *OpenAICompatibilityClient) GetEmail() string

+ func (c *OpenAICompatibilityClient) GetRequestMutex() *sync.Mutex

+ func (c *OpenAICompatibilityClient) GetUserAgent() string

+ func (c *OpenAICompatibilityClient) IsModelQuotaExceeded(model string) bool

+ func (c *OpenAICompatibilityClient) Provider() string

+ func (c *OpenAICompatibilityClient) RefreshTokens(ctx context.Context) error

+ func (c *OpenAICompatibilityClient) SaveTokenToFile() error

+ func (c *OpenAICompatibilityClient) SendRawMessage(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *OpenAICompatibilityClient) SendRawMessageStream(ctx context.Context, modelName string, rawJSON []byte, alt string) (<-chan []byte, <-chan *interfaces.ErrorMessage)

+ func (c *OpenAICompatibilityClient) SendRawTokenCount(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *OpenAICompatibilityClient) TokenStorage() auth.TokenStorage

+ func (c *OpenAICompatibilityClient) Type() string

+ type QwenClient struct

+ func NewQwenClient(cfg *config.Config, ts *qwen.QwenTokenStorage) *QwenClient

+ func (c *QwenClient) APIRequest(ctx context.Context, modelName, endpoint string, body interface{}, _ string, ...) (io.ReadCloser, *interfaces.ErrorMessage)

+ func (c *QwenClient) CanProvideModel(modelName string) bool

+ func (c *QwenClient) GetEmail() string

+ func (c *QwenClient) GetRequestMutex() *sync.Mutex

+ func (c *QwenClient) GetUserAgent() string

+ func (c *QwenClient) IsModelQuotaExceeded(model string) bool

+ func (c *QwenClient) Provider() string

+ func (c *QwenClient) RefreshTokens(ctx context.Context) error

+ func (c *QwenClient) SaveTokenToFile() error

+ func (c *QwenClient) SendRawMessage(ctx context.Context, modelName string, rawJSON []byte, alt string) ([]byte, *interfaces.ErrorMessage)

+ func (c *QwenClient) SendRawMessageStream(ctx context.Context, modelName string, rawJSON []byte, alt string) (<-chan []byte, <-chan *interfaces.ErrorMessage)

+ func (c *QwenClient) SendRawTokenCount(_ context.Context, _ string, _ []byte, _ string) ([]byte, *interfaces.ErrorMessage)

+ func (c *QwenClient) TokenStorage() auth.TokenStorage

+ func (c *QwenClient) Type() string

Other modules containing this package

github.com/luispater/CLIProxyAPI

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