pftools

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

type CircuitState int

type ClusterErrorHandler func(*PulsarFunctionManager, error)

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

type FunctionResult struct {
	Data  string
	Error error
}

type FunctionTool struct {
	Name               string
	Function           *utils.FunctionConfig
	InputSchema        *SchemaInfo
	OutputSchema       *SchemaInfo
	InputTopic         string
	OutputTopic        string
	Tool               mcp.Tool
	SchemaFetchSuccess bool
}

type ManagerOptions struct {
	PollInterval        time.Duration
	DefaultTimeout      time.Duration
	FailureThreshold    int
	ResetTimeout        time.Duration
	TenantNamespaces    []string
	StrictExport        bool
	ClusterErrorHandler ClusterErrorHandler
}

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

type SchemaInfo struct {
	Type             string
	Definition       map[string]interface{}
	PulsarSchemaInfo *utils.SchemaInfo
}

type Server struct {
	MCPServer     *server.MCPServer
	KafkaSession  *kafka.Session
	PulsarSession *pulsar.Session
	Logger        interface{}
}