infra

type AckPolicy int

type Config struct {
	// Vector (Qdrant) configuration
	Vector VectorConfig

	// KV (Valkey/Redis) configuration
	KV KVConfig

	// Storage (MinIO) configuration
	Storage StorageConfig

	// Search (Meilisearch) configuration
	Search SearchConfig

	// PubSub (NATS) configuration
	PubSub PubSubConfig

	// Tasks (Temporal) configuration
	Tasks TasksConfig

	// Global settings
	ConnectTimeout time.Duration
	RetryAttempts  int
	RetryDelay     time.Duration
}

type ConsumerConfig struct {
	Name          string
	Durable       string
	Description   string
	FilterSubject string
	DeliverPolicy DeliverPolicy
	AckPolicy     AckPolicy
	AckWait       time.Duration
	MaxDeliver    int
	MaxAckPending int
}

type DeliverPolicy int

type DocumentsResult struct {
	Results []map[string]interface{}
	Offset  int
	Limit   int
	Total   int
}

type GetDocumentsOptions struct {
	Offset int
	Limit  int
	Fields []string
}

type HealthStatus struct {
	Healthy bool          `json:"healthy"`
	Latency time.Duration `json:"latency"`
	Error   string        `json:"error,omitempty"`
}

type IndexSettings struct {
	SearchableAttributes []string
	FilterableAttributes []string
	SortableAttributes   []string
	RankingRules         []string
	StopWords            []string
	Synonyms             map[string][]string
	DistinctAttribute    string
}

type IndexStats struct {
	NumberOfDocuments int
	IsIndexing        bool
	FieldDistribution map[string]int64
}

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

type KVConfig struct {
	// Enabled enables the KV service
	Enabled bool

	// Addr is the Valkey server address (host:port)
	Addr string

	// Password for authentication (optional)
	Password string

	// DB is the database number to use
	DB int

	// TLS enables TLS connection
	TLS bool

	// PoolSize is the connection pool size
	PoolSize int

	// MinIdleConns minimum idle connections
	MinIdleConns int

	// ConnMaxIdleTime maximum idle time for connections
	ConnMaxIdleTime time.Duration

	// ReadTimeout for read operations
	ReadTimeout time.Duration

	// WriteTimeout for write operations
	WriteTimeout time.Duration

	// KeyPrefix is prepended to all keys
	KeyPrefix string
}

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

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

type Message struct {
	Subject string
	Reply   string
	Data    []byte
	// contains filtered or unexported fields
}

type MessageMetadata struct {
	Sequence   uint64
	Timestamp  time.Time
	NumPending uint64
}

type ObjectInfo struct {
	Key          string
	Size         int64
	ContentType  string
	ETag         string
	LastModified time.Time
	Metadata     map[string]string
}

type PubAck struct {
	Stream   string
	Sequence uint64
	Domain   string
}

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

type PubSubConfig struct {
	// Enabled enables the pubsub service
	Enabled bool

	// URL is the NATS server URL
	URL string

	// Name is the client name
	Name string

	// Token for authentication (optional)
	Token string

	// User for authentication (optional)
	User string

	// Password for authentication (optional)
	Password string

	// TLS enables TLS connection
	TLS bool

	// ReconnectWait is the wait time between reconnects
	ReconnectWait time.Duration

	// MaxReconnects is the maximum reconnection attempts
	MaxReconnects int

	// EnableJetStream enables JetStream for persistence
	EnableJetStream bool
}

type RetentionPolicy int

type RetryPolicy struct {
	InitialInterval    time.Duration
	BackoffCoefficient float64
	MaximumInterval    time.Duration
	MaximumAttempts    int32
}

type RetryPolicyInternal struct {
	InitialInterval    time.Duration
	BackoffCoefficient float64
	MaximumInterval    time.Duration
	MaximumAttempts    int32
}

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

type SearchConfig struct {
	// Enabled enables the search service
	Enabled bool

	// Host is the Meilisearch server URL
	Host string

	// APIKey for authentication
	APIKey string

	// DefaultIndex is the default search index
	DefaultIndex string

	// Timeout for requests
	Timeout time.Duration
}

type SearchOptions struct {
	Index                 string
	Query                 string
	Offset                int
	Limit                 int
	Filter                interface{}
	Sort                  []string
	Facets                []string
	AttributesToRetrieve  []string
	AttributesToCrop      []string
	CropLength            int
	AttributesToHighlight []string
	HighlightPreTag       string
	HighlightPostTag      string
	ShowMatchesPosition   bool
}

type SearchResult struct {
	Hits              []interface{}
	NbHits            int64
	Offset            int
	Limit             int
	ProcessingTimeMs  int64
	Query             string
	FacetDistribution map[string]interface{}
}

type StartWorkflowOptions struct {
	ID               string
	TaskQueue        string
	ExecutionTimeout time.Duration
	RunTimeout       time.Duration
	TaskTimeout      time.Duration
	CronSchedule     string
	SearchAttributes map[string]interface{}
	Memo             map[string]interface{}
	RetryPolicy      *RetryPolicy
}

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

type StorageConfig struct {
	// Enabled enables the storage service
	Enabled bool

	// Endpoint is the MinIO server endpoint (host:port)
	Endpoint string

	// AccessKey is the access key ID
	AccessKey string

	// SecretKey is the secret access key
	SecretKey string

	// UseSSL enables SSL connection
	UseSSL bool

	// Bucket is the default bucket name
	Bucket string

	// Region is the bucket region
	Region string

	// PublicBaseURL is the public URL base for assets
	PublicBaseURL string
}

type StorageType int

type StreamConfig struct {
	Name        string
	Description string
	Subjects    []string
	Retention   RetentionPolicy
	MaxAge      time.Duration
	MaxBytes    int64
	MaxMsgs     int64
	Storage     StorageType
	Replicas    int
}

type StreamMessage struct {
	Subject  string
	Data     []byte
	Headers  map[string][]string
	Metadata *MessageMetadata
	// contains filtered or unexported fields
}

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

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

type TasksConfig struct {
	// Enabled enables the tasks service
	Enabled bool

	// HostPort is the Temporal server address
	HostPort string

	// Namespace is the Temporal namespace
	Namespace string

	// Identity is the worker identity
	Identity string

	// TaskQueue is the default task queue
	TaskQueue string

	// TLS configuration
	TLS *TasksTLSConfig
}

type TasksTLSConfig struct {
	// CertPath is the path to the client certificate
	CertPath string

	// KeyPath is the path to the client key
	KeyPath string

	// CACertPath is the path to the CA certificate
	CACertPath string

	// ServerName for TLS verification
	ServerName string
}

type UploadOptions struct {
	Bucket      string
	Key         string
	Reader      io.Reader
	Size        int64
	ContentType string
	Metadata    map[string]string
}

type UploadResult struct {
	Bucket   string
	Key      string
	ETag     string
	Size     int64
	Location string
}

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

type VectorConfig struct {
	// Enabled enables the vector service
	Enabled bool

	// Host is the Qdrant server host
	Host string

	// Port is the Qdrant HTTP port (default: 6333)
	Port int

	// APIKey for authentication (optional)
	APIKey string

	// UseTLS enables TLS connection
	UseTLS bool

	// DefaultCollection is the default collection name
	DefaultCollection string

	// DefaultDimensions is the default vector dimensions (1536 for OpenAI)
	DefaultDimensions uint64
}

type VectorPoint struct {
	ID      string
	Vector  []float32
	Payload map[string]interface{}
}

type VectorSearchOpts struct {
	Collection string
	Vector     []float32
	Limit      int
	MinScore   float32
	Filter     map[string]interface{}
}

type VectorSearchResult struct {
	ID      string
	Score   float32
	Payload map[string]interface{}
}

type WorkerOptions struct {
	MaxConcurrentActivities      int
	MaxConcurrentWorkflows       int
	MaxConcurrentLocalActivities int
	ActivitiesPerSecond          float64
	LocalActivitiesPerSecond     float64
	TaskQueueActivitiesPerSecond float64
	EnableSessionWorker          bool
}

type WorkflowRun struct {
	ID    string
	RunID string
	// contains filtered or unexported fields
}

type ZAPConfig struct {
	Enabled bool
	NodeID  string
	Port    int
}

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