logs

type ActionTargetBuilder struct {
	Label         string            `json:"label"`
	LabelSelector string            `json:"label_selector"`
	Paths         []string          `json:"paths"`
	Selectors     map[string]string `json:"selectors"`
}

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

type CreateSessionOptions struct {
	ResourceKey  string                 `json:"resource_key"`
	ResourceID   string                 `json:"resource_id"`
	ResourceData map[string]interface{} `json:"resource_data"`
	Options      LogSessionOptions      `json:"options"`
}

type Handler struct {
	Plugin        string              `json:"plugin"`
	Resource      string              `json:"resource"`
	TargetBuilder ActionTargetBuilder `json:"target_builder"`
	Handler       LogHandlerFunc      `json:"-"`
	SourceBuilder SourceBuilderFunc   `json:"-"`
}

type LogHandlerFunc func(ctx *types.PluginContext, req LogStreamRequest) (io.ReadCloser, error)

type LogLevel int

type LogLine struct {
	SessionID string            `json:"session_id"`
	SourceID  string            `json:"source_id"`
	Labels    map[string]string `json:"labels"`
	Timestamp time.Time         `json:"timestamp"`
	Content   string            `json:"content"`
	Origin    LogLineOrigin     `json:"origin"`
	Level     LogLevel          `json:"level"`
}

type LogLineOrigin int

type LogSession struct {
	ID            string            `json:"id"`
	PluginID      string            `json:"plugin_id"`
	ConnectionID  string            `json:"connection_id"`
	ResourceKey   string            `json:"resource_key"`
	ResourceID    string            `json:"resource_id"`
	Options       LogSessionOptions `json:"options"`
	Status        LogSessionStatus  `json:"status"`
	ActiveSources []LogSource       `json:"active_sources"`
	CreatedAt     time.Time         `json:"created_at"`
}

type LogSessionOptions struct {
	Target              string            `json:"target"`
	Follow              bool              `json:"follow"`
	IncludePrevious     bool              `json:"include_previous"`
	IncludeTimestamps   bool              `json:"include_timestamps"`
	TailLines           int64             `json:"tail_lines"`
	SinceSeconds        int64             `json:"since_seconds"`
	SinceTime           *time.Time        `json:"since_time,omitempty"`
	LimitBytes          int64             `json:"limit_bytes"`
	IncludeSourceEvents bool              `json:"include_source_events"`
	Params              map[string]string `json:"params"`
}

type LogSessionStatus int

type LogSource struct {
	ID     string            `json:"id"`
	Labels map[string]string `json:"labels"`
}

type LogStreamCommand int

type LogStreamEvent struct {
	Type      LogStreamEventType `json:"type"`
	SourceID  string             `json:"source_id"`
	Message   string             `json:"message"`
	Timestamp time.Time          `json:"timestamp"`
}

type LogStreamEventType int

type LogStreamRequest struct {
	SourceID          string
	Labels            map[string]string
	ResourceData      map[string]interface{}
	Target            string
	Follow            bool
	IncludePrevious   bool
	IncludeTimestamps bool
	TailLines         int64
	SinceSeconds      int64
	SinceTime         *time.Time
	LimitBytes        int64
	Params            map[string]string
}

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

type ManagerConfig struct {
	Logger    logging.Logger
	Settings  settings.Provider
	Handlers  map[string]Handler
	Resolvers map[string]SourceResolver
	Sink      OutputSink     // optional: nil → ChannelSink created by Stream()
	Clock     timeutil.Clock // optional: nil → timeutil.RealClock
}

type OutputSink interface {
	OnLine(line LogLine)
	OnEvent(sessionID string, event LogStreamEvent)
}

type Plugin struct {
	plugin.Plugin
	Impl Provider
}

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

type PluginOpts struct {
	// Handlers maps resource keys to their log handlers.
	// For example: "core::v1::Pod" -> Handler
	Handlers map[string]Handler `json:"handlers"`

	// SourceResolvers maps resource keys to source resolvers that resolve
	// group resources into individual log sources.
	// For example: "apps::v1::Deployment" -> SourceResolver
	SourceResolvers map[string]SourceResolver `json:"-"`
}

type PluginServer struct {
	Impl Provider
	// contains filtered or unexported fields
}

type Provider interface {
	GetSupportedResources(ctx *types.PluginContext) []Handler
	CreateSession(ctx *types.PluginContext, opts CreateSessionOptions) (*LogSession, error)
	GetSession(ctx *types.PluginContext, sessionID string) (*LogSession, error)
	ListSessions(ctx *types.PluginContext) ([]*LogSession, error)
	CloseSession(ctx *types.PluginContext, sessionID string) error
	UpdateSessionOptions(ctx *types.PluginContext, sessionID string, opts LogSessionOptions) (*LogSession, error)
	Stream(ctx context.Context, in chan StreamInput) (chan StreamOutput, error)
}

type SourceBuilderFunc func(
	resourceID string,
	resourceData map[string]interface{},
	opts LogSessionOptions,
) []LogSource

type SourceEvent struct {
	Type   SourceEventType
	Source LogSource
}

type SourceEventType int

type SourceResolver func(
	ctx *types.PluginContext,
	resourceData map[string]interface{},
	opts SourceResolverOptions,
) (*SourceResolverResult, error)

type SourceResolverOptions struct {
	Watch  bool              // if true, also return a channel for source changes
	Target string            // optional filter (e.g., specific container name)
	Params map[string]string // plugin-specific resolver params
}

type SourceResolverResult struct {
	Sources []LogSource        // current sources
	Events  <-chan SourceEvent // source lifecycle stream (nil if Watch=false)
}

type StreamInput struct {
	SessionID string           `json:"session_id"`
	Command   LogStreamCommand `json:"command"`
}

type StreamOutput struct {
	SessionID string
	Line      *LogLine
	Event     *LogStreamEvent
}