monolog

type Config struct {
	// TCP server address (default port 9913)
	Addr string `mapstructure:"addr"`
	// Connection read timeout
	ReadTimeout time.Duration `mapstructure:"read_timeout"`
	// Maximum message size in bytes
	MaxMessageSize int64 `mapstructure:"max_message_size"`

	// Jobs integration
	Jobs JobsConfig `mapstructure:"jobs"`
}

type Configurer interface {
	// UnmarshalKey takes a single key and unmarshal it into a Struct
	UnmarshalKey(name string, out any) error
	// Has checks if a config section exists
	Has(name string) bool
}

type Job struct {
	// Job contains name of job broker (usually PHP class)
	Job string `json:"job"`
	// Ident is unique identifier of the job
	Ident string `json:"id"`
	// Pld is the payload (usually JSON)
	Pld []byte `json:"payload"`
	// Hdr contains headers with key-value pairs
	Hdr map[string][]string `json:"headers"`
	// Options contains job execution options
	Options *JobOptions `json:"options,omitempty"`
}

type JobOptions struct {
	// Priority is job priority, default - 10
	Priority int64 `json:"priority"`
	// Pipeline manually specified pipeline
	Pipeline string `json:"pipeline,omitempty"`
	// Delay defines time duration to delay execution for
	Delay int64 `json:"delay,omitempty"`
	// AutoAck use to ack a job right after it arrived from the driver
	AutoAck bool `json:"auto_ack"`
}

type Jobs interface {
	Push(ctx context.Context, msg jobs.Message) error
}

type JobsConfig struct {
	Pipeline string `mapstructure:"pipeline"` // Target pipeline in Jobs
	Priority int64  `mapstructure:"priority"` // Default priority for jobs
	Delay    int64  `mapstructure:"delay"`    // Default delay (0 = immediate)
	AutoAck  bool   `mapstructure:"auto_ack"` // Auto-acknowledge jobs
}

type LogRecord struct {
	Event      string         `json:"event"`             // Always "LOG_RECEIVED"
	UUID       string         `json:"uuid"`              // Unique log record identifier
	ClientID   int            `json:"client_id"`         // TCP connection ID
	RemoteAddr string         `json:"remote_addr"`       // Client IP:port
	ReceivedAt time.Time      `json:"received_at"`       // Server timestamp
	Payload    map[string]any `json:"payload"`           // Parsed Monolog JSON record
	Project    *string        `json:"project,omitempty"` // Project name (from context)
	Error      *string        `json:"error,omitempty"`   // Parse error if any
}

type Logger interface {
	NamedLogger(name string) *zap.Logger
}

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