plugin

type AuthContext struct {
	UserID      string
	AccountID   string
	ARN         string
	AccessKeyID string
	IsRoot      bool
	Roles       []string
	Claims      map[string]string
}

type Descriptor struct {
	Name     string            // e.g., "s3", "kubernetes", "argocd"
	Version  string            // semver
	Protocol string            // "aws-json", "aws-query", "k8s-api", "argocd-api"
	Actions  []string          // supported operations
	APIPaths []string          // URL path patterns for path-based routing
	Metadata map[string]string // arbitrary metadata
}

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

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

type GRPCBridgeConfig struct {
	// BinaryPath is the path to the plugin executable.
	BinaryPath string
	// Args are additional command-line arguments.
	Args []string
	// Addr is the address the plugin will listen on (e.g., "localhost:0" for auto-assign).
	// If empty, the bridge will use a Unix socket.
	Addr string
}

type HealthCheckResult struct {
	Name    string       `json:"name"`
	Status  HealthStatus `json:"status"`
	Message string       `json:"message,omitempty"`
}

type HealthStatus int

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

type Plugin interface {
	// Init is called once when the plugin is loaded.
	Init(ctx context.Context, config []byte, dataDir string, logLevel string) error

	// Shutdown is called when the core is stopping.
	Shutdown(ctx context.Context) error

	// HealthCheck returns the plugin's current health status.
	HealthCheck(ctx context.Context) (HealthStatus, string, error)

	// Describe returns the plugin's metadata and routing rules.
	Describe(ctx context.Context) (*Descriptor, error)

	// HandleRequest processes a single request.
	HandleRequest(ctx context.Context, req *Request) (*Response, error)
}

type PluginInfo struct {
	Name      string            `json:"name"`
	Version   string            `json:"version"`
	Protocol  string            `json:"protocol"`
	Mode      string            `json:"mode"`
	Healthy   bool              `json:"healthy"`
	Actions   []string          `json:"actions"`
	APIPaths  []string          `json:"api_paths,omitempty"`
	Metadata  map[string]string `json:"metadata,omitempty"`
	LastCheck time.Time         `json:"last_check"`
}

type PluginMode int

type Request struct {
	Action      string
	Body        []byte
	Headers     map[string]string
	QueryParams map[string]string
	Path        string
	Method      string
	Auth        *AuthContext
}

type Response struct {
	StatusCode int
	Body       []byte
	Headers    map[string]string
}

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

type StreamingPlugin interface {
	Plugin
	// StreamRequest processes a request that produces multiple responses.
	StreamRequest(ctx context.Context, req *Request, send func(*Response) error) error
}