provider

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

type ChatChunk struct {
	Content          string `json:"content"`
	FinishReason     string `json:"finish_reason"`
	PromptTokens     int    `json:"prompt_tokens"`     // Usually only in first or last chunk
	CompletionTokens int    `json:"completion_tokens"` // Usually cumulative or in last chunk
}

type ChatRequest struct {
	Model    string    `json:"model"`
	Messages []Message `json:"messages"`
	Stream   bool      `json:"stream"`
}

type ChatResponse struct {
	Content          string `json:"content"`
	Model            string `json:"model"`
	Provider         string `json:"provider"`
	PromptTokens     int    `json:"prompt_tokens"`
	CompletionTokens int    `json:"completion_tokens"`
}

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

type Message struct {
	Role    string `json:"role"`
	Content string `json:"content"`
}

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

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

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

type Provider interface {
	// Name returns the provider identifier (e.g., "openai", "anthropic").
	Name() string

	// Chat dispatches a non-streaming request.
	Chat(ctx context.Context, req ChatRequest) (*ChatResponse, error)

	// ChatStream dispatches a streaming request.
	// It returns a channel of chunks and a channel for errors.
	ChatStream(ctx context.Context, req ChatRequest) (<-chan ChatChunk, <-chan error)
}

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