transformer

Documentation

Overview

Package transformer provides the base transformer implementation.

Package transformer defines the transformer interface for request/response transformation.

Index

• type BaseTransformer
  • func NewBaseTransformer(name string) *BaseTransformer
  • func (b *BaseTransformer) MarshalSSEEvent(eventType string, data any) (SSEEvent, error)
  • func (b *BaseTransformer) Name() string
• type Provider
• type Registry
  • func NewRegistry() *Registry
  • func (r *Registry) Get(name string) (Transformer, error)
  • func (r *Registry) Has(name string) bool
  • func (r *Registry) Names() []string
  • func (r *Registry) Register(t Transformer)
• type SSEEvent
• type Transformer

Types

type BaseTransformer

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

BaseTransformer provides common utilities for transformers.

func NewBaseTransformer

func NewBaseTransformer(name string) *BaseTransformer

NewBaseTransformer creates a new base transformer.

func (*BaseTransformer) MarshalSSEEvent

func (b *BaseTransformer) MarshalSSEEvent(eventType string, data any) (SSEEvent, error)

MarshalSSEEvent creates an SSEEvent from the provided data.

func (*BaseTransformer) Name

func (b *BaseTransformer) Name() string

Name returns the transformer name.

type Provider

type Provider struct {
	BaseURL string
	APIKey  string
	Model   string
}

Provider represents a provider configuration (deprecated, for backward compatibility).

type Registry

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

Registry manages transformer instances. Uses sync.Map for optimal read-heavy concurrency (write-once at startup, read on every request).

func NewRegistry

func NewRegistry() *Registry

NewRegistry creates a new transformer registry.

func (*Registry) Get

func (r *Registry) Get(name string) (Transformer, error)

Get retrieves a transformer by name.

func (*Registry) Has

func (r *Registry) Has(name string) bool

Has checks if a transformer exists.

func (*Registry) Names

func (r *Registry) Names() []string

Names returns all registered transformer names.

func (*Registry) Register

func (r *Registry) Register(t Transformer)

Register adds a transformer to the registry.

type SSEEvent

type SSEEvent struct {
	// EventType is the SSE event type (e.g., "message_start", "content_block_delta").
	EventType string
	// Data is the raw JSON data payload.
	Data []byte
}

SSEEvent represents a complete server-sent event with type and data.

type Transformer

type Transformer interface {
	// Name returns the transformer name.
	Name() string

	// Endpoint returns the API endpoint path.
	Endpoint() string

	// PrepareRequest converts Anthropic request to provider HTTP request.
	PrepareRequest(req *anthropic.Request, baseURL, apiKey, model string) (*http.Request, error)

	// ParseResponse converts provider HTTP response to Anthropic response.
	ParseResponse(resp *http.Response) (*anthropic.Response, error)

	// SupportsStreaming returns true if transformer supports streaming.
	SupportsStreaming() bool

	// TransformStreamEvent converts provider SSE event to Anthropic SSE events.
	TransformStreamEvent(event *SSEEvent) ([]SSEEvent, error)
}

Transformer transforms between Anthropic and provider formats.