services

type CacheStats struct {
	Hits       int64   `json:"hits"`
	Misses     int64   `json:"misses"`
	Sets       int64   `json:"sets"`
	Deletes    int64   `json:"deletes"`
	Errors     int64   `json:"errors"`
	HitRate    float64 `json:"hit_rate"`
	AvgLatency int64   `json:"avg_latency_ns"`
	Size       int64   `json:"size"`
	Memory     int64   `json:"memory_bytes"`
}

type CheckResult struct {
	Status  string `json:"status"`
	Message string `json:"message"`
	Latency int64  `json:"latency_ms"`
}

type CircuitBreaker interface {
	Execute(fn func() (any, error)) (any, error)
	GetState() CircuitBreakerState
	GetStats() CircuitBreakerStats
}

type CircuitBreakerState string

type CircuitBreakerStats struct {
	LastStateChange    time.Time           `json:"last_state_change"`
	State              CircuitBreakerState `json:"state"`
	TotalRequests      int64               `json:"total_requests"`
	SuccessfulRequests int64               `json:"successful_requests"`
	FailedRequests     int64               `json:"failed_requests"`
}

type Counter = lift.Counter

type CreateUserRequest struct {
	Metadata map[string]string `json:"metadata"`
	Email    string            `json:"email"`
	Name     string            `json:"name"`
	TenantID string            `json:"tenant_id"`
}

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

type DiscoveryOptions struct {
	TenantID         string              `json:"tenant_id,omitempty"`
	Strategy         LoadBalanceStrategy `json:"strategy"`
	Version          string              `json:"version,omitempty"`
	Region           string              `json:"region,omitempty"`
	Tags             []string            `json:"tags"`
	MaxInstances     int                 `json:"max_instances"`
	IncludeUnhealthy bool                `json:"include_unhealthy"`
	PreferLocal      bool                `json:"prefer_local"`
}

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

type Event struct {
	// Primary identifiers and timestamps (8-byte aligned)
	PublishedAt time.Time `json:"published_at" dynamodbav:"published_at"`
	CreatedAt   time.Time `json:"created_at" dynamodbav:"created_at"`
	ExpiresAt   time.Time `json:"expires_at,omitempty" dynamodbav:"expires_at,omitempty"`

	// String fields (16 bytes each)
	ID            string `json:"id" dynamodbav:"id"`                 // ULID for ordering
	EventType     string `json:"event_type" dynamodbav:"event_type"` // e.g., "partner.created"
	TenantID      string `json:"tenant_id" dynamodbav:"tenant_id"`   // For multi-tenancy
	SourceID      string `json:"source_id" dynamodbav:"source_id"`   // Source entity ID
	PartitionKey  string `json:"partition_key" dynamodbav:"pk"`      // DynamoDB partition key
	SortKey       string `json:"sort_key" dynamodbav:"sk"`           // DynamoDB sort key
	CorrelationID string `json:"correlation_id,omitempty" dynamodbav:"correlation_id,omitempty"`

	// Complex types
	Payload  json.RawMessage   `json:"payload" dynamodbav:"payload"`                       // Event data
	Metadata map[string]string `json:"metadata,omitempty" dynamodbav:"metadata,omitempty"` // Additional context
	Tags     []string          `json:"tags,omitempty" dynamodbav:"tags,omitempty"`         // For filtering

	// Smaller numeric types
	Version    int `json:"version" dynamodbav:"version"`         // Schema version
	RetryCount int `json:"retry_count" dynamodbav:"retry_count"` // For failed processing
}

type EventBus interface {
	// Publish publishes an event to the bus and returns the event ID
	Publish(ctx context.Context, event *Event) (string, error)

	// Query retrieves events based on filters
	Query(ctx context.Context, query *EventQuery) ([]*Event, error)

	// Subscribe registers a handler for specific event types (for stream processing)
	Subscribe(ctx context.Context, eventType string, handler EventHandler) error

	// GetEvent retrieves a specific event by ID
	GetEvent(ctx context.Context, eventID string) (*Event, error)

	// DeleteEvent removes an event (for cleanup/GDPR)
	DeleteEvent(ctx context.Context, eventID string) error
}

type EventBusConfig struct {
	TableName        string
	MetricsNamespace string
	TTL              time.Duration
	RetryBaseDelay   time.Duration
	RetryAttempts    int
	MaxBatchSize     int
	EnableMetrics    bool
}

type EventHandler func(ctx context.Context, event *Event) error

type EventQuery struct {
	LastEvaluatedKey map[string]interface{}
	NextKey          map[string]interface{} // Returned pagination token for next query
	StartTime        *time.Time
	EndTime          *time.Time
	TenantID         string
	EventType        string
	Tags             []string
	Limit            int
}

type Gauge = lift.Gauge

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

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

type HealthCheckConfig struct {
	Path             string        `json:"path"`
	Interval         time.Duration `json:"interval"`
	Timeout          time.Duration `json:"timeout"`
	Retries          int           `json:"retries"`
	FailureThreshold int           `json:"failure_threshold"`
	SuccessThreshold int           `json:"success_threshold"`
	Enabled          bool          `json:"enabled"`
}

type HealthStatus struct {
	Timestamp time.Time              `json:"timestamp"`
	Checks    map[string]CheckResult `json:"checks"`
	Status    string                 `json:"status"`
	Message   string                 `json:"message"`
}

type Histogram = lift.Histogram

type LoadBalanceStrategy string

type LoadBalancer interface {
	Select(instances []*ServiceInstance, strategy LoadBalanceStrategy) *ServiceInstance
	UpdateWeights(instances []*ServiceInstance) error
	GetStats() LoadBalancerStats
}

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

type LoadBalancerStats struct {
	TotalRequests        int64 `json:"total_requests"`
	SuccessfulSelections int64 `json:"successful_selections"`
	FailedSelections     int64 `json:"failed_selections"`
	AverageLatency       int64 `json:"average_latency_ns"`
}

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

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

type MetricsCollector = lift.MetricsCollector

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

type RegistryConfig struct {
	CacheTTL            time.Duration `json:"cache_ttl"`
	HealthCheckInterval time.Duration `json:"health_check_interval"`
	MaxRetries          int           `json:"max_retries"`
	RetryBackoff        time.Duration `json:"retry_backoff"`
	EnableCaching       bool          `json:"enable_caching"`
	EnableMetrics       bool          `json:"enable_metrics"`
	TenantIsolation     bool          `json:"tenant_isolation"`
}

type RegistryStats struct {
	Timestamp          time.Time         `json:"timestamp"`
	CacheStats         CacheStats        `json:"cache_stats"`
	LoadBalancerStats  LoadBalancerStats `json:"load_balancer_stats"`
	RegisteredServices int               `json:"registered_services"`
}

type RetryPolicy struct {
	RetryableStatusCodes []int         `json:"retryable_status_codes"`
	RetryableErrors      []string      `json:"retryable_errors"`
	MaxRetries           int           `json:"max_retries"`
	InitialBackoff       time.Duration `json:"initial_backoff"`
	MaxBackoff           time.Duration `json:"max_backoff"`
	BackoffMultiplier    float64       `json:"backoff_multiplier"`
}

type SecureHTTPClientConfig struct {
	UserAgent              string        `json:"user_agent"`
	MaxIdleConns           int           `json:"max_idle_conns"`
	ResponseTimeout        time.Duration `json:"response_timeout"`
	KeepAliveTimeout       time.Duration `json:"keepalive_timeout"`
	TLSHandshakeTimeout    time.Duration `json:"tls_handshake_timeout"`
	ConnectTimeout         time.Duration `json:"connect_timeout"`
	MaxIdleConnsPerHost    int           `json:"max_idle_conns_per_host"`
	MaxConnsPerHost        int           `json:"max_conns_per_host"`
	IdleConnTimeout        time.Duration `json:"idle_conn_timeout"`
	MaxResponseHeaderBytes int64         `json:"max_response_header_bytes"`
	RequestTimeout         time.Duration `json:"request_timeout"`
	InsecureSkipVerify     bool          `json:"insecure_skip_verify"`
	DisableCompression     bool          `json:"disable_compression"`
	DisableKeepAlives      bool          `json:"disable_keep_alives"`
}

type ServiceCache interface {
	Get(key string) ([]*ServiceInstance, bool)
	Set(key string, instances []*ServiceInstance, ttl time.Duration)
	Delete(key string)
	Clear()
	Stats() CacheStats
}

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

type ServiceClientConfig struct {
	// Strings (16 bytes) - largest first
	UserAgent string `json:"user_agent"`

	// 8-byte types
	DefaultTimeout time.Duration `json:"default_timeout"`
	RetryBackoff   time.Duration `json:"retry_backoff"`

	// 4-byte types
	MaxRetries int `json:"max_retries"`

	// Booleans (1 byte each) - smallest last
	EnableTracing        bool `json:"enable_tracing"`
	EnableMetrics        bool `json:"enable_metrics"`
	EnableCircuitBreaker bool `json:"enable_circuit_breaker"`
	TenantIsolation      bool `json:"tenant_isolation"`
}

type ServiceConfig struct {
	Created     time.Time         `json:"created"`
	LastSeen    time.Time         `json:"last_seen"`
	Metadata    map[string]string `json:"metadata"`
	Name        string            `json:"name"`
	Version     string            `json:"version"`
	TenantID    string            `json:"tenant_id,omitempty"`
	Region      string            `json:"region"`
	Environment string            `json:"environment"`
	Endpoints   []ServiceEndpoint `json:"endpoints"`
	Tags        []string          `json:"tags"`
	HealthCheck HealthCheckConfig `json:"health_check"`
	Weight      int               `json:"weight"`
}

type ServiceDiscovery interface {
	Register(ctx context.Context, config *ServiceConfig) error
	Deregister(ctx context.Context, serviceID string) error
	Discover(ctx context.Context, serviceName string) ([]*ServiceInstance, error)
	Watch(ctx context.Context, serviceName string) (<-chan []*ServiceInstance, error)
	HealthCheck(ctx context.Context, instance *ServiceInstance) (*HealthStatus, error)
}

type ServiceEndpoint struct {
	Metadata map[string]string `json:"metadata"`
	Protocol string            `json:"protocol"`
	Host     string            `json:"host"`
	Path     string            `json:"path"`
	Port     int               `json:"port"`
}

type ServiceInstance struct {
	LastSeen    time.Time         `json:"last_seen"`
	Metadata    map[string]string `json:"metadata"`
	Health      HealthStatus      `json:"health"`
	ID          string            `json:"id"`
	ServiceName string            `json:"service_name"`
	Version     string            `json:"version"`
	TenantID    string            `json:"tenant_id,omitempty"`
	Endpoint    ServiceEndpoint   `json:"endpoint"`
	Weight      int               `json:"weight"`
}

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

type ServiceRequest struct {
	Body                any                 `json:"body"`
	Headers             map[string]string   `json:"headers"`
	Metadata            map[string]any      `json:"metadata"`
	LoadBalanceStrategy LoadBalanceStrategy `json:"load_balance_strategy"`
	ServiceName         string              `json:"service_name"`
	Method              string              `json:"method"`
	Path                string              `json:"path"`
	TenantID            string              `json:"tenant_id,omitempty"`
	UserID              string              `json:"user_id,omitempty"`
	RequestID           string              `json:"request_id,omitempty"`
	Timeout             time.Duration       `json:"timeout"`
}

type ServiceResponse struct {
	Headers    map[string]string `json:"headers"`
	Metadata   map[string]any    `json:"metadata"`
	Instance   *ServiceInstance  `json:"instance"`
	Body       []byte            `json:"body"`
	Duration   time.Duration     `json:"duration"`
	StatusCode int               `json:"status_code"`
}

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

type UpdateUserRequest struct {
	Email    *string           `json:"email,omitempty"`
	Name     *string           `json:"name,omitempty"`
	Metadata map[string]string `json:"metadata,omitempty"`
}

type User struct {
	CreatedAt time.Time         `json:"created_at"`
	UpdatedAt time.Time         `json:"updated_at"`
	Metadata  map[string]string `json:"metadata"`
	ID        string            `json:"id"`
	Email     string            `json:"email"`
	Name      string            `json:"name"`
	TenantID  string            `json:"tenant_id"`
}

type UserFilters struct {
	TenantID string `json:"tenant_id,omitempty"`
	Email    string `json:"email,omitempty"`
	Limit    int    `json:"limit,omitempty"`
	Offset   int    `json:"offset,omitempty"`
}

type UserList struct {
	Users  []*User `json:"users"`
	Total  int     `json:"total"`
	Limit  int     `json:"limit"`
	Offset int     `json:"offset"`
}

type UserService interface {
	GetUser(ctx context.Context, userID string) (*User, error)
	CreateUser(ctx context.Context, user *CreateUserRequest) (*User, error)
	UpdateUser(ctx context.Context, userID string, updates *UpdateUserRequest) (*User, error)
	DeleteUser(ctx context.Context, userID string) error
	ListUsers(ctx context.Context, filters *UserFilters) (*UserList, error)
}

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

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